remote

package

v0.0.0-...-9741fed Latest Latest Go to latest Published: Nov 14, 2018 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

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

CreateNewGrpcServer creates server, given context local storage

func DecodeFetchMessage(message *rpc.FetchMessage) (*storage.FetchQuery, string, error)

DecodeFetchMessage decodes rpc fetch message to read query and read options

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

DecodeFetchResult decodes fetch results from a GRPC-compatible type.

func DecodeWriteMessage(message *rpc.WriteMessage) (*storage.WriteQuery, string)

DecodeWriteMessage decodes rpc write message to write query and write options

func EncodeFetchMessage(query *storage.FetchQuery, queryID string) *rpc.FetchMessage

EncodeFetchMessage encodes fetch query and fetch options into rpc WriteMessage

func EncodeFetchResult(sResult *storage.FetchResult) *rpc.FetchResult

EncodeFetchResult encodes fetch result to rpc result

func EncodeWriteMessage(query *storage.WriteQuery, queryID string) *rpc.WriteMessage

EncodeWriteMessage encodes write query and write options into rpc WriteMessage

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

StartNewGrpcServer starts server on given address, then notifies channel

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

Client is an interface

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

NewGrpcClient creates grpc client