persistence

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

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

type Key struct {

	// Types that are valid to be assigned to TypedKey:
	//
	//	*Key_PlayerKey
	//	*Key_TitleKey
	TypedKey isKey_TypedKey `protobuf_oneof:"typed_key"`
	// contains filtered or unexported fields
}

type Key_PlayerKey struct {
	PlayerKey *PlayerKey `protobuf:"bytes,1,opt,name=player_key,json=playerKey,proto3,oneof"`
}

type Key_TitleKey struct {
	TitleKey *TitleKey `protobuf:"bytes,2,opt,name=title_key,json=titleKey,proto3,oneof"` //TODO any other category of value to be stored
}

type PlayerKey struct {
	TitleId  string `protobuf:"bytes,1,opt,name=title_id,json=titleId,proto3" json:"title_id,omitempty"`
	PlayerId string `protobuf:"bytes,2,opt,name=player_id,json=playerId,proto3" json:"player_id,omitempty"`
	Datatype string `protobuf:"bytes,3,opt,name=datatype,proto3" json:"datatype,omitempty"`
	// contains filtered or unexported fields
}

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

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

type StorageServiceClient interface {
	// Get obtains the currently stored value for a given key
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	// Set writes the provided value for the given key - if used concurrently, the last write wins.
	Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*SetResponse, error)
	// Watch streams updates to a given key as they are made
	Watch(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[WatchResponse], error)
	// Update establishes a two-way connection with the server to:
	// - obtain the current value for a key, holding a lock on it and blocking any other "update" or "set" requests for the same key
	// - set a new value for the key, releasing the lock on that key and closing the connection
	Update(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[UpdateRequest, UpdateResponse], error)
}

type StorageServiceServer interface {
	// Get obtains the currently stored value for a given key
	Get(context.Context, *GetRequest) (*GetResponse, error)
	// Set writes the provided value for the given key - if used concurrently, the last write wins.
	Set(context.Context, *SetRequest) (*SetResponse, error)
	// Watch streams updates to a given key as they are made
	Watch(*WatchRequest, grpc.ServerStreamingServer[WatchResponse]) error
	// Update establishes a two-way connection with the server to:
	// - obtain the current value for a key, holding a lock on it and blocking any other "update" or "set" requests for the same key
	// - set a new value for the key, releasing the lock on that key and closing the connection
	Update(grpc.BidiStreamingServer[UpdateRequest, UpdateResponse]) error
	// contains filtered or unexported methods
}

type StorageService_UpdateClient = grpc.BidiStreamingClient[UpdateRequest, UpdateResponse]

type StorageService_UpdateServer = grpc.BidiStreamingServer[UpdateRequest, UpdateResponse]

type StorageService_WatchClient = grpc.ServerStreamingClient[WatchResponse]

type StorageService_WatchServer = grpc.ServerStreamingServer[WatchResponse]

type TitleKey struct {
	TitleId  string `protobuf:"bytes,1,opt,name=title_id,json=titleId,proto3" json:"title_id,omitempty"`
	Datatype string `protobuf:"bytes,2,opt,name=datatype,proto3" json:"datatype,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedStorageServiceServer struct{}

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

type UpdateRequest struct {

	// Types that are valid to be assigned to RequestType:
	//
	//	*UpdateRequest_Get
	//	*UpdateRequest_Set
	RequestType isUpdateRequest_RequestType `protobuf_oneof:"request_type"`
	// contains filtered or unexported fields
}

type UpdateRequest_Get struct {
	Get *GetRequest `protobuf:"bytes,1,opt,name=get,proto3,oneof"`
}

type UpdateRequest_Set struct {
	Set *SetRequest `protobuf:"bytes,2,opt,name=set,proto3,oneof"`
}

type UpdateResponse struct {

	// Types that are valid to be assigned to ResponseType:
	//
	//	*UpdateResponse_Get
	//	*UpdateResponse_Set
	ResponseType isUpdateResponse_ResponseType `protobuf_oneof:"response_type"`
	// contains filtered or unexported fields
}

type UpdateResponse_Get struct {
	Get *GetResponse `protobuf:"bytes,1,opt,name=get,proto3,oneof"`
}

type UpdateResponse_Set struct {
	Set *SetResponse `protobuf:"bytes,2,opt,name=set,proto3,oneof"`
}

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

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