protobuf

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
}

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

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

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
}

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

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
}

type Event_Type int32

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

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

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
}

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)
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (KVS_ListClient, 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)
}

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)
	List(*ListRequest, KVS_ListServer) 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
}

type KVS_ListClient interface {
	Recv() (*ListResponse, error)
	grpc.ClientStream
}

type KVS_ListServer interface {
	Send(*ListResponse) error
	grpc.ServerStream
}

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

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

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
}

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

type ListRequest struct {
	Prefix       string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	ReturnValues bool   `protobuf:"varint,2,opt,name=return_values,json=returnValues,proto3" json:"return_values,omitempty"`
	// contains filtered or unexported fields
}

type ListResponse struct {
	Key   []byte `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
}

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

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
}

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

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
}

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

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
}

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

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
}

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
}

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
}

type UnimplementedKVSServer struct {
}

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

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