client

Documentation

Index

• type GRPCClient
  • func NewGRPCClient(grpc_address string) (*GRPCClient, error)
  • func NewGRPCClientWithContext(grpc_address string, baseCtx context.Context) (*GRPCClient, error)
  • func NewGRPCClientWithContextTLS(grpcAddress string, baseCtx context.Context, certificateFile string, ...) (*GRPCClient, error)
  • func (c *GRPCClient) BulkDelete(req *protobuf.BulkDeleteRequest, opts ...grpc.CallOption) (*protobuf.BulkDeleteResponse, error)
  • func (c *GRPCClient) BulkIndex(req *protobuf.BulkIndexRequest, opts ...grpc.CallOption) (*protobuf.BulkIndexResponse, error)
  • 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) 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) Mapping(opts ...grpc.CallOption) (*protobuf.MappingResponse, 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) Search(req *protobuf.SearchRequest, opts ...grpc.CallOption) (*protobuf.SearchResponse, error)
  • func (c *GRPCClient) Set(req *protobuf.SetRequest, 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.Index_WatchClient, error)

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 NewGRPCClientWithContextTLS

func NewGRPCClientWithContextTLS(grpcAddress string, baseCtx context.Context, certificateFile string, commonName string) (*GRPCClient, error)

func (*GRPCClient) BulkDelete

func (c *GRPCClient) BulkDelete(req *protobuf.BulkDeleteRequest, opts ...grpc.CallOption) (*protobuf.BulkDeleteResponse, error)

func (*GRPCClient) BulkIndex

func (c *GRPCClient) BulkIndex(req *protobuf.BulkIndexRequest, opts ...grpc.CallOption) (*protobuf.BulkIndexResponse, 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) 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) Mapping

func (c *GRPCClient) Mapping(opts ...grpc.CallOption) (*protobuf.MappingResponse, 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) Search

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

func (*GRPCClient) Set

func (c *GRPCClient) Set(req *protobuf.SetRequest, 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.Index_WatchClient, error)