remote

Documentation

Index

• func CreateNewGrpcServer(store m3.Storage, poolWrapper *pools.PoolWrapper) *grpc.Server
• func StartNewGrpcServer(server *grpc.Server, address string, waitForStart chan<- struct{}) error
• type Client
  • func NewGRPCClient(addresses []string, poolWrapper *pools.PoolWrapper, ...) (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 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,
	readWorkerPool xsync.PooledWorkerPool,
	tagOptions models.TagOptions,
	lookbackDuration time.Duration,
	additionalDialOpts ...grpc.DialOption,
) (Client, error)

NewGRPCClient creates grpc client