serverpb

type AppendClusterRequest struct {
	ServerId string `protobuf:"bytes,1,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
	PeerAddr string `protobuf:"bytes,2,opt,name=peer_addr,json=peerAddr,proto3" json:"peer_addr,omitempty"`
	Voter    bool   `protobuf:"varint,3,opt,name=voter,proto3" json:"voter,omitempty"`
	// contains filtered or unexported fields
}

type AppendClusterResponse struct {
	// contains filtered or unexported fields
}

type ConnectServiceRequest struct {
	// contains filtered or unexported fields
}

type ConnectServiceResponse struct {
	// contains filtered or unexported fields
}

type DeleteRequest struct {

	// key is the key, in bytes, to delete into the key-value store.
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// namespace means the same key-value store can exist in different namespaces
	Namespace *string `protobuf:"bytes,2,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

type DeleteResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// contains filtered or unexported fields
}

type DestroyServiceRequest struct {
	// contains filtered or unexported fields
}

type DestroyServiceResponse struct {
	// contains filtered or unexported fields
}

type GetRequest struct {

	// key is the key, in bytes, to set into the key-value store.
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// namespace means the same key-value store can exist in different namespaces
	Namespace *string `protobuf:"bytes,2,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

type GetResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Value  []byte          `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Ttl    *uint32         `protobuf:"varint,3,opt,name=ttl,proto3,oneof" json:"ttl,omitempty"`
	// contains filtered or unexported fields
}

type HealthCheckRServiceRequest struct {
	// contains filtered or unexported fields
}

type HealthCheckRServiceResponse struct {
	// contains filtered or unexported fields
}

type HealthCheckSServiceRequest struct {
	// contains filtered or unexported fields
}

type HealthCheckSServiceResponse struct {
	// contains filtered or unexported fields
}

type KVClient interface {
	Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*SetResponse, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	TrySet(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*SetResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	Watch(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (KV_WatchClient, error)
}

type KVServer interface {
	Set(context.Context, *SetRequest) (*SetResponse, error)
	Get(context.Context, *GetRequest) (*GetResponse, error)
	TrySet(context.Context, *SetRequest) (*SetResponse, error)
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	Watch(*WatchRequest, KV_WatchServer) error
	// contains filtered or unexported methods
}

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

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

type KeepAliveServiceRequest struct {
	// contains filtered or unexported fields
}

type KeepAliveServiceResponse struct {
	// contains filtered or unexported fields
}

type LeaderMonitorRequest struct {
	// contains filtered or unexported fields
}

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

type LockRequest struct {
	LockId string `protobuf:"bytes,1,opt,name=lock_id,json=lockId,proto3" json:"lock_id,omitempty"`
	Ttl    int64  `protobuf:"varint,2,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// contains filtered or unexported fields
}

type LockResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// contains filtered or unexported fields
}

type LockerClient interface {
	Lock(ctx context.Context, in *LockRequest, opts ...grpc.CallOption) (*LockResponse, error)
	Unlock(ctx context.Context, in *UnlockRequest, opts ...grpc.CallOption) (*UnlockResponse, error)
	TryLock(ctx context.Context, in *TryLockRequest, opts ...grpc.CallOption) (*TryLockResponse, error)
}

type LockerServer interface {
	Lock(context.Context, *LockRequest) (*LockResponse, error)
	Unlock(context.Context, *UnlockRequest) (*UnlockResponse, error)
	TryLock(context.Context, *TryLockRequest) (*TryLockResponse, error)
	// contains filtered or unexported methods
}

type PipelineServiceRequest struct {
	// contains filtered or unexported fields
}

type PipelineServiceResponse struct {
	// contains filtered or unexported fields
}

type QueryServiceRequest struct {
	// contains filtered or unexported fields
}

type QueryServiceResponse struct {
	// contains filtered or unexported fields
}

type RaftLogCommand int32

type RaftLogPayload struct {
	Command   RaftLogCommand `protobuf:"varint,1,opt,name=command,proto3,enum=serverpb.RaftLogCommand" json:"command,omitempty"`
	Key       []byte         `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value     []byte         `protobuf:"bytes,3,opt,name=value,proto3,oneof" json:"value,omitempty"`
	Ttl       *uint32        `protobuf:"varint,4,opt,name=ttl,proto3,oneof" json:"ttl,omitempty"`
	Namespace *string        `protobuf:"bytes,5,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

type RedQueenClient interface {
	AppendCluster(ctx context.Context, in *AppendClusterRequest, opts ...grpc.CallOption) (*AppendClusterResponse, error)
	LeaderMonitor(ctx context.Context, in *LeaderMonitorRequest, opts ...grpc.CallOption) (RedQueen_LeaderMonitorClient, error)
}

type RedQueenServer interface {
	AppendCluster(context.Context, *AppendClusterRequest) (*AppendClusterResponse, error)
	LeaderMonitor(*LeaderMonitorRequest, RedQueen_LeaderMonitorServer) error
	// contains filtered or unexported methods
}

type RedQueen_LeaderMonitorClient interface {
	Recv() (*LeaderMonitorResponse, error)
	grpc.ClientStream
}

type RedQueen_LeaderMonitorServer interface {
	Send(*LeaderMonitorResponse) error
	grpc.ServerStream
}

type RegistryServiceRequest struct {
	// contains filtered or unexported fields
}

type RegistryServiceResponse struct {
	// contains filtered or unexported fields
}

type ResponseHeader struct {

	// cluster_id is the ID of the cluster which sent the response.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// reserve field
	Revision uint64 `protobuf:"varint,2,opt,name=revision,proto3" json:"revision,omitempty"`
	// raft_term is the raft term when the request was applied.
	RaftTerm uint64 `protobuf:"varint,3,opt,name=raft_term,json=raftTerm,proto3" json:"raft_term,omitempty"`
	// contains filtered or unexported fields
}

type ServiceBridgeClient interface {
	Register(ctx context.Context, in *RegistryServiceRequest, opts ...grpc.CallOption) (*RegistryServiceResponse, error)
	Destroy(ctx context.Context, in *DestroyServiceRequest, opts ...grpc.CallOption) (*DestroyServiceResponse, error)
	Query(ctx context.Context, in *QueryServiceRequest, opts ...grpc.CallOption) (*QueryServiceResponse, error)
	Connect(ctx context.Context, in *ConnectServiceRequest, opts ...grpc.CallOption) (*ConnectServiceResponse, error)
	Pipeline(ctx context.Context, opts ...grpc.CallOption) (ServiceBridge_PipelineClient, error)
	HealthCheckSender(ctx context.Context, opts ...grpc.CallOption) (ServiceBridge_HealthCheckSenderClient, error)
	HealthCheckReceiver(ctx context.Context, in *HealthCheckRServiceRequest, opts ...grpc.CallOption) (ServiceBridge_HealthCheckReceiverClient, error)
}

type ServiceBridgeServer interface {
	Register(context.Context, *RegistryServiceRequest) (*RegistryServiceResponse, error)
	Destroy(context.Context, *DestroyServiceRequest) (*DestroyServiceResponse, error)
	Query(context.Context, *QueryServiceRequest) (*QueryServiceResponse, error)
	Connect(context.Context, *ConnectServiceRequest) (*ConnectServiceResponse, error)
	Pipeline(ServiceBridge_PipelineServer) error
	HealthCheckSender(ServiceBridge_HealthCheckSenderServer) error
	HealthCheckReceiver(*HealthCheckRServiceRequest, ServiceBridge_HealthCheckReceiverServer) error
	// contains filtered or unexported methods
}

type ServiceBridge_HealthCheckReceiverClient interface {
	Recv() (*HealthCheckRServiceResponse, error)
	grpc.ClientStream
}

type ServiceBridge_HealthCheckReceiverServer interface {
	Send(*HealthCheckRServiceResponse) error
	grpc.ServerStream
}

type ServiceBridge_HealthCheckSenderClient interface {
	Send(*HealthCheckSServiceRequest) error
	CloseAndRecv() (*HealthCheckSServiceResponse, error)
	grpc.ClientStream
}

type ServiceBridge_HealthCheckSenderServer interface {
	SendAndClose(*HealthCheckSServiceResponse) error
	Recv() (*HealthCheckSServiceRequest, error)
	grpc.ServerStream
}

type ServiceBridge_PipelineClient interface {
	Send(*PipelineServiceRequest) error
	Recv() (*PipelineServiceResponse, error)
	grpc.ClientStream
}

type ServiceBridge_PipelineServer interface {
	Send(*PipelineServiceResponse) error
	Recv() (*PipelineServiceRequest, error)
	grpc.ServerStream
}

type ServiceHealthStatus int32

type SetRequest struct {

	// key is the key, in bytes, to set into the key-value store.
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// value is the value, in bytes, to associate with the key in the key-value store.
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// ttl indicates the ttl time of this key-value store.
	// 0 means never ttl, the unit is second.
	Ttl         uint32 `protobuf:"varint,3,opt,name=ttl,proto3" json:"ttl,omitempty"`
	IgnoreValue bool   `protobuf:"varint,4,opt,name=ignore_value,json=ignoreValue,proto3" json:"ignore_value,omitempty"`
	IgnoreTtl   bool   `protobuf:"varint,5,opt,name=ignore_ttl,json=ignoreTtl,proto3" json:"ignore_ttl,omitempty"`
	// namespace means the same key-value store can exist in different namespaces
	Namespace *string `protobuf:"bytes,6,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

type SetResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// contains filtered or unexported fields
}

type TryLockRequest struct {
	LockId   string `protobuf:"bytes,1,opt,name=lock_id,json=lockId,proto3" json:"lock_id,omitempty"`
	Ttl      int64  `protobuf:"varint,2,opt,name=ttl,proto3" json:"ttl,omitempty"`
	Deadline int64  `protobuf:"varint,3,opt,name=deadline,proto3" json:"deadline,omitempty"`
	// contains filtered or unexported fields
}

type TryLockResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedKVServer struct {
}

type UnimplementedLockerServer struct {
}

type UnimplementedRedQueenServer struct {
}

type UnimplementedServiceBridgeServer struct {
}

type UnlockRequest struct {
	LockId string `protobuf:"bytes,1,opt,name=lock_id,json=lockId,proto3" json:"lock_id,omitempty"`
	// contains filtered or unexported fields
}

type UnlockResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// contains filtered or unexported fields
}

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

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

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

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

type WatchRequest struct {

	// key is the key, in bytes, to delete into the key-value store.
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// ignore_errors caused by problems such as key-value being deleted or not existing
	IgnoreErrors bool `protobuf:"varint,2,opt,name=ignore_errors,json=ignoreErrors,proto3" json:"ignore_errors,omitempty"`
	// namespace means the same key-value store can exist in different namespaces
	Namespace *string `protobuf:"bytes,3,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"`
	// buf_size, declare the buffer size of watch
	BufSize *uint32 `protobuf:"varint,4,opt,name=buf_size,json=bufSize,proto3,oneof" json:"buf_size,omitempty"`
	// contains filtered or unexported fields
}

type WatchResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// update_seq is the updated serial number (current session)
	UpdateSeq uint64 `protobuf:"varint,2,opt,name=update_seq,json=updateSeq,proto3" json:"update_seq,omitempty"`
	// timestamp is the when this value was updated
	Timestamp int64  `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Data      []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}