remote

Documentation

Index

• func CreateNewGrpcServer(store m3.Storage, poolWrapper *pools.PoolWrapper) *grpc.Server
• func DecodeCompressedFetchResponse(fetchResult *rpc.FetchResponse, iteratorPools encoding.IteratorPools) (encoding.SeriesIterators, error)
• func DecodeDecompressedFetchResult(name string, rpcSeries []*rpc.DecompressedSeries) ([]*ts.Series, error)
• func DecodeFetchRequest(req *rpc.FetchRequest) (*storage.FetchQuery, error)
• func EncodeFetchRequest(query *storage.FetchQuery) (*rpc.FetchRequest, error)
• func EncodeFetchResult(results *storage.FetchResult) *rpc.FetchResponse
• func EncodeMetadata(ctx context.Context, requestID string) context.Context
• func EncodeToCompressedFetchResult(iterators encoding.SeriesIterators, iterPools encoding.IteratorPools) (*rpc.FetchResponse, error)
• func RetrieveMetadata(streamCtx context.Context) context.Context
• func StartNewGrpcServer(server *grpc.Server, address string, waitForStart chan<- struct{}) error
• type Client
  • func NewGrpcClient(addresses []string, poolWrapper *pools.PoolWrapper, workerPool pool.ObjectPool, ...) (Client, error)

Functions

func CreateNewGrpcServer

func CreateNewGrpcServer(
	store m3.Storage,
	poolWrapper *pools.PoolWrapper,
) *grpc.Server

CreateNewGrpcServer builds a grpc server which must be started later

func DecodeCompressedFetchResponse

func DecodeCompressedFetchResponse(
	fetchResult *rpc.FetchResponse,
	iteratorPools encoding.IteratorPools,
) (encoding.SeriesIterators, error)

DecodeCompressedFetchResponse decodes compressed fetch response to seriesIterators

func DecodeDecompressedFetchResult

func DecodeDecompressedFetchResult(
	name string,
	rpcSeries []*rpc.DecompressedSeries,
) ([]*ts.Series, error)

DecodeDecompressedFetchResult decodes fetch results from a GRPC-compatible type.

func DecodeFetchRequest

func DecodeFetchRequest(
	req *rpc.FetchRequest,
) (*storage.FetchQuery, error)

DecodeFetchRequest decodes rpc fetch request to read query and read options

func EncodeFetchRequest

func EncodeFetchRequest(
	query *storage.FetchQuery,
) (*rpc.FetchRequest, error)

EncodeFetchRequest encodes fetch request into rpc FetchRequest

func EncodeFetchResult

func EncodeFetchResult(results *storage.FetchResult) *rpc.FetchResponse

EncodeFetchResult encodes fetch result to rpc response

func EncodeMetadata

func EncodeMetadata(ctx context.Context, requestID string) context.Context

EncodeMetadata creates a context that propagates request metadata as well as requestID

func EncodeToCompressedFetchResult

func EncodeToCompressedFetchResult(
	iterators encoding.SeriesIterators,
	iterPools encoding.IteratorPools,
) (*rpc.FetchResponse, error)

EncodeToCompressedFetchResult encodes SeriesIterators to compressed fetch response

func RetrieveMetadata

func RetrieveMetadata(streamCtx context.Context) context.Context

RetrieveMetadata creates a context with propagated request metadata as well as requestID

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
	Close() error
}

Client is the grpc client

func NewGrpcClient

func NewGrpcClient(
	addresses []string,
	poolWrapper *pools.PoolWrapper,
	workerPool pool.ObjectPool,
	additionalDialOpts ...grpc.DialOption,
) (Client, error)

NewGrpcClient creates grpc client