remote

Documentation

Index

• func CompressedSeriesFromSeriesIterator(it encoding.SeriesIterator, iterPools encoding.IteratorPools) (*rpc.Series, error)
• func DecodeCompressedFetchResponse(fetchResult *rpc.FetchResponse, iteratorPools encoding.IteratorPools) (encoding.SeriesIterators, error)
• func NewGRPCServer(querier m3.Querier, queryContextOpts models.QueryContextOptions, ...) *grpc.Server
• type Client
  • func NewGRPCClient(name string, addresses []string, poolWrapper *pools.PoolWrapper, ...) (Client, error)

Functions

func CompressedSeriesFromSeriesIterator

func CompressedSeriesFromSeriesIterator(
	it encoding.SeriesIterator,
	iterPools encoding.IteratorPools,
) (*rpc.Series, error)

CompressedSeriesFromSeriesIterator builds compressed rpc series from a SeriesIterator SeriesIterator is the top level iterator returned by m3db

func DecodeCompressedFetchResponse

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

DecodeCompressedFetchResponse decodes compressed fetch response to seriesIterators.

func NewGRPCServer

func NewGRPCServer(
	querier m3.Querier,
	queryContextOpts models.QueryContextOptions,
	poolWrapper *pools.PoolWrapper,
	instrumentOpts instrument.Options,
) *grpc.Server

NewGRPCServer builds a grpc server which must be started later.

Types

type Client

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

Client is the remote GRPC client.

func NewGRPCClient

func NewGRPCClient(
	name string,
	addresses []string,
	poolWrapper *pools.PoolWrapper,
	opts m3.Options,
	instrumentOpts instrument.Options,
	additionalDialOpts ...grpc.DialOption,
) (Client, error)

NewGRPCClient creates a new remote GRPC client.