remote

Documentation

Index

• func NewGRPCServer(store m3.Storage, queryContextOpts models.QueryContextOptions, ...) *grpc.Server
• type Client
  • func NewGRPCClient(addresses []string, poolWrapper *pools.PoolWrapper, ...) (Client, error)

Functions

func NewGRPCServer

func NewGRPCServer(
	store m3.Storage,
	queryContextOpts models.QueryContextOptions,
	poolWrapper *pools.PoolWrapper,
) *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 grpc client

func NewGRPCClient

func NewGRPCClient(
	addresses []string,
	poolWrapper *pools.PoolWrapper,
	readWorkerPool xsync.PooledWorkerPool,
	tagOptions models.TagOptions,
	lookbackDuration time.Duration,
	additionalDialOpts ...grpc.DialOption,
) (Client, error)

NewGRPCClient creates grpc client.