datastore

package
v0.0.0-...-7c66ffc Latest Latest
Warning

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

 Go to latest Published: Jun 24, 2020 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterDataStoreServer 

func RegisterDataStoreServer(s *grpc.Server, srv DataStoreServer)

Types

type DataFilter 

type DataFilter struct {
	CollectionId         string   `protobuf:"bytes,1,opt,name=collectionId,proto3" json:"collectionId,omitempty"`
	DeviceId             string   `protobuf:"bytes,2,opt,name=deviceId,proto3" json:"deviceId,omitempty"`
	From                 int64    `protobuf:"varint,3,opt,name=from,proto3" json:"from,omitempty"`
	To                   int64    `protobuf:"varint,4,opt,name=to,proto3" json:"to,omitempty"`
	Limit                int32    `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

DataFilter is the filtering parameters for data. collectionId is

func (*DataFilter) Descriptor 

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

func (*DataFilter) GetCollectionId 

func (m *DataFilter) GetCollectionId() string

func (*DataFilter) GetDeviceId 

func (m *DataFilter) GetDeviceId() string

func (*DataFilter) GetFrom 

func (m *DataFilter) GetFrom() int64

func (*DataFilter) GetLimit 

func (m *DataFilter) GetLimit() int32

func (*DataFilter) GetTo 

func (m *DataFilter) GetTo() int64

func (*DataFilter) ProtoMessage 

func (*DataFilter) ProtoMessage()

func (*DataFilter) Reset 

func (m *DataFilter) Reset()

func (*DataFilter) String 

func (m *DataFilter) String() string

func (*DataFilter) XXX_DiscardUnknown 

func (m *DataFilter) XXX_DiscardUnknown()

func (*DataFilter) XXX_Marshal 

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

func (*DataFilter) XXX_Merge 

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

func (*DataFilter) XXX_Size 

func (m *DataFilter) XXX_Size() int

func (*DataFilter) XXX_Unmarshal 

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

type DataMessage 

type DataMessage struct {
	Sequence int64 `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// sequence number assigned by the sender.
	CollectionId         string   `protobuf:"bytes,2,opt,name=collectionId,proto3" json:"collectionId,omitempty"`
	DeviceId             string   `protobuf:"bytes,3,opt,name=deviceId,proto3" json:"deviceId,omitempty"`
	Created              int64    `protobuf:"varint,4,opt,name=created,proto3" json:"created,omitempty"`
	Metadata             []byte   `protobuf:"bytes,5,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Payload              []byte   `protobuf:"bytes,6,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

DataMessage is both the input and the output from the data store. The sequence numbers aren't message identifiers. They are just counters for messages to keep track of acknowledgements.

func (*DataMessage) Descriptor 

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

func (*DataMessage) GetCollectionId 

func (m *DataMessage) GetCollectionId() string

func (*DataMessage) GetCreated 

func (m *DataMessage) GetCreated() int64

func (*DataMessage) GetDeviceId 

func (m *DataMessage) GetDeviceId() string

func (*DataMessage) GetMetadata 

func (m *DataMessage) GetMetadata() []byte

func (*DataMessage) GetPayload 

func (m *DataMessage) GetPayload() []byte

func (*DataMessage) GetSequence 

func (m *DataMessage) GetSequence() int64

func (*DataMessage) ProtoMessage 

func (*DataMessage) ProtoMessage()

func (*DataMessage) Reset 

func (m *DataMessage) Reset()

func (*DataMessage) String 

func (m *DataMessage) String() string

func (*DataMessage) XXX_DiscardUnknown 

func (m *DataMessage) XXX_DiscardUnknown()

func (*DataMessage) XXX_Marshal 

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

func (*DataMessage) XXX_Merge 

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

func (*DataMessage) XXX_Size 

func (m *DataMessage) XXX_Size() int

func (*DataMessage) XXX_Unmarshal 

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

type DataMetrics 

type DataMetrics struct {
	CollectionId         string   `protobuf:"bytes,1,opt,name=collectionId,proto3" json:"collectionId,omitempty"`
	DeviceId             string   `protobuf:"bytes,2,opt,name=deviceId,proto3" json:"deviceId,omitempty"`
	MessageCount         int64    `protobuf:"varint,3,opt,name=messageCount,proto3" json:"messageCount,omitempty"`
	FirstDataPoint       int64    `protobuf:"varint,4,opt,name=firstDataPoint,proto3" json:"firstDataPoint,omitempty"`
	LastDataPoint        int64    `protobuf:"varint,5,opt,name=lastDataPoint,proto3" json:"lastDataPoint,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DataMetrics) Descriptor 

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

func (*DataMetrics) GetCollectionId 

func (m *DataMetrics) GetCollectionId() string

func (*DataMetrics) GetDeviceId 

func (m *DataMetrics) GetDeviceId() string

func (*DataMetrics) GetFirstDataPoint 

func (m *DataMetrics) GetFirstDataPoint() int64

func (*DataMetrics) GetLastDataPoint 

func (m *DataMetrics) GetLastDataPoint() int64

func (*DataMetrics) GetMessageCount 

func (m *DataMetrics) GetMessageCount() int64

func (*DataMetrics) ProtoMessage 

func (*DataMetrics) ProtoMessage()

func (*DataMetrics) Reset 

func (m *DataMetrics) Reset()

func (*DataMetrics) String 

func (m *DataMetrics) String() string

func (*DataMetrics) XXX_DiscardUnknown 

func (m *DataMetrics) XXX_DiscardUnknown()

func (*DataMetrics) XXX_Marshal 

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

func (*DataMetrics) XXX_Merge 

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

func (*DataMetrics) XXX_Size 

func (m *DataMetrics) XXX_Size() int

func (*DataMetrics) XXX_Unmarshal 

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

type DataStoreClient 

type DataStoreClient interface {
	// PutData stores messages. Messages are acknowledged when they are written
	// to the underlying data store (whatever that may be).
	PutData(ctx context.Context, opts ...grpc.CallOption) (DataStore_PutDataClient, error)
	// GetData returns data from either a collection (if just collection ID is
	// specified) or a particular device (if both collection ID and device ID is
	// supplied)
	GetData(ctx context.Context, in *DataFilter, opts ...grpc.CallOption) (DataStore_GetDataClient, error)
	// GetDataMetrics returns metrics on data stored. Filtering works similar to
	// the GetData method
	GetDataMetrics(ctx context.Context, in *DataFilter, opts ...grpc.CallOption) (*DataMetrics, error)
	// StoreData is a simpler version of the PutData interface. It's not as
	// performant but easier to implement.
	StoreData(ctx context.Context, in *DataMessage, opts ...grpc.CallOption) (*Receipt, error)
}

DataStoreClient is the client API for DataStore service.

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

func NewDataStoreClient 

func NewDataStoreClient(cc *grpc.ClientConn) DataStoreClient

type DataStoreServer 

type DataStoreServer interface {
	// PutData stores messages. Messages are acknowledged when they are written
	// to the underlying data store (whatever that may be).
	PutData(DataStore_PutDataServer) error
	// GetData returns data from either a collection (if just collection ID is
	// specified) or a particular device (if both collection ID and device ID is
	// supplied)
	GetData(*DataFilter, DataStore_GetDataServer) error
	// GetDataMetrics returns metrics on data stored. Filtering works similar to
	// the GetData method
	GetDataMetrics(context.Context, *DataFilter) (*DataMetrics, error)
	// StoreData is a simpler version of the PutData interface. It's not as
	// performant but easier to implement.
	StoreData(context.Context, *DataMessage) (*Receipt, error)
}

DataStoreServer is the server API for DataStore service.

type DataStore_GetDataClient 

type DataStore_GetDataClient interface {
	Recv() (*DataMessage, error)
	grpc.ClientStream
}

type DataStore_GetDataServer 

type DataStore_GetDataServer interface {
	Send(*DataMessage) error
	grpc.ServerStream
}

type DataStore_PutDataClient 

type DataStore_PutDataClient interface {
	Send(*DataMessage) error
	Recv() (*Receipt, error)
	grpc.ClientStream
}

type DataStore_PutDataServer 

type DataStore_PutDataServer interface {
	Send(*Receipt) error
	Recv() (*DataMessage, error)
	grpc.ServerStream
}

type Receipt 

type Receipt struct {
	Sequence             int64    `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Receipt messages are sent by the data store to acknowledge receiption of messages.

func (*Receipt) Descriptor 

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

func (*Receipt) GetSequence 

func (m *Receipt) GetSequence() int64

func (*Receipt) ProtoMessage 

func (*Receipt) ProtoMessage()

func (*Receipt) Reset 

func (m *Receipt) Reset()

func (*Receipt) String 

func (m *Receipt) String() string

func (*Receipt) XXX_DiscardUnknown 

func (m *Receipt) XXX_DiscardUnknown()

func (*Receipt) XXX_Marshal 

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

func (*Receipt) XXX_Merge 

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

func (*Receipt) XXX_Size 

func (m *Receipt) XXX_Size() int

func (*Receipt) XXX_Unmarshal 

func (m *Receipt) 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.