Documentation ¶
Index ¶
- type GRPCClient
- func (c *GRPCClient) Close() error
- func (c *GRPCClient) Cluster(opts ...grpc.CallOption) (*protobuf.ClusterResponse, error)
- func (c *GRPCClient) Delete(req *protobuf.DeleteRequest, opts ...grpc.CallOption) error
- func (c *GRPCClient) DeleteObject(req *protobuf.DeleteObjectRequest, opts ...grpc.CallOption) error
- func (c *GRPCClient) Get(req *protobuf.GetRequest, opts ...grpc.CallOption) (*protobuf.GetResponse, error)
- func (c *GRPCClient) Join(req *protobuf.JoinRequest, opts ...grpc.CallOption) error
- func (c *GRPCClient) Leave(req *protobuf.LeaveRequest, opts ...grpc.CallOption) error
- func (c *GRPCClient) LivenessCheck(opts ...grpc.CallOption) (*protobuf.LivenessCheckResponse, error)
- func (c *GRPCClient) Metrics(opts ...grpc.CallOption) (*protobuf.MetricsResponse, error)
- func (c *GRPCClient) Node(opts ...grpc.CallOption) (*protobuf.NodeResponse, error)
- func (c *GRPCClient) ReadinessCheck(opts ...grpc.CallOption) (*protobuf.ReadinessCheckResponse, error)
- func (c *GRPCClient) Set(req *protobuf.SetRequest, opts ...grpc.CallOption) error
- func (c *GRPCClient) SetObject(req *protobuf.SetObjectRequest, opts ...grpc.CallOption) error
- func (c *GRPCClient) Snapshot(opts ...grpc.CallOption) error
- func (c *GRPCClient) Target() string
- func (c *GRPCClient) Watch(req *empty.Empty, opts ...grpc.CallOption) (protobuf.KVS_WatchClient, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GRPCClient ¶
type GRPCClient struct {
// contains filtered or unexported fields
}
func NewGRPCClient ¶
func NewGRPCClient(grpc_address string) (*GRPCClient, error)
func NewGRPCClientWithContext ¶
func NewGRPCClientWithContext(grpc_address string, baseCtx context.Context) (*GRPCClient, error)
func (*GRPCClient) Close ¶
func (c *GRPCClient) Close() error
func (*GRPCClient) Cluster ¶
func (c *GRPCClient) Cluster(opts ...grpc.CallOption) (*protobuf.ClusterResponse, error)
func (*GRPCClient) Delete ¶
func (c *GRPCClient) Delete(req *protobuf.DeleteRequest, opts ...grpc.CallOption) error
func (*GRPCClient) DeleteObject ¶
func (c *GRPCClient) DeleteObject(req *protobuf.DeleteObjectRequest, opts ...grpc.CallOption) 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) error
func (*GRPCClient) Leave ¶
func (c *GRPCClient) Leave(req *protobuf.LeaveRequest, opts ...grpc.CallOption) error
func (*GRPCClient) LivenessCheck ¶
func (c *GRPCClient) LivenessCheck(opts ...grpc.CallOption) (*protobuf.LivenessCheckResponse, error)
func (*GRPCClient) Metrics ¶
func (c *GRPCClient) Metrics(opts ...grpc.CallOption) (*protobuf.MetricsResponse, error)
func (*GRPCClient) Node ¶
func (c *GRPCClient) Node(opts ...grpc.CallOption) (*protobuf.NodeResponse, error)
func (*GRPCClient) ReadinessCheck ¶
func (c *GRPCClient) ReadinessCheck(opts ...grpc.CallOption) (*protobuf.ReadinessCheckResponse, error)
func (*GRPCClient) Set ¶
func (c *GRPCClient) Set(req *protobuf.SetRequest, opts ...grpc.CallOption) error
func (*GRPCClient) SetObject ¶
func (c *GRPCClient) SetObject(req *protobuf.SetObjectRequest, opts ...grpc.CallOption) error
func (*GRPCClient) Snapshot ¶
func (c *GRPCClient) Snapshot(opts ...grpc.CallOption) error
func (*GRPCClient) Target ¶
func (c *GRPCClient) Target() string
func (*GRPCClient) Watch ¶
func (c *GRPCClient) Watch(req *empty.Empty, opts ...grpc.CallOption) (protobuf.KVS_WatchClient, error)
Click to show internal directories.
Click to hide internal directories.