protobuf

package
v0.7.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 3, 2019 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var LivenessProbeResponse_State_name = map[int32]string{
	0: "UNKNOWN",
	1: "ALIVE",
	2: "DEAD",
}
View Source 
var LivenessProbeResponse_State_value = map[string]int32{
	"UNKNOWN": 0,
	"ALIVE":   1,
	"DEAD":    2,
}
View Source 
var ReadinessProbeResponse_State_name = map[int32]string{
	0: "UNKNOWN",
	1: "READY",
	2: "NOT_READY",
}
View Source 
var ReadinessProbeResponse_State_value = map[string]int32{
	"UNKNOWN":   0,
	"READY":     1,
	"NOT_READY": 2,
}
View Source 
var WatchStateResponse_Command_name = map[int32]string{
	0: "UNKNOWN",
	1: "SET",
	2: "DELETE",
}
View Source 
var WatchStateResponse_Command_value = map[string]int32{
	"UNKNOWN": 0,
	"SET":     1,
	"DELETE":  2,
}

Functions

func MarshalAny 

func MarshalAny(message *any.Any) (interface{}, error)

func RegisterBlastServer added in v0.6.0 

func RegisterBlastServer(s *grpc.Server, srv BlastServer)

func UnmarshalAny 

func UnmarshalAny(instance interface{}, message *any.Any) error

Types

type BlastClient added in v0.6.0 

type BlastClient interface {
	LivenessProbe(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*LivenessProbeResponse, error)
	ReadinessProbe(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ReadinessProbeResponse, error)
	GetNode(ctx context.Context, in *GetNodeRequest, opts ...grpc.CallOption) (*GetNodeResponse, error)
	SetNode(ctx context.Context, in *SetNodeRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	DeleteNode(ctx context.Context, in *DeleteNodeRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	GetCluster(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*GetClusterResponse, error)
	WatchCluster(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (Blast_WatchClusterClient, error)
	Snapshot(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
	GetState(ctx context.Context, in *GetStateRequest, opts ...grpc.CallOption) (*GetStateResponse, error)
	SetState(ctx context.Context, in *SetStateRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	DeleteState(ctx context.Context, in *DeleteStateRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	WatchState(ctx context.Context, in *WatchStateRequest, opts ...grpc.CallOption) (Blast_WatchStateClient, error)
	GetDocument(ctx context.Context, in *GetDocumentRequest, opts ...grpc.CallOption) (*GetDocumentResponse, error)
	IndexDocument(ctx context.Context, opts ...grpc.CallOption) (Blast_IndexDocumentClient, error)
	DeleteDocument(ctx context.Context, opts ...grpc.CallOption) (Blast_DeleteDocumentClient, error)
	Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchResponse, error)
	GetIndexConfig(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*GetIndexConfigResponse, error)
	GetIndexStats(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*GetIndexStatsResponse, error)
}

BlastClient is the client API for Blast service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewBlastClient added in v0.6.0 

func NewBlastClient(cc *grpc.ClientConn) BlastClient

type BlastServer added in v0.6.0 

type BlastServer interface {
	LivenessProbe(context.Context, *empty.Empty) (*LivenessProbeResponse, error)
	ReadinessProbe(context.Context, *empty.Empty) (*ReadinessProbeResponse, error)
	GetNode(context.Context, *GetNodeRequest) (*GetNodeResponse, error)
	SetNode(context.Context, *SetNodeRequest) (*empty.Empty, error)
	DeleteNode(context.Context, *DeleteNodeRequest) (*empty.Empty, error)
	GetCluster(context.Context, *empty.Empty) (*GetClusterResponse, error)
	WatchCluster(*empty.Empty, Blast_WatchClusterServer) error
	Snapshot(context.Context, *empty.Empty) (*empty.Empty, error)
	GetState(context.Context, *GetStateRequest) (*GetStateResponse, error)
	SetState(context.Context, *SetStateRequest) (*empty.Empty, error)
	DeleteState(context.Context, *DeleteStateRequest) (*empty.Empty, error)
	WatchState(*WatchStateRequest, Blast_WatchStateServer) error
	GetDocument(context.Context, *GetDocumentRequest) (*GetDocumentResponse, error)
	IndexDocument(Blast_IndexDocumentServer) error
	DeleteDocument(Blast_DeleteDocumentServer) error
	Search(context.Context, *SearchRequest) (*SearchResponse, error)
	GetIndexConfig(context.Context, *empty.Empty) (*GetIndexConfigResponse, error)
	GetIndexStats(context.Context, *empty.Empty) (*GetIndexStatsResponse, error)
}

BlastServer is the server API for Blast service.

type Blast_DeleteDocumentClient added in v0.6.0 

type Blast_DeleteDocumentClient interface {
	Send(*DeleteDocumentRequest) error
	CloseAndRecv() (*DeleteDocumentResponse, error)
	grpc.ClientStream
}

type Blast_DeleteDocumentServer added in v0.6.0 

type Blast_DeleteDocumentServer interface {
	SendAndClose(*DeleteDocumentResponse) error
	Recv() (*DeleteDocumentRequest, error)
	grpc.ServerStream
}

type Blast_IndexDocumentClient added in v0.6.0 

type Blast_IndexDocumentClient interface {
	Send(*IndexDocumentRequest) error
	CloseAndRecv() (*IndexDocumentResponse, error)
	grpc.ClientStream
}

type Blast_IndexDocumentServer added in v0.6.0 

type Blast_IndexDocumentServer interface {
	SendAndClose(*IndexDocumentResponse) error
	Recv() (*IndexDocumentRequest, error)
	grpc.ServerStream
}

type Blast_WatchClusterClient added in v0.6.0 

type Blast_WatchClusterClient interface {
	Recv() (*GetClusterResponse, error)
	grpc.ClientStream
}

type Blast_WatchClusterServer added in v0.6.0 

type Blast_WatchClusterServer interface {
	Send(*GetClusterResponse) error
	grpc.ServerStream
}

type Blast_WatchStateClient added in v0.6.0 

type Blast_WatchStateClient interface {
	Recv() (*WatchStateResponse, error)
	grpc.ClientStream
}

type Blast_WatchStateServer added in v0.6.0 

type Blast_WatchStateServer interface {
	Send(*WatchStateResponse) error
	grpc.ServerStream
}

type DeleteDocumentRequest added in v0.6.0 

type DeleteDocumentRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteDocumentRequest) Descriptor added in v0.6.0 

func (*DeleteDocumentRequest) Descriptor() ([]byte, []int)

func (*DeleteDocumentRequest) GetId added in v0.6.0 

func (m *DeleteDocumentRequest) GetId() string

func (*DeleteDocumentRequest) ProtoMessage added in v0.6.0 

func (*DeleteDocumentRequest) ProtoMessage()

func (*DeleteDocumentRequest) Reset added in v0.6.0 

func (m *DeleteDocumentRequest) Reset()

func (*DeleteDocumentRequest) String added in v0.6.0 

func (m *DeleteDocumentRequest) String() string

func (*DeleteDocumentRequest) XXX_DiscardUnknown added in v0.6.0 

func (m *DeleteDocumentRequest) XXX_DiscardUnknown()

func (*DeleteDocumentRequest) XXX_Marshal added in v0.6.0 

func (m *DeleteDocumentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteDocumentRequest) XXX_Merge added in v0.6.0 

func (m *DeleteDocumentRequest) XXX_Merge(src proto.Message)

func (*DeleteDocumentRequest) XXX_Size added in v0.6.0 

func (m *DeleteDocumentRequest) XXX_Size() int

func (*DeleteDocumentRequest) XXX_Unmarshal added in v0.6.0 

func (m *DeleteDocumentRequest) XXX_Unmarshal(b []byte) error

type DeleteDocumentResponse added in v0.6.0 

type DeleteDocumentResponse struct {
	Count                int32    `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteDocumentResponse) Descriptor added in v0.6.0 

func (*DeleteDocumentResponse) Descriptor() ([]byte, []int)

func (*DeleteDocumentResponse) GetCount added in v0.6.0 

func (m *DeleteDocumentResponse) GetCount() int32

func (*DeleteDocumentResponse) ProtoMessage added in v0.6.0 

func (*DeleteDocumentResponse) ProtoMessage()

func (*DeleteDocumentResponse) Reset added in v0.6.0 

func (m *DeleteDocumentResponse) Reset()

func (*DeleteDocumentResponse) String added in v0.6.0 

func (m *DeleteDocumentResponse) String() string

func (*DeleteDocumentResponse) XXX_DiscardUnknown added in v0.6.0 

func (m *DeleteDocumentResponse) XXX_DiscardUnknown()

func (*DeleteDocumentResponse) XXX_Marshal added in v0.6.0 

func (m *DeleteDocumentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteDocumentResponse) XXX_Merge added in v0.6.0 

func (m *DeleteDocumentResponse) XXX_Merge(src proto.Message)

func (*DeleteDocumentResponse) XXX_Size added in v0.6.0 

func (m *DeleteDocumentResponse) XXX_Size() int

func (*DeleteDocumentResponse) XXX_Unmarshal added in v0.6.0 

func (m *DeleteDocumentResponse) XXX_Unmarshal(b []byte) error

type DeleteNodeRequest added in v0.6.0 

type DeleteNodeRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

use for raft cluster status

func (*DeleteNodeRequest) Descriptor added in v0.6.0 

func (*DeleteNodeRequest) Descriptor() ([]byte, []int)

func (*DeleteNodeRequest) GetId added in v0.6.0 

func (m *DeleteNodeRequest) GetId() string

func (*DeleteNodeRequest) ProtoMessage added in v0.6.0 

func (*DeleteNodeRequest) ProtoMessage()

func (*DeleteNodeRequest) Reset added in v0.6.0 

func (m *DeleteNodeRequest) Reset()

func (*DeleteNodeRequest) String added in v0.6.0 

func (m *DeleteNodeRequest) String() string

func (*DeleteNodeRequest) XXX_DiscardUnknown added in v0.6.0 

func (m *DeleteNodeRequest) XXX_DiscardUnknown()

func (*DeleteNodeRequest) XXX_Marshal added in v0.6.0 

func (m *DeleteNodeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteNodeRequest) XXX_Merge added in v0.6.0 

func (m *DeleteNodeRequest) XXX_Merge(src proto.Message)

func (*DeleteNodeRequest) XXX_Size added in v0.6.0 

func (m *DeleteNodeRequest) XXX_Size() int

func (*DeleteNodeRequest) XXX_Unmarshal added in v0.6.0 

func (m *DeleteNodeRequest) XXX_Unmarshal(b []byte) error

type DeleteStateRequest added in v0.6.0 

type DeleteStateRequest struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteStateRequest) Descriptor added in v0.6.0 

func (*DeleteStateRequest) Descriptor() ([]byte, []int)

func (*DeleteStateRequest) GetKey added in v0.6.0 

func (m *DeleteStateRequest) GetKey() string

func (*DeleteStateRequest) ProtoMessage added in v0.6.0 

func (*DeleteStateRequest) ProtoMessage()

func (*DeleteStateRequest) Reset added in v0.6.0 

func (m *DeleteStateRequest) Reset()

func (*DeleteStateRequest) String added in v0.6.0 

func (m *DeleteStateRequest) String() string

func (*DeleteStateRequest) XXX_DiscardUnknown added in v0.6.0 

func (m *DeleteStateRequest) XXX_DiscardUnknown()

func (*DeleteStateRequest) XXX_Marshal added in v0.6.0 

func (m *DeleteStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteStateRequest) XXX_Merge added in v0.6.0 

func (m *DeleteStateRequest) XXX_Merge(src proto.Message)

func (*DeleteStateRequest) XXX_Size added in v0.6.0 

func (m *DeleteStateRequest) XXX_Size() int

func (*DeleteStateRequest) XXX_Unmarshal added in v0.6.0 

func (m *DeleteStateRequest) XXX_Unmarshal(b []byte) error

type Document 

type Document struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Fields               *any.Any `protobuf:"bytes,2,opt,name=fields,proto3" json:"fields,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

use for creating snapshot

func (*Document) Descriptor 

func (*Document) Descriptor() ([]byte, []int)

func (*Document) GetFields 

func (m *Document) GetFields() *any.Any

func (*Document) GetId 

func (m *Document) GetId() string

func (*Document) ProtoMessage 

func (*Document) ProtoMessage()

func (*Document) Reset 

func (m *Document) Reset()

func (*Document) String 

func (m *Document) String() string

func (*Document) XXX_DiscardUnknown added in v0.6.0 

func (m *Document) XXX_DiscardUnknown()

func (*Document) XXX_Marshal added in v0.6.0 

func (m *Document) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Document) XXX_Merge added in v0.6.0 

func (m *Document) XXX_Merge(src proto.Message)

func (*Document) XXX_Size added in v0.6.0 

func (m *Document) XXX_Size() int

func (*Document) XXX_Unmarshal added in v0.6.0 

func (m *Document) XXX_Unmarshal(b []byte) error

type GetClusterResponse added in v0.6.0 

type GetClusterResponse struct {
	Cluster              *any.Any `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

use for raft cluster status

func (*GetClusterResponse) Descriptor added in v0.6.0 

func (*GetClusterResponse) Descriptor() ([]byte, []int)

func (*GetClusterResponse) GetCluster added in v0.6.0 

func (m *GetClusterResponse) GetCluster() *any.Any

func (*GetClusterResponse) ProtoMessage added in v0.6.0 

func (*GetClusterResponse) ProtoMessage()

func (*GetClusterResponse) Reset added in v0.6.0 

func (m *GetClusterResponse) Reset()

func (*GetClusterResponse) String added in v0.6.0 

func (m *GetClusterResponse) String() string

func (*GetClusterResponse) XXX_DiscardUnknown added in v0.6.0 

func (m *GetClusterResponse) XXX_DiscardUnknown()

func (*GetClusterResponse) XXX_Marshal added in v0.6.0 

func (m *GetClusterResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetClusterResponse) XXX_Merge added in v0.6.0 

func (m *GetClusterResponse) XXX_Merge(src proto.Message)

func (*GetClusterResponse) XXX_Size added in v0.6.0 

func (m *GetClusterResponse) XXX_Size() int

func (*GetClusterResponse) XXX_Unmarshal added in v0.6.0 

func (m *GetClusterResponse) XXX_Unmarshal(b []byte) error

type GetDocumentRequest added in v0.6.0 

type GetDocumentRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetDocumentRequest) Descriptor added in v0.6.0 

func (*GetDocumentRequest) Descriptor() ([]byte, []int)

func (*GetDocumentRequest) GetId added in v0.6.0 

func (m *GetDocumentRequest) GetId() string

func (*GetDocumentRequest) ProtoMessage added in v0.6.0 

func (*GetDocumentRequest) ProtoMessage()

func (*GetDocumentRequest) Reset added in v0.6.0 

func (m *GetDocumentRequest) Reset()

func (*GetDocumentRequest) String added in v0.6.0 

func (m *GetDocumentRequest) String() string

func (*GetDocumentRequest) XXX_DiscardUnknown added in v0.6.0 

func (m *GetDocumentRequest) XXX_DiscardUnknown()

func (*GetDocumentRequest) XXX_Marshal added in v0.6.0 

func (m *GetDocumentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetDocumentRequest) XXX_Merge added in v0.6.0 

func (m *GetDocumentRequest) XXX_Merge(src proto.Message)

func (*GetDocumentRequest) XXX_Size added in v0.6.0 

func (m *GetDocumentRequest) XXX_Size() int

func (*GetDocumentRequest) XXX_Unmarshal added in v0.6.0 

func (m *GetDocumentRequest) XXX_Unmarshal(b []byte) error

type GetDocumentResponse added in v0.6.0 

type GetDocumentResponse struct {
	Fields               *any.Any `protobuf:"bytes,1,opt,name=fields,proto3" json:"fields,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetDocumentResponse) Descriptor added in v0.6.0 

func (*GetDocumentResponse) Descriptor() ([]byte, []int)

func (*GetDocumentResponse) GetFields added in v0.6.0 

func (m *GetDocumentResponse) GetFields() *any.Any

func (*GetDocumentResponse) ProtoMessage added in v0.6.0 

func (*GetDocumentResponse) ProtoMessage()

func (*GetDocumentResponse) Reset added in v0.6.0 

func (m *GetDocumentResponse) Reset()

func (*GetDocumentResponse) String added in v0.6.0 

func (m *GetDocumentResponse) String() string

func (*GetDocumentResponse) XXX_DiscardUnknown added in v0.6.0 

func (m *GetDocumentResponse) XXX_DiscardUnknown()

func (*GetDocumentResponse) XXX_Marshal added in v0.6.0 

func (m *GetDocumentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetDocumentResponse) XXX_Merge added in v0.6.0 

func (m *GetDocumentResponse) XXX_Merge(src proto.Message)

func (*GetDocumentResponse) XXX_Size added in v0.6.0 

func (m *GetDocumentResponse) XXX_Size() int

func (*GetDocumentResponse) XXX_Unmarshal added in v0.6.0 

func (m *GetDocumentResponse) XXX_Unmarshal(b []byte) error

type GetIndexConfigResponse added in v0.6.0 

type GetIndexConfigResponse struct {
	IndexConfig          *any.Any `protobuf:"bytes,1,opt,name=index_config,json=indexConfig,proto3" json:"index_config,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetIndexConfigResponse) Descriptor added in v0.6.0 

func (*GetIndexConfigResponse) Descriptor() ([]byte, []int)

func (*GetIndexConfigResponse) GetIndexConfig added in v0.6.0 

func (m *GetIndexConfigResponse) GetIndexConfig() *any.Any

func (*GetIndexConfigResponse) ProtoMessage added in v0.6.0 

func (*GetIndexConfigResponse) ProtoMessage()

func (*GetIndexConfigResponse) Reset added in v0.6.0 

func (m *GetIndexConfigResponse) Reset()

func (*GetIndexConfigResponse) String added in v0.6.0 

func (m *GetIndexConfigResponse) String() string

func (*GetIndexConfigResponse) XXX_DiscardUnknown added in v0.6.0 

func (m *GetIndexConfigResponse) XXX_DiscardUnknown()

func (*GetIndexConfigResponse) XXX_Marshal added in v0.6.0 

func (m *GetIndexConfigResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetIndexConfigResponse) XXX_Merge added in v0.6.0 

func (m *GetIndexConfigResponse) XXX_Merge(src proto.Message)

func (*GetIndexConfigResponse) XXX_Size added in v0.6.0 

func (m *GetIndexConfigResponse) XXX_Size() int

func (*GetIndexConfigResponse) XXX_Unmarshal added in v0.6.0 

func (m *GetIndexConfigResponse) XXX_Unmarshal(b []byte) error

type GetIndexStatsResponse added in v0.6.0 

type GetIndexStatsResponse struct {
	IndexStats           *any.Any `protobuf:"bytes,1,opt,name=index_stats,json=indexStats,proto3" json:"index_stats,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetIndexStatsResponse) Descriptor added in v0.6.0 

func (*GetIndexStatsResponse) Descriptor() ([]byte, []int)

func (*GetIndexStatsResponse) GetIndexStats added in v0.6.0 

func (m *GetIndexStatsResponse) GetIndexStats() *any.Any

func (*GetIndexStatsResponse) ProtoMessage added in v0.6.0 

func (*GetIndexStatsResponse) ProtoMessage()

func (*GetIndexStatsResponse) Reset added in v0.6.0 

func (m *GetIndexStatsResponse) Reset()

func (*GetIndexStatsResponse) String added in v0.6.0 

func (m *GetIndexStatsResponse) String() string

func (*GetIndexStatsResponse) XXX_DiscardUnknown added in v0.6.0 

func (m *GetIndexStatsResponse) XXX_DiscardUnknown()

func (*GetIndexStatsResponse) XXX_Marshal added in v0.6.0 

func (m *GetIndexStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetIndexStatsResponse) XXX_Merge added in v0.6.0 

func (m *GetIndexStatsResponse) XXX_Merge(src proto.Message)

func (*GetIndexStatsResponse) XXX_Size added in v0.6.0 

func (m *GetIndexStatsResponse) XXX_Size() int

func (*GetIndexStatsResponse) XXX_Unmarshal added in v0.6.0 

func (m *GetIndexStatsResponse) XXX_Unmarshal(b []byte) error

type GetNodeRequest added in v0.6.0 

type GetNodeRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

use for raft cluster status

func (*GetNodeRequest) Descriptor added in v0.6.0 

func (*GetNodeRequest) Descriptor() ([]byte, []int)

func (*GetNodeRequest) GetId added in v0.6.0 

func (m *GetNodeRequest) GetId() string

func (*GetNodeRequest) ProtoMessage added in v0.6.0 

func (*GetNodeRequest) ProtoMessage()

func (*GetNodeRequest) Reset added in v0.6.0 

func (m *GetNodeRequest) Reset()

func (*GetNodeRequest) String added in v0.6.0 

func (m *GetNodeRequest) String() string

func (*GetNodeRequest) XXX_DiscardUnknown added in v0.6.0 

func (m *GetNodeRequest) XXX_DiscardUnknown()

func (*GetNodeRequest) XXX_Marshal added in v0.6.0 

func (m *GetNodeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetNodeRequest) XXX_Merge added in v0.6.0 

func (m *GetNodeRequest) XXX_Merge(src proto.Message)

func (*GetNodeRequest) XXX_Size added in v0.6.0 

func (m *GetNodeRequest) XXX_Size() int

func (*GetNodeRequest) XXX_Unmarshal added in v0.6.0 

func (m *GetNodeRequest) XXX_Unmarshal(b []byte) error

type GetNodeResponse added in v0.6.0 

type GetNodeResponse struct {
	Metadata             *any.Any `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	State                string   `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

use for raft cluster status

func (*GetNodeResponse) Descriptor added in v0.6.0 

func (*GetNodeResponse) Descriptor() ([]byte, []int)

func (*GetNodeResponse) GetMetadata added in v0.6.0 

func (m *GetNodeResponse) GetMetadata() *any.Any

func (*GetNodeResponse) GetState added in v0.6.0 

func (m *GetNodeResponse) GetState() string

func (*GetNodeResponse) ProtoMessage added in v0.6.0 

func (*GetNodeResponse) ProtoMessage()

func (*GetNodeResponse) Reset added in v0.6.0 

func (m *GetNodeResponse) Reset()

func (*GetNodeResponse) String added in v0.6.0 

func (m *GetNodeResponse) String() string

func (*GetNodeResponse) XXX_DiscardUnknown added in v0.6.0 

func (m *GetNodeResponse) XXX_DiscardUnknown()

func (*GetNodeResponse) XXX_Marshal added in v0.6.0 

func (m *GetNodeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetNodeResponse) XXX_Merge added in v0.6.0 

func (m *GetNodeResponse) XXX_Merge(src proto.Message)

func (*GetNodeResponse) XXX_Size added in v0.6.0 

func (m *GetNodeResponse) XXX_Size() int

func (*GetNodeResponse) XXX_Unmarshal added in v0.6.0 

func (m *GetNodeResponse) XXX_Unmarshal(b []byte) error

type GetStateRequest added in v0.6.0 

type GetStateRequest struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetStateRequest) Descriptor added in v0.6.0 

func (*GetStateRequest) Descriptor() ([]byte, []int)

func (*GetStateRequest) GetKey added in v0.6.0 

func (m *GetStateRequest) GetKey() string

func (*GetStateRequest) ProtoMessage added in v0.6.0 

func (*GetStateRequest) ProtoMessage()

func (*GetStateRequest) Reset added in v0.6.0 

func (m *GetStateRequest) Reset()

func (*GetStateRequest) String added in v0.6.0 

func (m *GetStateRequest) String() string

func (*GetStateRequest) XXX_DiscardUnknown added in v0.6.0 

func (m *GetStateRequest) XXX_DiscardUnknown()

func (*GetStateRequest) XXX_Marshal added in v0.6.0 

func (m *GetStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetStateRequest) XXX_Merge added in v0.6.0 

func (m *GetStateRequest) XXX_Merge(src proto.Message)

func (*GetStateRequest) XXX_Size added in v0.6.0 

func (m *GetStateRequest) XXX_Size() int

func (*GetStateRequest) XXX_Unmarshal added in v0.6.0 

func (m *GetStateRequest) XXX_Unmarshal(b []byte) error

type GetStateResponse added in v0.6.0 

type GetStateResponse struct {
	Value                *any.Any `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetStateResponse) Descriptor added in v0.6.0 

func (*GetStateResponse) Descriptor() ([]byte, []int)

func (*GetStateResponse) GetValue added in v0.6.0 

func (m *GetStateResponse) GetValue() *any.Any

func (*GetStateResponse) ProtoMessage added in v0.6.0 

func (*GetStateResponse) ProtoMessage()

func (*GetStateResponse) Reset added in v0.6.0 

func (m *GetStateResponse) Reset()

func (*GetStateResponse) String added in v0.6.0 

func (m *GetStateResponse) String() string

func (*GetStateResponse) XXX_DiscardUnknown added in v0.6.0 

func (m *GetStateResponse) XXX_DiscardUnknown()

func (*GetStateResponse) XXX_Marshal added in v0.6.0 

func (m *GetStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetStateResponse) XXX_Merge added in v0.6.0 

func (m *GetStateResponse) XXX_Merge(src proto.Message)

func (*GetStateResponse) XXX_Size added in v0.6.0 

func (m *GetStateResponse) XXX_Size() int

func (*GetStateResponse) XXX_Unmarshal added in v0.6.0 

func (m *GetStateResponse) XXX_Unmarshal(b []byte) error

type IndexDocumentRequest added in v0.6.0 

type IndexDocumentRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Fields               *any.Any `protobuf:"bytes,2,opt,name=fields,proto3" json:"fields,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IndexDocumentRequest) Descriptor added in v0.6.0 

func (*IndexDocumentRequest) Descriptor() ([]byte, []int)

func (*IndexDocumentRequest) GetFields added in v0.6.0 

func (m *IndexDocumentRequest) GetFields() *any.Any

func (*IndexDocumentRequest) GetId added in v0.6.0 

func (m *IndexDocumentRequest) GetId() string

func (*IndexDocumentRequest) ProtoMessage added in v0.6.0 

func (*IndexDocumentRequest) ProtoMessage()

func (*IndexDocumentRequest) Reset added in v0.6.0 

func (m *IndexDocumentRequest) Reset()

func (*IndexDocumentRequest) String added in v0.6.0 

func (m *IndexDocumentRequest) String() string

func (*IndexDocumentRequest) XXX_DiscardUnknown added in v0.6.0 

func (m *IndexDocumentRequest) XXX_DiscardUnknown()

func (*IndexDocumentRequest) XXX_Marshal added in v0.6.0 

func (m *IndexDocumentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IndexDocumentRequest) XXX_Merge added in v0.6.0 

func (m *IndexDocumentRequest) XXX_Merge(src proto.Message)

func (*IndexDocumentRequest) XXX_Size added in v0.6.0 

func (m *IndexDocumentRequest) XXX_Size() int

func (*IndexDocumentRequest) XXX_Unmarshal added in v0.6.0 

func (m *IndexDocumentRequest) XXX_Unmarshal(b []byte) error

type IndexDocumentResponse added in v0.6.0 

type IndexDocumentResponse struct {
	Count                int32    `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IndexDocumentResponse) Descriptor added in v0.6.0 

func (*IndexDocumentResponse) Descriptor() ([]byte, []int)

func (*IndexDocumentResponse) GetCount added in v0.6.0 

func (m *IndexDocumentResponse) GetCount() int32

func (*IndexDocumentResponse) ProtoMessage added in v0.6.0 

func (*IndexDocumentResponse) ProtoMessage()

func (*IndexDocumentResponse) Reset added in v0.6.0 

func (m *IndexDocumentResponse) Reset()

func (*IndexDocumentResponse) String added in v0.6.0 

func (m *IndexDocumentResponse) String() string

func (*IndexDocumentResponse) XXX_DiscardUnknown added in v0.6.0 

func (m *IndexDocumentResponse) XXX_DiscardUnknown()

func (*IndexDocumentResponse) XXX_Marshal added in v0.6.0 

func (m *IndexDocumentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IndexDocumentResponse) XXX_Merge added in v0.6.0 

func (m *IndexDocumentResponse) XXX_Merge(src proto.Message)

func (*IndexDocumentResponse) XXX_Size added in v0.6.0 

func (m *IndexDocumentResponse) XXX_Size() int

func (*IndexDocumentResponse) XXX_Unmarshal added in v0.6.0 

func (m *IndexDocumentResponse) XXX_Unmarshal(b []byte) error

type LivenessProbeResponse added in v0.6.0 

type LivenessProbeResponse struct {
	State                LivenessProbeResponse_State `protobuf:"varint,1,opt,name=state,proto3,enum=protobuf.LivenessProbeResponse_State" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

use for health check

func (*LivenessProbeResponse) Descriptor added in v0.6.0 

func (*LivenessProbeResponse) Descriptor() ([]byte, []int)

func (*LivenessProbeResponse) GetState added in v0.6.0 

func (m *LivenessProbeResponse) GetState() LivenessProbeResponse_State

func (*LivenessProbeResponse) ProtoMessage added in v0.6.0 

func (*LivenessProbeResponse) ProtoMessage()

func (*LivenessProbeResponse) Reset added in v0.6.0 

func (m *LivenessProbeResponse) Reset()

func (*LivenessProbeResponse) String added in v0.6.0 

func (m *LivenessProbeResponse) String() string

func (*LivenessProbeResponse) XXX_DiscardUnknown added in v0.6.0 

func (m *LivenessProbeResponse) XXX_DiscardUnknown()

func (*LivenessProbeResponse) XXX_Marshal added in v0.6.0 

func (m *LivenessProbeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LivenessProbeResponse) XXX_Merge added in v0.6.0 

func (m *LivenessProbeResponse) XXX_Merge(src proto.Message)

func (*LivenessProbeResponse) XXX_Size added in v0.6.0 

func (m *LivenessProbeResponse) XXX_Size() int

func (*LivenessProbeResponse) XXX_Unmarshal added in v0.6.0 

func (m *LivenessProbeResponse) XXX_Unmarshal(b []byte) error

type LivenessProbeResponse_State added in v0.6.0 

type LivenessProbeResponse_State int32
const (
	LivenessProbeResponse_UNKNOWN LivenessProbeResponse_State = 0
	LivenessProbeResponse_ALIVE   LivenessProbeResponse_State = 1
	LivenessProbeResponse_DEAD    LivenessProbeResponse_State = 2
)

func (LivenessProbeResponse_State) EnumDescriptor added in v0.6.0 

func (LivenessProbeResponse_State) EnumDescriptor() ([]byte, []int)

func (LivenessProbeResponse_State) String added in v0.6.0 

func (x LivenessProbeResponse_State) String() string

type ReadinessProbeResponse added in v0.6.0 

type ReadinessProbeResponse struct {
	State                ReadinessProbeResponse_State `protobuf:"varint,1,opt,name=state,proto3,enum=protobuf.ReadinessProbeResponse_State" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

use for health check

func (*ReadinessProbeResponse) Descriptor added in v0.6.0 

func (*ReadinessProbeResponse) Descriptor() ([]byte, []int)

func (*ReadinessProbeResponse) GetState added in v0.6.0 

func (m *ReadinessProbeResponse) GetState() ReadinessProbeResponse_State

func (*ReadinessProbeResponse) ProtoMessage added in v0.6.0 

func (*ReadinessProbeResponse) ProtoMessage()

func (*ReadinessProbeResponse) Reset added in v0.6.0 

func (m *ReadinessProbeResponse) Reset()

func (*ReadinessProbeResponse) String added in v0.6.0 

func (m *ReadinessProbeResponse) String() string

func (*ReadinessProbeResponse) XXX_DiscardUnknown added in v0.6.0 

func (m *ReadinessProbeResponse) XXX_DiscardUnknown()

func (*ReadinessProbeResponse) XXX_Marshal added in v0.6.0 

func (m *ReadinessProbeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadinessProbeResponse) XXX_Merge added in v0.6.0 

func (m *ReadinessProbeResponse) XXX_Merge(src proto.Message)

func (*ReadinessProbeResponse) XXX_Size added in v0.6.0 

func (m *ReadinessProbeResponse) XXX_Size() int

func (*ReadinessProbeResponse) XXX_Unmarshal added in v0.6.0 

func (m *ReadinessProbeResponse) XXX_Unmarshal(b []byte) error

type ReadinessProbeResponse_State added in v0.6.0 

type ReadinessProbeResponse_State int32
const (
	ReadinessProbeResponse_UNKNOWN   ReadinessProbeResponse_State = 0
	ReadinessProbeResponse_READY     ReadinessProbeResponse_State = 1
	ReadinessProbeResponse_NOT_READY ReadinessProbeResponse_State = 2
)

func (ReadinessProbeResponse_State) EnumDescriptor added in v0.6.0 

func (ReadinessProbeResponse_State) EnumDescriptor() ([]byte, []int)

func (ReadinessProbeResponse_State) String added in v0.6.0 

func (x ReadinessProbeResponse_State) String() string

type SearchRequest 

type SearchRequest struct {
	SearchRequest        *any.Any `protobuf:"bytes,1,opt,name=search_request,json=searchRequest,proto3" json:"search_request,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SearchRequest) Descriptor 

func (*SearchRequest) Descriptor() ([]byte, []int)

func (*SearchRequest) GetSearchRequest 

func (m *SearchRequest) GetSearchRequest() *any.Any

func (*SearchRequest) ProtoMessage 

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) Reset 

func (m *SearchRequest) Reset()

func (*SearchRequest) String 

func (m *SearchRequest) String() string

func (*SearchRequest) XXX_DiscardUnknown added in v0.6.0 

func (m *SearchRequest) XXX_DiscardUnknown()

func (*SearchRequest) XXX_Marshal added in v0.6.0 

func (m *SearchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SearchRequest) XXX_Merge added in v0.6.0 

func (m *SearchRequest) XXX_Merge(src proto.Message)

func (*SearchRequest) XXX_Size added in v0.6.0 

func (m *SearchRequest) XXX_Size() int

func (*SearchRequest) XXX_Unmarshal added in v0.6.0 

func (m *SearchRequest) XXX_Unmarshal(b []byte) error

type SearchResponse 

type SearchResponse struct {
	SearchResult         *any.Any `protobuf:"bytes,1,opt,name=search_result,json=searchResult,proto3" json:"search_result,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SearchResponse) Descriptor 

func (*SearchResponse) Descriptor() ([]byte, []int)

func (*SearchResponse) GetSearchResult 

func (m *SearchResponse) GetSearchResult() *any.Any

func (*SearchResponse) ProtoMessage 

func (*SearchResponse) ProtoMessage()

func (*SearchResponse) Reset 

func (m *SearchResponse) Reset()

func (*SearchResponse) String 

func (m *SearchResponse) String() string

func (*SearchResponse) XXX_DiscardUnknown added in v0.6.0 

func (m *SearchResponse) XXX_DiscardUnknown()

func (*SearchResponse) XXX_Marshal added in v0.6.0 

func (m *SearchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SearchResponse) XXX_Merge added in v0.6.0 

func (m *SearchResponse) XXX_Merge(src proto.Message)

func (*SearchResponse) XXX_Size added in v0.6.0 

func (m *SearchResponse) XXX_Size() int

func (*SearchResponse) XXX_Unmarshal added in v0.6.0 

func (m *SearchResponse) XXX_Unmarshal(b []byte) error

type SetNodeRequest added in v0.6.0 

type SetNodeRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Metadata             *any.Any `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

use for raft cluster status

func (*SetNodeRequest) Descriptor added in v0.6.0 

func (*SetNodeRequest) Descriptor() ([]byte, []int)

func (*SetNodeRequest) GetId added in v0.6.0 

func (m *SetNodeRequest) GetId() string

func (*SetNodeRequest) GetMetadata added in v0.6.0 

func (m *SetNodeRequest) GetMetadata() *any.Any

func (*SetNodeRequest) ProtoMessage added in v0.6.0 

func (*SetNodeRequest) ProtoMessage()

func (*SetNodeRequest) Reset added in v0.6.0 

func (m *SetNodeRequest) Reset()

func (*SetNodeRequest) String added in v0.6.0 

func (m *SetNodeRequest) String() string

func (*SetNodeRequest) XXX_DiscardUnknown added in v0.6.0 

func (m *SetNodeRequest) XXX_DiscardUnknown()

func (*SetNodeRequest) XXX_Marshal added in v0.6.0 

func (m *SetNodeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetNodeRequest) XXX_Merge added in v0.6.0 

func (m *SetNodeRequest) XXX_Merge(src proto.Message)

func (*SetNodeRequest) XXX_Size added in v0.6.0 

func (m *SetNodeRequest) XXX_Size() int

func (*SetNodeRequest) XXX_Unmarshal added in v0.6.0 

func (m *SetNodeRequest) XXX_Unmarshal(b []byte) error

type SetStateRequest added in v0.6.0 

type SetStateRequest struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                *any.Any `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetStateRequest) Descriptor added in v0.6.0 

func (*SetStateRequest) Descriptor() ([]byte, []int)

func (*SetStateRequest) GetKey added in v0.6.0 

func (m *SetStateRequest) GetKey() string

func (*SetStateRequest) GetValue added in v0.6.0 

func (m *SetStateRequest) GetValue() *any.Any

func (*SetStateRequest) ProtoMessage added in v0.6.0 

func (*SetStateRequest) ProtoMessage()

func (*SetStateRequest) Reset added in v0.6.0 

func (m *SetStateRequest) Reset()

func (*SetStateRequest) String added in v0.6.0 

func (m *SetStateRequest) String() string

func (*SetStateRequest) XXX_DiscardUnknown added in v0.6.0 

func (m *SetStateRequest) XXX_DiscardUnknown()

func (*SetStateRequest) XXX_Marshal added in v0.6.0 

func (m *SetStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetStateRequest) XXX_Merge added in v0.6.0 

func (m *SetStateRequest) XXX_Merge(src proto.Message)

func (*SetStateRequest) XXX_Size added in v0.6.0 

func (m *SetStateRequest) XXX_Size() int

func (*SetStateRequest) XXX_Unmarshal added in v0.6.0 

func (m *SetStateRequest) XXX_Unmarshal(b []byte) error

type WatchStateRequest added in v0.6.0 

type WatchStateRequest struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WatchStateRequest) Descriptor added in v0.6.0 

func (*WatchStateRequest) Descriptor() ([]byte, []int)

func (*WatchStateRequest) GetKey added in v0.6.0 

func (m *WatchStateRequest) GetKey() string

func (*WatchStateRequest) ProtoMessage added in v0.6.0 

func (*WatchStateRequest) ProtoMessage()

func (*WatchStateRequest) Reset added in v0.6.0 

func (m *WatchStateRequest) Reset()

func (*WatchStateRequest) String added in v0.6.0 

func (m *WatchStateRequest) String() string

func (*WatchStateRequest) XXX_DiscardUnknown added in v0.6.0 

func (m *WatchStateRequest) XXX_DiscardUnknown()

func (*WatchStateRequest) XXX_Marshal added in v0.6.0 

func (m *WatchStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WatchStateRequest) XXX_Merge added in v0.6.0 

func (m *WatchStateRequest) XXX_Merge(src proto.Message)

func (*WatchStateRequest) XXX_Size added in v0.6.0 

func (m *WatchStateRequest) XXX_Size() int

func (*WatchStateRequest) XXX_Unmarshal added in v0.6.0 

func (m *WatchStateRequest) XXX_Unmarshal(b []byte) error

type WatchStateResponse added in v0.6.0 

type WatchStateResponse struct {
	Command              WatchStateResponse_Command `protobuf:"varint,1,opt,name=command,proto3,enum=protobuf.WatchStateResponse_Command" json:"command,omitempty"`
	Key                  string                     `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value                *any.Any                   `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*WatchStateResponse) Descriptor added in v0.6.0 

func (*WatchStateResponse) Descriptor() ([]byte, []int)

func (*WatchStateResponse) GetCommand added in v0.6.0 

func (m *WatchStateResponse) GetCommand() WatchStateResponse_Command

func (*WatchStateResponse) GetKey added in v0.6.0 

func (m *WatchStateResponse) GetKey() string

func (*WatchStateResponse) GetValue added in v0.6.0 

func (m *WatchStateResponse) GetValue() *any.Any

func (*WatchStateResponse) ProtoMessage added in v0.6.0 

func (*WatchStateResponse) ProtoMessage()

func (*WatchStateResponse) Reset added in v0.6.0 

func (m *WatchStateResponse) Reset()

func (*WatchStateResponse) String added in v0.6.0 

func (m *WatchStateResponse) String() string

func (*WatchStateResponse) XXX_DiscardUnknown added in v0.6.0 

func (m *WatchStateResponse) XXX_DiscardUnknown()

func (*WatchStateResponse) XXX_Marshal added in v0.6.0 

func (m *WatchStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WatchStateResponse) XXX_Merge added in v0.6.0 

func (m *WatchStateResponse) XXX_Merge(src proto.Message)

func (*WatchStateResponse) XXX_Size added in v0.6.0 

func (m *WatchStateResponse) XXX_Size() int

func (*WatchStateResponse) XXX_Unmarshal added in v0.6.0 

func (m *WatchStateResponse) XXX_Unmarshal(b []byte) error

type WatchStateResponse_Command added in v0.6.0 

type WatchStateResponse_Command int32
const (
	WatchStateResponse_UNKNOWN WatchStateResponse_Command = 0
	WatchStateResponse_SET     WatchStateResponse_Command = 1
	WatchStateResponse_DELETE  WatchStateResponse_Command = 2
)

func (WatchStateResponse_Command) EnumDescriptor added in v0.6.0 

func (WatchStateResponse_Command) EnumDescriptor() ([]byte, []int)

func (WatchStateResponse_Command) String added in v0.6.0 

func (x WatchStateResponse_Command) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.