Versions in this module Expand all Collapse all v0 v0.0.2 Sep 5, 2019 Changes in this version + var ErrFailedToConnect = errors.New("Datanode query client failed to connect") + type DataNodeQueryClient interface + Query func(ctx context.Context, requestID string, host topology.Host, ...) (queryCom.AQLQueryResult, error) + QueryRaw func(ctx context.Context, requestID string, host topology.Host, ...) ([]byte, error) + func NewDataNodeQueryClient() DataNodeQueryClient + type Peer interface + BorrowConnection func(fn WithConnectionFn) error + Close func() + Host func() topology.Host + type PeerConnDialer func(target string, opts ...grpc.DialOption) (client rpc.PeerDataNodeClient, closeFn func() error, err error) + type PeerSource interface + BorrowConnection func(hostIDs []string, fn WithConnectionFn) error + Close func() + type WithConnectionFn func(peerID string, client rpc.PeerDataNodeClient)
Go to main page