remote

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
  • func NewGrpcClient(addresses []string, additionalDialOpts ...grpc.DialOption) (Client, error)

Functions

func CreateNewGrpcServer

func CreateNewGrpcServer(store storage.Storage) *grpc.Server

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

func DecodeFetchResult(_ context.Context, rpcSeries []*rpc.Series) ([]*ts.Series, error)

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

func StartNewGrpcServer

func StartNewGrpcServer(server *grpc.Server, address string, waitForStart chan<- struct{}) error

StartNewGrpcServer starts server on given address, then notifies channel

Types

type Client

type Client interface {
	storage.Querier
	storage.Appender
	Close() error
}

Client is an interface

func NewGrpcClient

func NewGrpcClient(addresses []string, additionalDialOpts ...grpc.DialOption) (Client, error)

NewGrpcClient creates grpc client