client

Documentation

Index

• type GRPCClient
  • func NewGRPCClient(address string, maxCallSendMsgSize int, maxCallRecvMsgSize int) (*GRPCClient, error)
  • func (c *GRPCClient) Bulk(req *protobuf.BulkRequest, opts ...grpc.CallOption) (*protobuf.BulkResponse, error)
  • func (c *GRPCClient) Close() error
  • func (c *GRPCClient) Delete(req *protobuf.DeleteRequest, opts ...grpc.CallOption) (*protobuf.DeleteResponse, error)
  • func (c *GRPCClient) Get(req *protobuf.GetRequest, opts ...grpc.CallOption) (*protobuf.GetResponse, error)
  • func (c *GRPCClient) Join(req *protobuf.JoinRequest, opts ...grpc.CallOption) (*protobuf.JoinResponse, error)
  • func (c *GRPCClient) Leave(req *protobuf.LeaveRequest, opts ...grpc.CallOption) (*protobuf.LeaveResponse, error)
  • func (c *GRPCClient) Peers(opts ...grpc.CallOption) (*protobuf.PeersResponse, error)
  • func (c *GRPCClient) Put(req *protobuf.PutRequest, opts ...grpc.CallOption) (*protobuf.PutResponse, error)
  • func (c *GRPCClient) Search(req *protobuf.SearchRequest, opts ...grpc.CallOption) (*protobuf.SearchResponse, error)
  • func (c *GRPCClient) Snapshot(opts ...grpc.CallOption) (*protobuf.SnapshotResponse, error)

Types

type GRPCClient

type GRPCClient struct {
	// contains filtered or unexported fields
}

func NewGRPCClient

func NewGRPCClient(address string, maxCallSendMsgSize int, maxCallRecvMsgSize int) (*GRPCClient, error)

func (*GRPCClient) Bulk

func (c *GRPCClient) Bulk(req *protobuf.BulkRequest, opts ...grpc.CallOption) (*protobuf.BulkResponse, error)

func (*GRPCClient) Close

func (c *GRPCClient) Close() error

func (*GRPCClient) Delete

func (c *GRPCClient) Delete(req *protobuf.DeleteRequest, opts ...grpc.CallOption) (*protobuf.DeleteResponse, error)

func (*GRPCClient) Get

func (c *GRPCClient) Get(req *protobuf.GetRequest, opts ...grpc.CallOption) (*protobuf.GetResponse, error)

func (*GRPCClient) Join

func (c *GRPCClient) Join(req *protobuf.JoinRequest, opts ...grpc.CallOption) (*protobuf.JoinResponse, error)

func (*GRPCClient) Leave

func (c *GRPCClient) Leave(req *protobuf.LeaveRequest, opts ...grpc.CallOption) (*protobuf.LeaveResponse, error)

func (*GRPCClient) Peers

func (c *GRPCClient) Peers(opts ...grpc.CallOption) (*protobuf.PeersResponse, error)

func (*GRPCClient) Put

func (c *GRPCClient) Put(req *protobuf.PutRequest, opts ...grpc.CallOption) (*protobuf.PutResponse, error)

func (*GRPCClient) Search

func (c *GRPCClient) Search(req *protobuf.SearchRequest, opts ...grpc.CallOption) (*protobuf.SearchResponse, error)

func (*GRPCClient) Snapshot

func (c *GRPCClient) Snapshot(opts ...grpc.CallOption) (*protobuf.SnapshotResponse, error)