protobuf

package
v0.4.2 Latest Latest
Warning

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

 Go to latest Published: Dec 9, 2020 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Overview

Package protobuf is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	Event_Type_name = map[int32]string{
		0: "Unknown",
		1: "Join",
		2: "Leave",
		3: "Set",
		4: "SetObject",
		5: "Delete",
		6: "DeleteObject",
	}
	Event_Type_value = map[string]int32{
		"Unknown":      0,
		"Join":         1,
		"Leave":        2,
		"Set":          3,
		"SetObject":    4,
		"Delete":       5,
		"DeleteObject": 6,
	}
)

Enum value maps for Event_Type.

View Source 
var File_protobuf_kvs_proto protoreflect.FileDescriptor
View Source 
var File_protobuf_meta_proto protoreflect.FileDescriptor
View Source 
var KVS_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "kvs.KVS",
	HandlerType: (*KVSServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "LivenessCheck",
			Handler:    _KVS_LivenessCheck_Handler,
		},
		{
			MethodName: "ReadinessCheck",
			Handler:    _KVS_ReadinessCheck_Handler,
		},
		{
			MethodName: "Node",
			Handler:    _KVS_Node_Handler,
		},
		{
			MethodName: "Join",
			Handler:    _KVS_Join_Handler,
		},
		{
			MethodName: "Cluster",
			Handler:    _KVS_Cluster_Handler,
		},
		{
			MethodName: "Leave",
			Handler:    _KVS_Leave_Handler,
		},
		{
			MethodName: "Snapshot",
			Handler:    _KVS_Snapshot_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _KVS_Get_Handler,
		},
		{
			MethodName: "Scan",
			Handler:    _KVS_Scan_Handler,
		},
		{
			MethodName: "Set",
			Handler:    _KVS_Set_Handler,
		},
		{
			MethodName: "SetObject",
			Handler:    _KVS_SetObject_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _KVS_Delete_Handler,
		},
		{
			MethodName: "DeleteObject",
			Handler:    _KVS_DeleteObject_Handler,
		},
		{
			MethodName: "Metrics",
			Handler:    _KVS_Metrics_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Watch",
			Handler:       _KVS_Watch_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "protobuf/kvs.proto",
}

KVS_ServiceDesc is the grpc.ServiceDesc for KVS service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterKVSHandler 

func RegisterKVSHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterKVSHandler registers the http handlers for service KVS to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterKVSHandlerClient 

func RegisterKVSHandlerClient(ctx context.Context, mux *runtime.ServeMux, client KVSClient) error

RegisterKVSHandlerClient registers the http handlers for service KVS to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "KVSClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "KVSClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "KVSClient" to call the correct interceptors.

func RegisterKVSHandlerFromEndpoint 

func RegisterKVSHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterKVSHandlerFromEndpoint is same as RegisterKVSHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterKVSHandlerServer 

func RegisterKVSHandlerServer(ctx context.Context, mux *runtime.ServeMux, server KVSServer) error

RegisterKVSHandlerServer registers the http handlers for service KVS to "mux". UnaryRPC :call KVSServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterKVSHandlerFromEndpoint instead.

func RegisterKVSServer 

func RegisterKVSServer(s grpc.ServiceRegistrar, srv KVSServer)

Types

type Cluster 

type Cluster struct {
	Nodes  map[string]*Node `` /* 151-byte string literal not displayed */
	Leader string           `protobuf:"bytes,2,opt,name=leader,proto3" json:"leader,omitempty"`
	// contains filtered or unexported fields
}

func (*Cluster) Descriptor deprecated 

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

Deprecated: Use Cluster.ProtoReflect.Descriptor instead.

func (*Cluster) GetLeader 

func (x *Cluster) GetLeader() string

func (*Cluster) GetNodes 

func (x *Cluster) GetNodes() map[string]*Node

func (*Cluster) ProtoMessage 

func (*Cluster) ProtoMessage()

func (*Cluster) ProtoReflect 

func (x *Cluster) ProtoReflect() protoreflect.Message

func (*Cluster) Reset 

func (x *Cluster) Reset()

func (*Cluster) String 

func (x *Cluster) String() string

type ClusterResponse 

type ClusterResponse struct {
	Cluster *Cluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterResponse) Descriptor deprecated 

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

Deprecated: Use ClusterResponse.ProtoReflect.Descriptor instead.

func (*ClusterResponse) GetCluster 

func (x *ClusterResponse) GetCluster() *Cluster

func (*ClusterResponse) ProtoMessage 

func (*ClusterResponse) ProtoMessage()

func (*ClusterResponse) ProtoReflect 

func (x *ClusterResponse) ProtoReflect() protoreflect.Message

func (*ClusterResponse) Reset 

func (x *ClusterResponse) Reset()

func (*ClusterResponse) String 

func (x *ClusterResponse) String() string

type DeleteMetadataRequest 

type DeleteMetadataRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteMetadataRequest) Descriptor deprecated 

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

Deprecated: Use DeleteMetadataRequest.ProtoReflect.Descriptor instead.

func (*DeleteMetadataRequest) GetId 

func (x *DeleteMetadataRequest) GetId() string

func (*DeleteMetadataRequest) ProtoMessage 

func (*DeleteMetadataRequest) ProtoMessage()

func (*DeleteMetadataRequest) ProtoReflect 

func (x *DeleteMetadataRequest) ProtoReflect() protoreflect.Message

func (*DeleteMetadataRequest) Reset 

func (x *DeleteMetadataRequest) Reset()

func (*DeleteMetadataRequest) String 

func (x *DeleteMetadataRequest) String() string

type DeleteObjectRequest 

type DeleteObjectRequest struct {
	ItemKey string `protobuf:"bytes,1,opt,name=item_key,json=itemKey,proto3" json:"item_key,omitempty"`
	MetaKey string `protobuf:"bytes,2,opt,name=meta_key,json=metaKey,proto3" json:"meta_key,omitempty"`
	// Equivalent to HTTP header If-None-Match.
	IfNoneMatch string `protobuf:"bytes,3,opt,name=if_none_match,json=ifNoneMatch,proto3" json:"if_none_match,omitempty"`
	// Equivalent to HTTP header If-Match.
	IfMatch string `protobuf:"bytes,4,opt,name=if_match,json=ifMatch,proto3" json:"if_match,omitempty"`
	// Equivalent to HTTP header If-Unmodified-Since.
	IfUnmodifiedSince int64 `protobuf:"varint,5,opt,name=if_unmodified_since,json=ifUnmodifiedSince,proto3" json:"if_unmodified_since,omitempty"`
	// Equivalent to HTTP header If-Modified-Since.
	IfModifiedSince int64 `protobuf:"varint,6,opt,name=if_modified_since,json=ifModifiedSince,proto3" json:"if_modified_since,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteObjectRequest) Descriptor deprecated 

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

Deprecated: Use DeleteObjectRequest.ProtoReflect.Descriptor instead.

func (*DeleteObjectRequest) GetIfMatch 

func (x *DeleteObjectRequest) GetIfMatch() string

func (*DeleteObjectRequest) GetIfModifiedSince 

func (x *DeleteObjectRequest) GetIfModifiedSince() int64

func (*DeleteObjectRequest) GetIfNoneMatch 

func (x *DeleteObjectRequest) GetIfNoneMatch() string

func (*DeleteObjectRequest) GetIfUnmodifiedSince 

func (x *DeleteObjectRequest) GetIfUnmodifiedSince() int64

func (*DeleteObjectRequest) GetItemKey 

func (x *DeleteObjectRequest) GetItemKey() string

func (*DeleteObjectRequest) GetMetaKey 

func (x *DeleteObjectRequest) GetMetaKey() string

func (*DeleteObjectRequest) ProtoMessage 

func (*DeleteObjectRequest) ProtoMessage()

func (*DeleteObjectRequest) ProtoReflect 

func (x *DeleteObjectRequest) ProtoReflect() protoreflect.Message

func (*DeleteObjectRequest) Reset 

func (x *DeleteObjectRequest) Reset()

func (*DeleteObjectRequest) String 

func (x *DeleteObjectRequest) String() string

type DeleteRequest 

type DeleteRequest struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) GetKey 

func (x *DeleteRequest) GetKey() string

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect 

func (x *DeleteRequest) ProtoReflect() protoreflect.Message

func (*DeleteRequest) Reset 

func (x *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (x *DeleteRequest) String() string

type Event 

type Event struct {
	Type Event_Type `protobuf:"varint,1,opt,name=type,proto3,enum=kvs.Event_Type" json:"type,omitempty"`
	Data *any.Any   `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*Event) Descriptor deprecated 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetData 

func (x *Event) GetData() *any.Any

func (*Event) GetType 

func (x *Event) GetType() Event_Type

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

func (x *Event) ProtoReflect() protoreflect.Message

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type Event_Type 

type Event_Type int32
const (
	Event_Unknown      Event_Type = 0
	Event_Join         Event_Type = 1
	Event_Leave        Event_Type = 2
	Event_Set          Event_Type = 3
	Event_SetObject    Event_Type = 4
	Event_Delete       Event_Type = 5
	Event_DeleteObject Event_Type = 6
)

func (Event_Type) Descriptor 

func (Event_Type) Descriptor() protoreflect.EnumDescriptor

func (Event_Type) Enum 

func (x Event_Type) Enum() *Event_Type

func (Event_Type) EnumDescriptor deprecated 

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

Deprecated: Use Event_Type.Descriptor instead.

func (Event_Type) Number 

func (x Event_Type) Number() protoreflect.EnumNumber

func (Event_Type) String 

func (x Event_Type) String() string

func (Event_Type) Type 

func (Event_Type) Type() protoreflect.EnumType

type GetRequest 

type GetRequest struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRequest) Descriptor deprecated 

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetKey 

func (x *GetRequest) GetKey() string

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect 

func (x *GetRequest) ProtoReflect() protoreflect.Message

func (*GetRequest) Reset 

func (x *GetRequest) Reset()

func (*GetRequest) String 

func (x *GetRequest) String() string

type GetResponse 

type GetResponse struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResponse) Descriptor deprecated 

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetValue 

func (x *GetResponse) GetValue() []byte

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect 

func (x *GetResponse) ProtoReflect() protoreflect.Message

func (*GetResponse) Reset 

func (x *GetResponse) Reset()

func (*GetResponse) String 

func (x *GetResponse) String() string

type JoinRequest 

type JoinRequest struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Node *Node  `protobuf:"bytes,2,opt,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

func (*JoinRequest) Descriptor deprecated 

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

Deprecated: Use JoinRequest.ProtoReflect.Descriptor instead.

func (*JoinRequest) GetId 

func (x *JoinRequest) GetId() string

func (*JoinRequest) GetNode 

func (x *JoinRequest) GetNode() *Node

func (*JoinRequest) ProtoMessage 

func (*JoinRequest) ProtoMessage()

func (*JoinRequest) ProtoReflect 

func (x *JoinRequest) ProtoReflect() protoreflect.Message

func (*JoinRequest) Reset 

func (x *JoinRequest) Reset()

func (*JoinRequest) String 

func (x *JoinRequest) String() string

type KVSClient 

type KVSClient interface {
	LivenessCheck(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*LivenessCheckResponse, error)
	ReadinessCheck(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ReadinessCheckResponse, error)
	Node(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*NodeResponse, error)
	Join(ctx context.Context, in *JoinRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	Cluster(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ClusterResponse, error)
	Leave(ctx context.Context, in *LeaveRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	Snapshot(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	Scan(ctx context.Context, in *ScanRequest, opts ...grpc.CallOption) (*ScanResponse, error)
	Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	SetObject(ctx context.Context, in *SetObjectRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	DeleteObject(ctx context.Context, in *DeleteObjectRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	Watch(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (KVS_WatchClient, error)
	Metrics(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*MetricsResponse, error)
}

KVSClient is the client API for KVS service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewKVSClient 

func NewKVSClient(cc grpc.ClientConnInterface) KVSClient

type KVSServer 

type KVSServer interface {
	LivenessCheck(context.Context, *empty.Empty) (*LivenessCheckResponse, error)
	ReadinessCheck(context.Context, *empty.Empty) (*ReadinessCheckResponse, error)
	Node(context.Context, *empty.Empty) (*NodeResponse, error)
	Join(context.Context, *JoinRequest) (*empty.Empty, error)
	Cluster(context.Context, *empty.Empty) (*ClusterResponse, error)
	Leave(context.Context, *LeaveRequest) (*empty.Empty, error)
	Snapshot(context.Context, *empty.Empty) (*empty.Empty, error)
	Get(context.Context, *GetRequest) (*GetResponse, error)
	Scan(context.Context, *ScanRequest) (*ScanResponse, error)
	Set(context.Context, *SetRequest) (*empty.Empty, error)
	SetObject(context.Context, *SetObjectRequest) (*empty.Empty, error)
	Delete(context.Context, *DeleteRequest) (*empty.Empty, error)
	DeleteObject(context.Context, *DeleteObjectRequest) (*empty.Empty, error)
	Watch(*empty.Empty, KVS_WatchServer) error
	Metrics(context.Context, *empty.Empty) (*MetricsResponse, error)
	// contains filtered or unexported methods
}

KVSServer is the server API for KVS service. All implementations must embed UnimplementedKVSServer for forward compatibility

type KVS_WatchClient 

type KVS_WatchClient interface {
	Recv() (*WatchResponse, error)
	grpc.ClientStream
}

type KVS_WatchServer 

type KVS_WatchServer interface {
	Send(*WatchResponse) error
	grpc.ServerStream
}

type KeyValuePair 

type KeyValuePair struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyValuePair) Descriptor deprecated 

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

Deprecated: Use KeyValuePair.ProtoReflect.Descriptor instead.

func (*KeyValuePair) GetKey 

func (x *KeyValuePair) GetKey() string

func (*KeyValuePair) GetValue 

func (x *KeyValuePair) GetValue() []byte

func (*KeyValuePair) ProtoMessage 

func (*KeyValuePair) ProtoMessage()

func (*KeyValuePair) ProtoReflect 

func (x *KeyValuePair) ProtoReflect() protoreflect.Message

func (*KeyValuePair) Reset 

func (x *KeyValuePair) Reset()

func (*KeyValuePair) String 

func (x *KeyValuePair) String() string

type LeaveRequest 

type LeaveRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*LeaveRequest) Descriptor deprecated 

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

Deprecated: Use LeaveRequest.ProtoReflect.Descriptor instead.

func (*LeaveRequest) GetId 

func (x *LeaveRequest) GetId() string

func (*LeaveRequest) ProtoMessage 

func (*LeaveRequest) ProtoMessage()

func (*LeaveRequest) ProtoReflect 

func (x *LeaveRequest) ProtoReflect() protoreflect.Message

func (*LeaveRequest) Reset 

func (x *LeaveRequest) Reset()

func (*LeaveRequest) String 

func (x *LeaveRequest) String() string

type LivenessCheckResponse 

type LivenessCheckResponse struct {
	Alive bool `protobuf:"varint,1,opt,name=alive,proto3" json:"alive,omitempty"`
	// contains filtered or unexported fields
}

func (*LivenessCheckResponse) Descriptor deprecated 

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

Deprecated: Use LivenessCheckResponse.ProtoReflect.Descriptor instead.

func (*LivenessCheckResponse) GetAlive 

func (x *LivenessCheckResponse) GetAlive() bool

func (*LivenessCheckResponse) ProtoMessage 

func (*LivenessCheckResponse) ProtoMessage()

func (*LivenessCheckResponse) ProtoReflect 

func (x *LivenessCheckResponse) ProtoReflect() protoreflect.Message

func (*LivenessCheckResponse) Reset 

func (x *LivenessCheckResponse) Reset()

func (*LivenessCheckResponse) String 

func (x *LivenessCheckResponse) String() string

type Metadata 

type Metadata struct {
	GrpcAddress string `protobuf:"bytes,1,opt,name=grpc_address,json=grpcAddress,proto3" json:"grpc_address,omitempty"`
	HttpAddress string `protobuf:"bytes,2,opt,name=http_address,json=httpAddress,proto3" json:"http_address,omitempty"`
	// contains filtered or unexported fields
}

func (*Metadata) Descriptor deprecated 

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

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) GetGrpcAddress 

func (x *Metadata) GetGrpcAddress() string

func (*Metadata) GetHttpAddress 

func (x *Metadata) GetHttpAddress() string

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect 

func (x *Metadata) ProtoReflect() protoreflect.Message

func (*Metadata) Reset 

func (x *Metadata) Reset()

func (*Metadata) String 

func (x *Metadata) String() string

type MetricsResponse 

type MetricsResponse struct {
	Metrics []byte `protobuf:"bytes,1,opt,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricsResponse) Descriptor deprecated 

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

Deprecated: Use MetricsResponse.ProtoReflect.Descriptor instead.

func (*MetricsResponse) GetMetrics 

func (x *MetricsResponse) GetMetrics() []byte

func (*MetricsResponse) ProtoMessage 

func (*MetricsResponse) ProtoMessage()

func (*MetricsResponse) ProtoReflect 

func (x *MetricsResponse) ProtoReflect() protoreflect.Message

func (*MetricsResponse) Reset 

func (x *MetricsResponse) Reset()

func (*MetricsResponse) String 

func (x *MetricsResponse) String() string

type Node 

type Node struct {
	RaftAddress string    `protobuf:"bytes,1,opt,name=raft_address,json=raftAddress,proto3" json:"raft_address,omitempty"`
	Metadata    *Metadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	State       string    `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*Node) Descriptor deprecated 

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

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetMetadata 

func (x *Node) GetMetadata() *Metadata

func (*Node) GetRaftAddress 

func (x *Node) GetRaftAddress() string

func (*Node) GetState 

func (x *Node) GetState() string

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) ProtoReflect 

func (x *Node) ProtoReflect() protoreflect.Message

func (*Node) Reset 

func (x *Node) Reset()

func (*Node) String 

func (x *Node) String() string

type NodeResponse 

type NodeResponse struct {
	Node *Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeResponse) Descriptor deprecated 

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

Deprecated: Use NodeResponse.ProtoReflect.Descriptor instead.

func (*NodeResponse) GetNode 

func (x *NodeResponse) GetNode() *Node

func (*NodeResponse) ProtoMessage 

func (*NodeResponse) ProtoMessage()

func (*NodeResponse) ProtoReflect 

func (x *NodeResponse) ProtoReflect() protoreflect.Message

func (*NodeResponse) Reset 

func (x *NodeResponse) Reset()

func (*NodeResponse) String 

func (x *NodeResponse) String() string

type ObjectMeta added in v0.4.2 

type ObjectMeta struct {

	// Reference stores the key of the object the metadata instance refers to.
	Reference string `protobuf:"bytes,1,opt,name=Reference,proto3" json:"Reference,omitempty"`
	// CreateTimestamp stores the timestamp of the initial creation of the
	// first generation of this object.
	CreateTimestamp int64 `protobuf:"varint,2,opt,name=CreateTimestamp,proto3" json:"CreateTimestamp,omitempty"`
	// UpdateTimestamp stores the timestamp of the creation of this version of the object.
	UpdateTimestamp int64 `protobuf:"varint,3,opt,name=UpdateTimestamp,proto3" json:"UpdateTimestamp,omitempty"`
	// Version is the global version of this object and provides a global chronological
	// versioning of all key-value pairs.
	Version string `protobuf:"bytes,4,opt,name=Version,proto3" json:"Version,omitempty"`
	// Generation is the version of this object and is increased by 1 every time it is updated.
	Generation uint64 `protobuf:"varint,5,opt,name=Generation,proto3" json:"Generation,omitempty"`
	// Children stores the direct dependencies of this object which should be deleted
	// in case of cascade deletion or removal of previously referenced children.
	Children []string `protobuf:"bytes,6,rep,name=Children,proto3" json:"Children,omitempty"`
	// HistoryCursor is set only for objects that are generation 2 or greater and it stores
	// the value of the previous version of this object.
	HistoryCursor string `protobuf:"bytes,7,opt,name=HistoryCursor,proto3" json:"HistoryCursor,omitempty"`
	// ContentEncoding is equivalent to the header Content-Encoding of the HTTP protocol
	// and can be omitted (undefined encoding), or set to either "plain" or "gzip".
	ContentEncoding string `protobuf:"bytes,8,opt,name=ContentEncoding,proto3" json:"ContentEncoding,omitempty"`
	// ContentEncoding is equivalent to the header Content-Type of the HTTP protocol
	// and can be omitted (undefined type) or set to any valid MIME type.
	ContentType string `protobuf:"bytes,9,opt,name=ContentType,proto3" json:"ContentType,omitempty"`
	// contains filtered or unexported fields
}

func (*ObjectMeta) Descriptor deprecated added in v0.4.2 

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

Deprecated: Use ObjectMeta.ProtoReflect.Descriptor instead.

func (*ObjectMeta) GetChildren added in v0.4.2 

func (x *ObjectMeta) GetChildren() []string

func (*ObjectMeta) GetContentEncoding added in v0.4.2 

func (x *ObjectMeta) GetContentEncoding() string

func (*ObjectMeta) GetContentType added in v0.4.2 

func (x *ObjectMeta) GetContentType() string

func (*ObjectMeta) GetCreateTimestamp added in v0.4.2 

func (x *ObjectMeta) GetCreateTimestamp() int64

func (*ObjectMeta) GetGeneration added in v0.4.2 

func (x *ObjectMeta) GetGeneration() uint64

func (*ObjectMeta) GetHistoryCursor added in v0.4.2 

func (x *ObjectMeta) GetHistoryCursor() string

func (*ObjectMeta) GetReference added in v0.4.2 

func (x *ObjectMeta) GetReference() string

func (*ObjectMeta) GetUpdateTimestamp added in v0.4.2 

func (x *ObjectMeta) GetUpdateTimestamp() int64

func (*ObjectMeta) GetVersion added in v0.4.2 

func (x *ObjectMeta) GetVersion() string

func (*ObjectMeta) ProtoMessage added in v0.4.2 

func (*ObjectMeta) ProtoMessage()

func (*ObjectMeta) ProtoReflect added in v0.4.2 

func (x *ObjectMeta) ProtoReflect() protoreflect.Message

func (*ObjectMeta) Reset added in v0.4.2 

func (x *ObjectMeta) Reset()

func (*ObjectMeta) String added in v0.4.2 

func (x *ObjectMeta) String() string

type ReadinessCheckResponse 

type ReadinessCheckResponse struct {
	Ready bool `protobuf:"varint,1,opt,name=ready,proto3" json:"ready,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadinessCheckResponse) Descriptor deprecated 

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

Deprecated: Use ReadinessCheckResponse.ProtoReflect.Descriptor instead.

func (*ReadinessCheckResponse) GetReady 

func (x *ReadinessCheckResponse) GetReady() bool

func (*ReadinessCheckResponse) ProtoMessage 

func (*ReadinessCheckResponse) ProtoMessage()

func (*ReadinessCheckResponse) ProtoReflect 

func (x *ReadinessCheckResponse) ProtoReflect() protoreflect.Message

func (*ReadinessCheckResponse) Reset 

func (x *ReadinessCheckResponse) Reset()

func (*ReadinessCheckResponse) String 

func (x *ReadinessCheckResponse) String() string

type ScanRequest 

type ScanRequest struct {
	Prefix string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// contains filtered or unexported fields
}

func (*ScanRequest) Descriptor deprecated 

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

Deprecated: Use ScanRequest.ProtoReflect.Descriptor instead.

func (*ScanRequest) GetPrefix 

func (x *ScanRequest) GetPrefix() string

func (*ScanRequest) ProtoMessage 

func (*ScanRequest) ProtoMessage()

func (*ScanRequest) ProtoReflect 

func (x *ScanRequest) ProtoReflect() protoreflect.Message

func (*ScanRequest) Reset 

func (x *ScanRequest) Reset()

func (*ScanRequest) String 

func (x *ScanRequest) String() string

type ScanResponse 

type ScanResponse struct {
	Values [][]byte `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*ScanResponse) Descriptor deprecated 

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

Deprecated: Use ScanResponse.ProtoReflect.Descriptor instead.

func (*ScanResponse) GetValues 

func (x *ScanResponse) GetValues() [][]byte

func (*ScanResponse) ProtoMessage 

func (*ScanResponse) ProtoMessage()

func (*ScanResponse) ProtoReflect 

func (x *ScanResponse) ProtoReflect() protoreflect.Message

func (*ScanResponse) Reset 

func (x *ScanResponse) Reset()

func (*ScanResponse) String 

func (x *ScanResponse) String() string

type SetMetadataRequest 

type SetMetadataRequest struct {
	Id       string    `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Metadata *Metadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*SetMetadataRequest) Descriptor deprecated 

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

Deprecated: Use SetMetadataRequest.ProtoReflect.Descriptor instead.

func (*SetMetadataRequest) GetId 

func (x *SetMetadataRequest) GetId() string

func (*SetMetadataRequest) GetMetadata 

func (x *SetMetadataRequest) GetMetadata() *Metadata

func (*SetMetadataRequest) ProtoMessage 

func (*SetMetadataRequest) ProtoMessage()

func (*SetMetadataRequest) ProtoReflect 

func (x *SetMetadataRequest) ProtoReflect() protoreflect.Message

func (*SetMetadataRequest) Reset 

func (x *SetMetadataRequest) Reset()

func (*SetMetadataRequest) String 

func (x *SetMetadataRequest) String() string

type SetObjectRequest 

type SetObjectRequest struct {
	Item *KeyValuePair `protobuf:"bytes,1,opt,name=item,proto3" json:"item,omitempty"`
	Meta *KeyValuePair `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"`
	// Equivalent to HTTP header If-None-Match.
	IfNoneMatch string `protobuf:"bytes,3,opt,name=if_none_match,json=ifNoneMatch,proto3" json:"if_none_match,omitempty"`
	// Equivalent to HTTP header If-Match.
	IfMatch string `protobuf:"bytes,4,opt,name=if_match,json=ifMatch,proto3" json:"if_match,omitempty"`
	// Equivalent to HTTP header If-Unmodified-Since.
	IfUnmodifiedSince int64 `protobuf:"varint,5,opt,name=if_unmodified_since,json=ifUnmodifiedSince,proto3" json:"if_unmodified_since,omitempty"`
	// Equivalent to HTTP header If-Modified-Since.
	IfModifiedSince int64 `protobuf:"varint,6,opt,name=if_modified_since,json=ifModifiedSince,proto3" json:"if_modified_since,omitempty"`
	// contains filtered or unexported fields
}

func (*SetObjectRequest) Descriptor deprecated 

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

Deprecated: Use SetObjectRequest.ProtoReflect.Descriptor instead.

func (*SetObjectRequest) GetIfMatch 

func (x *SetObjectRequest) GetIfMatch() string

func (*SetObjectRequest) GetIfModifiedSince 

func (x *SetObjectRequest) GetIfModifiedSince() int64

func (*SetObjectRequest) GetIfNoneMatch 

func (x *SetObjectRequest) GetIfNoneMatch() string

func (*SetObjectRequest) GetIfUnmodifiedSince 

func (x *SetObjectRequest) GetIfUnmodifiedSince() int64

func (*SetObjectRequest) GetItem 

func (x *SetObjectRequest) GetItem() *KeyValuePair

func (*SetObjectRequest) GetMeta 

func (x *SetObjectRequest) GetMeta() *KeyValuePair

func (*SetObjectRequest) ProtoMessage 

func (*SetObjectRequest) ProtoMessage()

func (*SetObjectRequest) ProtoReflect 

func (x *SetObjectRequest) ProtoReflect() protoreflect.Message

func (*SetObjectRequest) Reset 

func (x *SetObjectRequest) Reset()

func (*SetObjectRequest) String 

func (x *SetObjectRequest) String() string

type SetRequest 

type SetRequest struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*SetRequest) Descriptor deprecated 

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

Deprecated: Use SetRequest.ProtoReflect.Descriptor instead.

func (*SetRequest) GetKey 

func (x *SetRequest) GetKey() string

func (*SetRequest) GetValue 

func (x *SetRequest) GetValue() []byte

func (*SetRequest) ProtoMessage 

func (*SetRequest) ProtoMessage()

func (*SetRequest) ProtoReflect 

func (x *SetRequest) ProtoReflect() protoreflect.Message

func (*SetRequest) Reset 

func (x *SetRequest) Reset()

func (*SetRequest) String 

func (x *SetRequest) String() string

type UnimplementedKVSServer 

type UnimplementedKVSServer struct {
}

UnimplementedKVSServer must be embedded to have forward compatible implementations.

func (UnimplementedKVSServer) Cluster 

func (UnimplementedKVSServer) Cluster(context.Context, *empty.Empty) (*ClusterResponse, error)

func (UnimplementedKVSServer) Delete 

func (UnimplementedKVSServer) Delete(context.Context, *DeleteRequest) (*empty.Empty, error)

func (UnimplementedKVSServer) DeleteObject 

func (UnimplementedKVSServer) DeleteObject(context.Context, *DeleteObjectRequest) (*empty.Empty, error)

func (UnimplementedKVSServer) Get 

func (UnimplementedKVSServer) Get(context.Context, *GetRequest) (*GetResponse, error)

func (UnimplementedKVSServer) Join 

func (UnimplementedKVSServer) Join(context.Context, *JoinRequest) (*empty.Empty, error)

func (UnimplementedKVSServer) Leave 

func (UnimplementedKVSServer) Leave(context.Context, *LeaveRequest) (*empty.Empty, error)

func (UnimplementedKVSServer) LivenessCheck 

func (UnimplementedKVSServer) LivenessCheck(context.Context, *empty.Empty) (*LivenessCheckResponse, error)

func (UnimplementedKVSServer) Metrics 

func (UnimplementedKVSServer) Metrics(context.Context, *empty.Empty) (*MetricsResponse, error)

func (UnimplementedKVSServer) Node 

func (UnimplementedKVSServer) Node(context.Context, *empty.Empty) (*NodeResponse, error)

func (UnimplementedKVSServer) ReadinessCheck 

func (UnimplementedKVSServer) ReadinessCheck(context.Context, *empty.Empty) (*ReadinessCheckResponse, error)

func (UnimplementedKVSServer) Scan 

func (UnimplementedKVSServer) Scan(context.Context, *ScanRequest) (*ScanResponse, error)

func (UnimplementedKVSServer) Set 

func (UnimplementedKVSServer) Set(context.Context, *SetRequest) (*empty.Empty, error)

func (UnimplementedKVSServer) SetObject 

func (UnimplementedKVSServer) SetObject(context.Context, *SetObjectRequest) (*empty.Empty, error)

func (UnimplementedKVSServer) Snapshot 

func (UnimplementedKVSServer) Snapshot(context.Context, *empty.Empty) (*empty.Empty, error)

func (UnimplementedKVSServer) Watch 

func (UnimplementedKVSServer) Watch(*empty.Empty, KVS_WatchServer) error

type UnsafeKVSServer 

type UnsafeKVSServer interface {
	// contains filtered or unexported methods
}

UnsafeKVSServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to KVSServer will result in compilation errors.

type WatchResponse 

type WatchResponse struct {
	Event *Event `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchResponse) Descriptor deprecated 

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

Deprecated: Use WatchResponse.ProtoReflect.Descriptor instead.

func (*WatchResponse) GetEvent 

func (x *WatchResponse) GetEvent() *Event

func (*WatchResponse) ProtoMessage 

func (*WatchResponse) ProtoMessage()

func (*WatchResponse) ProtoReflect 

func (x *WatchResponse) ProtoReflect() protoreflect.Message

func (*WatchResponse) Reset 

func (x *WatchResponse) Reset()

func (*WatchResponse) String 

func (x *WatchResponse) 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.