datacollector

package
v0.0.0-...-69fe9f8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 21, 2019 License: Apache-2.0 Imports: 6 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterDataCollectorServiceServer 

func RegisterDataCollectorServiceServer(s *grpc.Server, srv DataCollectorServiceServer)

Types

type Config 

type Config struct {
	Data                 []*DataSet `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*Config) Descriptor 

func (*Config) Descriptor() ([]byte, []int)

func (*Config) GetData 

func (m *Config) GetData() []*DataSet

func (*Config) ProtoMessage 

func (*Config) ProtoMessage()

func (*Config) Reset 

func (m *Config) Reset()

func (*Config) String 

func (m *Config) String() string

func (*Config) XXX_DiscardUnknown 

func (m *Config) XXX_DiscardUnknown()

func (*Config) XXX_Marshal 

func (m *Config) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Config) XXX_Merge 

func (m *Config) XXX_Merge(src proto.Message)

func (*Config) XXX_Size 

func (m *Config) XXX_Size() int

func (*Config) XXX_Unmarshal 

func (m *Config) XXX_Unmarshal(b []byte) error

type DataCollectorServiceClient 

type DataCollectorServiceClient interface {
	GetDataSets(ctx context.Context, in *GetDataSetsRequest, opts ...grpc.CallOption) (*GetDataSetsResponse, error)
}

DataCollectorServiceClient is the client API for DataCollectorService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDataCollectorServiceClient 

func NewDataCollectorServiceClient(cc *grpc.ClientConn) DataCollectorServiceClient

type DataCollectorServiceServer 

type DataCollectorServiceServer interface {
	GetDataSets(context.Context, *GetDataSetsRequest) (*GetDataSetsResponse, error)
}

DataCollectorServiceServer is the server API for DataCollectorService service.

type DataSet 

type DataSet struct {
	JobName              string     `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	Identifier           string     `protobuf:"bytes,2,opt,name=identifier,proto3" json:"identifier,omitempty"`
	Readings             []*Reading `protobuf:"bytes,3,rep,name=readings,proto3" json:"readings,omitempty"`
	Staging              []*Reading `protobuf:"bytes,5,rep,name=staging,proto3" json:"staging,omitempty"`
	SpecName             string     `protobuf:"bytes,4,opt,name=spec_name,json=specName,proto3" json:"spec_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*DataSet) Descriptor 

func (*DataSet) Descriptor() ([]byte, []int)

func (*DataSet) GetIdentifier 

func (m *DataSet) GetIdentifier() string

func (*DataSet) GetJobName 

func (m *DataSet) GetJobName() string

func (*DataSet) GetReadings 

func (m *DataSet) GetReadings() []*Reading

func (*DataSet) GetSpecName 

func (m *DataSet) GetSpecName() string

func (*DataSet) GetStaging 

func (m *DataSet) GetStaging() []*Reading

func (*DataSet) ProtoMessage 

func (*DataSet) ProtoMessage()

func (*DataSet) Reset 

func (m *DataSet) Reset()

func (*DataSet) String 

func (m *DataSet) String() string

func (*DataSet) XXX_DiscardUnknown 

func (m *DataSet) XXX_DiscardUnknown()

func (*DataSet) XXX_Marshal 

func (m *DataSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataSet) XXX_Merge 

func (m *DataSet) XXX_Merge(src proto.Message)

func (*DataSet) XXX_Size 

func (m *DataSet) XXX_Size() int

func (*DataSet) XXX_Unmarshal 

func (m *DataSet) XXX_Unmarshal(b []byte) error

type GetDataSetsRequest 

type GetDataSetsRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetDataSetsRequest) Descriptor 

func (*GetDataSetsRequest) Descriptor() ([]byte, []int)

func (*GetDataSetsRequest) ProtoMessage 

func (*GetDataSetsRequest) ProtoMessage()

func (*GetDataSetsRequest) Reset 

func (m *GetDataSetsRequest) Reset()

func (*GetDataSetsRequest) String 

func (m *GetDataSetsRequest) String() string

func (*GetDataSetsRequest) XXX_DiscardUnknown 

func (m *GetDataSetsRequest) XXX_DiscardUnknown()

func (*GetDataSetsRequest) XXX_Marshal 

func (m *GetDataSetsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetDataSetsRequest) XXX_Merge 

func (m *GetDataSetsRequest) XXX_Merge(src proto.Message)

func (*GetDataSetsRequest) XXX_Size 

func (m *GetDataSetsRequest) XXX_Size() int

func (*GetDataSetsRequest) XXX_Unmarshal 

func (m *GetDataSetsRequest) XXX_Unmarshal(b []byte) error

type GetDataSetsResponse 

type GetDataSetsResponse struct {
	DataSets             []*DataSet `protobuf:"bytes,1,rep,name=data_sets,json=dataSets,proto3" json:"data_sets,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*GetDataSetsResponse) Descriptor 

func (*GetDataSetsResponse) Descriptor() ([]byte, []int)

func (*GetDataSetsResponse) GetDataSets 

func (m *GetDataSetsResponse) GetDataSets() []*DataSet

func (*GetDataSetsResponse) ProtoMessage 

func (*GetDataSetsResponse) ProtoMessage()

func (*GetDataSetsResponse) Reset 

func (m *GetDataSetsResponse) Reset()

func (*GetDataSetsResponse) String 

func (m *GetDataSetsResponse) String() string

func (*GetDataSetsResponse) XXX_DiscardUnknown 

func (m *GetDataSetsResponse) XXX_DiscardUnknown()

func (*GetDataSetsResponse) XXX_Marshal 

func (m *GetDataSetsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetDataSetsResponse) XXX_Merge 

func (m *GetDataSetsResponse) XXX_Merge(src proto.Message)

func (*GetDataSetsResponse) XXX_Size 

func (m *GetDataSetsResponse) XXX_Size() int

func (*GetDataSetsResponse) XXX_Unmarshal 

func (m *GetDataSetsResponse) XXX_Unmarshal(b []byte) error

type ReadConfig 

type ReadConfig struct {
	Spec                 []*ReadSpec `protobuf:"bytes,1,rep,name=spec,proto3" json:"spec,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*ReadConfig) Descriptor 

func (*ReadConfig) Descriptor() ([]byte, []int)

func (*ReadConfig) GetSpec 

func (m *ReadConfig) GetSpec() []*ReadSpec

func (*ReadConfig) ProtoMessage 

func (*ReadConfig) ProtoMessage()

func (*ReadConfig) Reset 

func (m *ReadConfig) Reset()

func (*ReadConfig) String 

func (m *ReadConfig) String() string

func (*ReadConfig) XXX_DiscardUnknown 

func (m *ReadConfig) XXX_DiscardUnknown()

func (*ReadConfig) XXX_Marshal 

func (m *ReadConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadConfig) XXX_Merge 

func (m *ReadConfig) XXX_Merge(src proto.Message)

func (*ReadConfig) XXX_Size 

func (m *ReadConfig) XXX_Size() int

func (*ReadConfig) XXX_Unmarshal 

func (m *ReadConfig) XXX_Unmarshal(b []byte) error

type ReadSpec 

type ReadSpec struct {
	MeasureKey           string   `protobuf:"bytes,1,opt,name=measure_key,json=measureKey,proto3" json:"measure_key,omitempty"`
	JobName              string   `protobuf:"bytes,2,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	Name                 string   `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReadSpec) Descriptor 

func (*ReadSpec) Descriptor() ([]byte, []int)

func (*ReadSpec) GetJobName 

func (m *ReadSpec) GetJobName() string

func (*ReadSpec) GetMeasureKey 

func (m *ReadSpec) GetMeasureKey() string

func (*ReadSpec) GetName 

func (m *ReadSpec) GetName() string

func (*ReadSpec) ProtoMessage 

func (*ReadSpec) ProtoMessage()

func (*ReadSpec) Reset 

func (m *ReadSpec) Reset()

func (*ReadSpec) String 

func (m *ReadSpec) String() string

func (*ReadSpec) XXX_DiscardUnknown 

func (m *ReadSpec) XXX_DiscardUnknown()

func (*ReadSpec) XXX_Marshal 

func (m *ReadSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadSpec) XXX_Merge 

func (m *ReadSpec) XXX_Merge(src proto.Message)

func (*ReadSpec) XXX_Size 

func (m *ReadSpec) XXX_Size() int

func (*ReadSpec) XXX_Unmarshal 

func (m *ReadSpec) XXX_Unmarshal(b []byte) error

type Reading 

type Reading struct {
	Timestamp            int64         `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Measure              *proto1.State `protobuf:"bytes,2,opt,name=measure,proto3" json:"measure,omitempty"`
	Collapsed            bool          `protobuf:"varint,3,opt,name=collapsed,proto3" json:"collapsed,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*Reading) Descriptor 

func (*Reading) Descriptor() ([]byte, []int)

func (*Reading) GetCollapsed 

func (m *Reading) GetCollapsed() bool

func (*Reading) GetMeasure 

func (m *Reading) GetMeasure() *proto1.State

func (*Reading) GetTimestamp 

func (m *Reading) GetTimestamp() int64

func (*Reading) ProtoMessage 

func (*Reading) ProtoMessage()

func (*Reading) Reset 

func (m *Reading) Reset()

func (*Reading) String 

func (m *Reading) String() string

func (*Reading) XXX_DiscardUnknown 

func (m *Reading) XXX_DiscardUnknown()

func (*Reading) XXX_Marshal 

func (m *Reading) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Reading) XXX_Merge 

func (m *Reading) XXX_Merge(src proto.Message)

func (*Reading) XXX_Size 

func (m *Reading) XXX_Size() int

func (*Reading) XXX_Unmarshal 

func (m *Reading) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.