api

type ClockClient interface {
	Get(ctx context.Context, in *ClockGetRequest, opts ...grpc.CallOption) (*ClockGetResponse, error)
	Set(ctx context.Context, in *ClockSetRequest, opts ...grpc.CallOption) (*ClockSetResponse, error)
}

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

type ClockGetResponse struct {
	Value *ClockValue `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type ClockServer interface {
	Get(context.Context, *ClockGetRequest) (*ClockGetResponse, error)
	Set(context.Context, *ClockSetRequest) (*ClockSetResponse, error)
	// contains filtered or unexported methods
}

type ClockSetRequest struct {
	Value *ClockValue `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

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

type ClockValue struct {
	Epoch uint64 `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"`
	Clock uint64 `protobuf:"varint,2,opt,name=clock,proto3" json:"clock,omitempty"`
	// contains filtered or unexported fields
}

type ClockedEntry struct {
	Entry *Entry      `protobuf:"bytes,1,opt,name=entry,proto3" json:"entry,omitempty"`
	Clock *ClockValue `protobuf:"bytes,2,opt,name=clock,proto3" json:"clock,omitempty"`
	// contains filtered or unexported fields
}

type ClusterClient interface {
	Info(ctx context.Context, in *ClusterInfoRequest, opts ...grpc.CallOption) (*ClusterInfoResponse, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*SetResponse, error)
}

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

type ClusterInfoResponse struct {
	Uptime           *durationpb.Duration `protobuf:"bytes,1,opt,name=uptime,proto3" json:"uptime,omitempty"`
	ReplicationLevel int64                `protobuf:"varint,2,opt,name=replication_level,json=replicationLevel,proto3" json:"replication_level,omitempty"`
	StorageNodes     []*StorageNode       `protobuf:"bytes,3,rep,name=storage_nodes,json=storageNodes,proto3" json:"storage_nodes,omitempty"`
	// contains filtered or unexported fields
}

type ClusterServer interface {
	Info(context.Context, *ClusterInfoRequest) (*ClusterInfoResponse, error)
	Get(context.Context, *GetRequest) (*GetResponse, error)
	Set(context.Context, *SetRequest) (*SetResponse, error)
	// contains filtered or unexported methods
}

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

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

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

type Health int32

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

type HealthResponse struct {
	NodeId string               `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Status Health               `protobuf:"varint,2,opt,name=status,proto3,enum=api.Health" json:"status,omitempty"`
	Uptime *durationpb.Duration `protobuf:"bytes,3,opt,name=uptime,proto3" json:"uptime,omitempty"`
	// contains filtered or unexported fields
}

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

type InfoResponse struct {
	NodeId string               `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Uptime *durationpb.Duration `protobuf:"bytes,2,opt,name=uptime,proto3" json:"uptime,omitempty"`
	Keys   []string             `protobuf:"bytes,3,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

type NodeClient interface {
	Health(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*HealthResponse, error)
	Info(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (Node_InfoClient, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*NodeGetResponse, error)
	Set(ctx context.Context, in *NodeSetRequest, opts ...grpc.CallOption) (*SetResponse, error)
}

type NodeGetResponse struct {
	ClockedEntry *ClockedEntry `protobuf:"bytes,1,opt,name=clocked_entry,json=clockedEntry,proto3" json:"clocked_entry,omitempty"`
	// contains filtered or unexported fields
}

type NodeServer interface {
	Health(context.Context, *HealthRequest) (*HealthResponse, error)
	Info(*InfoRequest, Node_InfoServer) error
	Get(context.Context, *GetRequest) (*NodeGetResponse, error)
	Set(context.Context, *NodeSetRequest) (*SetResponse, error)
	// contains filtered or unexported methods
}

type NodeSetRequest struct {
	ClockedEntry *ClockedEntry `protobuf:"bytes,1,opt,name=clocked_entry,json=clockedEntry,proto3" json:"clocked_entry,omitempty"`
	// contains filtered or unexported fields
}

type Node_InfoClient interface {
	Recv() (*InfoResponse, error)
	grpc.ClientStream
}

type Node_InfoServer interface {
	Send(*InfoResponse) error
	grpc.ServerStream
}

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

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

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

type UnimplementedClockServer struct {
}

type UnimplementedClusterServer struct {
}

type UnimplementedNodeServer struct {
}

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

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

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