Documentation ¶
Index ¶
- func CreateNewGrpcServer(store storage.Storage) *grpc.Server
- func DecodeCompressedFetchResult(fetchResult *rpc.FetchResult, iteratorPools encoding.IteratorPools) (encoding.SeriesIterators, error)
- func DecodeFetchMessage(message *rpc.FetchMessage) (*storage.FetchQuery, string, error)
- func DecodeFetchResult(_ context.Context, rpcSeries []*rpc.Series) ([]*ts.Series, error)
- func DecodeWriteMessage(message *rpc.WriteMessage) (*storage.WriteQuery, string)
- func EncodeFetchMessage(query *storage.FetchQuery, queryID string) *rpc.FetchMessage
- func EncodeFetchResult(sResult *storage.FetchResult) *rpc.FetchResult
- func EncodeToCompressedFetchResult(iterators encoding.SeriesIterators, iterPools encoding.IteratorPools) (*rpc.FetchResult, error)
- func EncodeWriteMessage(query *storage.WriteQuery, queryID string) *rpc.WriteMessage
- func StartNewGrpcServer(server *grpc.Server, address string, waitForStart chan<- struct{}) error
- type Client
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateNewGrpcServer ¶
CreateNewGrpcServer creates server, given context local storage
func DecodeCompressedFetchResult ¶
func DecodeCompressedFetchResult( fetchResult *rpc.FetchResult, iteratorPools encoding.IteratorPools, ) (encoding.SeriesIterators, error)
DecodeCompressedFetchResult decodes compressed fetch results to seriesIterators
func DecodeFetchMessage ¶
func DecodeFetchMessage(message *rpc.FetchMessage) (*storage.FetchQuery, string, error)
DecodeFetchMessage decodes rpc fetch message to read query and read options
func DecodeFetchResult ¶
DecodeFetchResult decodes fetch results from a GRPC-compatible type.
func DecodeWriteMessage ¶
func DecodeWriteMessage(message *rpc.WriteMessage) (*storage.WriteQuery, string)
DecodeWriteMessage decodes rpc write message to write query and write options
func EncodeFetchMessage ¶
func EncodeFetchMessage(query *storage.FetchQuery, queryID string) *rpc.FetchMessage
EncodeFetchMessage encodes fetch query and fetch options into rpc WriteMessage
func EncodeFetchResult ¶
func EncodeFetchResult(sResult *storage.FetchResult) *rpc.FetchResult
EncodeFetchResult encodes fetch result to rpc result
func EncodeToCompressedFetchResult ¶
func EncodeToCompressedFetchResult( iterators encoding.SeriesIterators, iterPools encoding.IteratorPools, ) (*rpc.FetchResult, error)
EncodeToCompressedFetchResult encodes SeriesIterators to compressed fetch results
func EncodeWriteMessage ¶
func EncodeWriteMessage(query *storage.WriteQuery, queryID string) *rpc.WriteMessage
EncodeWriteMessage encodes write query and write options into rpc WriteMessage