v1

package
v0.0.0-...-3017044 Latest Latest
Warning

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

 Go to latest Published: Mar 11, 2025 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	KVStoreWriteService_Put_FullMethodName                   = "/kvalchemy.replicator.v1.KVStoreWriteService/Put"
	KVStoreWriteService_PutStream_FullMethodName             = "/kvalchemy.replicator.v1.KVStoreWriteService/PutStream"
	KVStoreWriteService_PutStreamChunksForKey_FullMethodName = "/kvalchemy.replicator.v1.KVStoreWriteService/PutStreamChunksForKey"
	KVStoreWriteService_Delete_FullMethodName                = "/kvalchemy.replicator.v1.KVStoreWriteService/Delete"
	KVStoreWriteService_DeleteStream_FullMethodName          = "/kvalchemy.replicator.v1.KVStoreWriteService/DeleteStream"
)
View Source 
const (
	KVStoreReadService_Get_FullMethodName = "/kvalchemy.replicator.v1.KVStoreReadService/Get"
)
View Source 
const (
	WALReplicationService_StreamWAL_FullMethodName = "/kvalchemy.replicator.v1.WALReplicationService/StreamWAL"
)

Variables

View Source 
var File_kvalchemy_replicator_v1_service_proto protoreflect.FileDescriptor
View Source 
var KVStoreReadService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "kvalchemy.replicator.v1.KVStoreReadService",
	HandlerType: (*KVStoreReadServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Get",
			Handler:       _KVStoreReadService_Get_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "kvalchemy/replicator/v1/service.proto",
}

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

View Source 
var KVStoreWriteService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "kvalchemy.replicator.v1.KVStoreWriteService",
	HandlerType: (*KVStoreWriteServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Put",
			Handler:    _KVStoreWriteService_Put_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _KVStoreWriteService_Delete_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "PutStream",
			Handler:       _KVStoreWriteService_PutStream_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "PutStreamChunksForKey",
			Handler:       _KVStoreWriteService_PutStreamChunksForKey_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "DeleteStream",
			Handler:       _KVStoreWriteService_DeleteStream_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "kvalchemy/replicator/v1/service.proto",
}

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

View Source 
var WALReplicationService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "kvalchemy.replicator.v1.WALReplicationService",
	HandlerType: (*WALReplicationServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamWAL",
			Handler:       _WALReplicationService_StreamWAL_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "kvalchemy/replicator/v1/service.proto",
}

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

Functions

func RegisterKVStoreReadServiceServer 

func RegisterKVStoreReadServiceServer(s grpc.ServiceRegistrar, srv KVStoreReadServiceServer)

func RegisterKVStoreWriteServiceServer 

func RegisterKVStoreWriteServiceServer(s grpc.ServiceRegistrar, srv KVStoreWriteServiceServer)

func RegisterWALReplicationServiceServer 

func RegisterWALReplicationServiceServer(s grpc.ServiceRegistrar, srv WALReplicationServiceServer)

Types

type ChunkCommitMarker 

type ChunkCommitMarker struct {
	FinalCrc32Checksum uint32 `protobuf:"fixed32,1,opt,name=final_crc32_checksum,json=finalCrc32Checksum,proto3" json:"final_crc32_checksum,omitempty"`
	// contains filtered or unexported fields
}

func (*ChunkCommitMarker) Descriptor deprecated 

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

Deprecated: Use ChunkCommitMarker.ProtoReflect.Descriptor instead.

func (*ChunkCommitMarker) GetFinalCrc32Checksum 

func (x *ChunkCommitMarker) GetFinalCrc32Checksum() uint32

func (*ChunkCommitMarker) ProtoMessage 

func (*ChunkCommitMarker) ProtoMessage()

func (*ChunkCommitMarker) ProtoReflect 

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

func (*ChunkCommitMarker) Reset 

func (x *ChunkCommitMarker) Reset()

func (*ChunkCommitMarker) String 

func (x *ChunkCommitMarker) String() string

type ChunkPutValue 

type ChunkPutValue struct {
	Value         []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Crc32Checksum uint32 `protobuf:"fixed32,2,opt,name=crc32_checksum,json=crc32Checksum,proto3" json:"crc32_checksum,omitempty"`
	// contains filtered or unexported fields
}

func (*ChunkPutValue) Descriptor deprecated 

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

Deprecated: Use ChunkPutValue.ProtoReflect.Descriptor instead.

func (*ChunkPutValue) GetCrc32Checksum 

func (x *ChunkPutValue) GetCrc32Checksum() uint32

func (*ChunkPutValue) GetValue 

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

func (*ChunkPutValue) ProtoMessage 

func (*ChunkPutValue) ProtoMessage()

func (*ChunkPutValue) ProtoReflect 

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

func (*ChunkPutValue) Reset 

func (x *ChunkPutValue) Reset()

func (*ChunkPutValue) String 

func (x *ChunkPutValue) String() string

type ChunkStartMarker 

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

func (*ChunkStartMarker) Descriptor deprecated 

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

Deprecated: Use ChunkStartMarker.ProtoReflect.Descriptor instead.

func (*ChunkStartMarker) GetKey 

func (x *ChunkStartMarker) GetKey() []byte

func (*ChunkStartMarker) ProtoMessage 

func (*ChunkStartMarker) ProtoMessage()

func (*ChunkStartMarker) ProtoReflect 

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

func (*ChunkStartMarker) Reset 

func (x *ChunkStartMarker) Reset()

func (*ChunkStartMarker) String 

func (x *ChunkStartMarker) String() string

type DeleteRequest 

type DeleteRequest struct {
	Key []byte `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() []byte

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 DeleteResponse 

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

func (*DeleteResponse) Descriptor deprecated 

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

Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) ProtoReflect 

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

func (*DeleteResponse) Reset 

func (x *DeleteResponse) Reset()

func (*DeleteResponse) String 

func (x *DeleteResponse) String() string

type DeleteStreamRequest 

type DeleteStreamRequest struct {
	Deletes []*DeleteRequest `protobuf:"bytes,1,rep,name=deletes,proto3" json:"deletes,omitempty"` // List of keys to delete
	// contains filtered or unexported fields
}

func (*DeleteStreamRequest) Descriptor deprecated 

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

Deprecated: Use DeleteStreamRequest.ProtoReflect.Descriptor instead.

func (*DeleteStreamRequest) GetDeletes 

func (x *DeleteStreamRequest) GetDeletes() []*DeleteRequest

func (*DeleteStreamRequest) ProtoMessage 

func (*DeleteStreamRequest) ProtoMessage()

func (*DeleteStreamRequest) ProtoReflect 

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

func (*DeleteStreamRequest) Reset 

func (x *DeleteStreamRequest) Reset()

func (*DeleteStreamRequest) String 

func (x *DeleteStreamRequest) String() string

type DeleteStreamResponse 

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

func (*DeleteStreamResponse) Descriptor deprecated 

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

Deprecated: Use DeleteStreamResponse.ProtoReflect.Descriptor instead.

func (*DeleteStreamResponse) ProtoMessage 

func (*DeleteStreamResponse) ProtoMessage()

func (*DeleteStreamResponse) ProtoReflect 

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

func (*DeleteStreamResponse) Reset 

func (x *DeleteStreamResponse) Reset()

func (*DeleteStreamResponse) String 

func (x *DeleteStreamResponse) String() string

type GetRequest 

type GetRequest struct {
	Key []byte `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() []byte

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 {
	Data               []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Chunked            bool   `protobuf:"varint,2,opt,name=chunked,proto3" json:"chunked,omitempty"`
	FinalCrc32Checksum uint32 `protobuf:"fixed32,3,opt,name=final_crc32_checksum,json=finalCrc32Checksum,proto3" json:"final_crc32_checksum,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResponse) Descriptor deprecated 

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetChunked 

func (x *GetResponse) GetChunked() bool

func (*GetResponse) GetData 

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

func (*GetResponse) GetFinalCrc32Checksum 

func (x *GetResponse) GetFinalCrc32Checksum() uint32

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 KVStoreReadServiceClient 

type KVStoreReadServiceClient interface {
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[GetResponse], error)
}

KVStoreReadServiceClient is the client API for KVStoreReadService 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 NewKVStoreReadServiceClient 

func NewKVStoreReadServiceClient(cc grpc.ClientConnInterface) KVStoreReadServiceClient

type KVStoreReadServiceServer 

type KVStoreReadServiceServer interface {
	Get(*GetRequest, grpc.ServerStreamingServer[GetResponse]) error
	// contains filtered or unexported methods
}

KVStoreReadServiceServer is the server API for KVStoreReadService service. All implementations must embed UnimplementedKVStoreReadServiceServer for forward compatibility.

type KVStoreReadService_GetClient 

type KVStoreReadService_GetClient = grpc.ServerStreamingClient[GetResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type KVStoreReadService_GetServer 

type KVStoreReadService_GetServer = grpc.ServerStreamingServer[GetResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type KVStoreWriteServiceClient 

type KVStoreWriteServiceClient interface {
	Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error)
	PutStream(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[PutStreamRequest, PutStreamResponse], error)
	// PutStreamChunksForKey: starts a stream can be used to put a large value associated
	// with the key.
	// value needs to be chunked into smaller size for efficient transmission and storage over grpc.
	// STEPS:
	// 1. Send the Chunk Start Marker.
	// 2. Stream the Chunk Values.
	// 3. Send the Chunk Commit Marker.
	// It's important to send Chunk Commit Marker else the chunked value will not be visible to reader.
	PutStreamChunksForKey(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[PutStreamChunksForKeyRequest, PutStreamChunksForKeyResponse], error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	DeleteStream(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[DeleteStreamRequest, DeleteStreamResponse], error)
}

KVStoreWriteServiceClient is the client API for KVStoreWriteService 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 NewKVStoreWriteServiceClient 

func NewKVStoreWriteServiceClient(cc grpc.ClientConnInterface) KVStoreWriteServiceClient

type KVStoreWriteServiceServer 

type KVStoreWriteServiceServer interface {
	Put(context.Context, *PutRequest) (*PutResponse, error)
	PutStream(grpc.ClientStreamingServer[PutStreamRequest, PutStreamResponse]) error
	// PutStreamChunksForKey: starts a stream can be used to put a large value associated
	// with the key.
	// value needs to be chunked into smaller size for efficient transmission and storage over grpc.
	// STEPS:
	// 1. Send the Chunk Start Marker.
	// 2. Stream the Chunk Values.
	// 3. Send the Chunk Commit Marker.
	// It's important to send Chunk Commit Marker else the chunked value will not be visible to reader.
	PutStreamChunksForKey(grpc.ClientStreamingServer[PutStreamChunksForKeyRequest, PutStreamChunksForKeyResponse]) error
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	DeleteStream(grpc.ClientStreamingServer[DeleteStreamRequest, DeleteStreamResponse]) error
	// contains filtered or unexported methods
}

KVStoreWriteServiceServer is the server API for KVStoreWriteService service. All implementations must embed UnimplementedKVStoreWriteServiceServer for forward compatibility.

type KVStoreWriteService_DeleteStreamClient 

type KVStoreWriteService_DeleteStreamClient = grpc.ClientStreamingClient[DeleteStreamRequest, DeleteStreamResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type KVStoreWriteService_DeleteStreamServer 

type KVStoreWriteService_DeleteStreamServer = grpc.ClientStreamingServer[DeleteStreamRequest, DeleteStreamResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type KVStoreWriteService_PutStreamChunksForKeyClient 

type KVStoreWriteService_PutStreamChunksForKeyClient = grpc.ClientStreamingClient[PutStreamChunksForKeyRequest, PutStreamChunksForKeyResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type KVStoreWriteService_PutStreamChunksForKeyServer 

type KVStoreWriteService_PutStreamChunksForKeyServer = grpc.ClientStreamingServer[PutStreamChunksForKeyRequest, PutStreamChunksForKeyResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type KVStoreWriteService_PutStreamClient 

type KVStoreWriteService_PutStreamClient = grpc.ClientStreamingClient[PutStreamRequest, PutStreamResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type KVStoreWriteService_PutStreamServer 

type KVStoreWriteService_PutStreamServer = grpc.ClientStreamingServer[PutStreamRequest, PutStreamResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type PutRequest 

type PutRequest 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"`
	Timestamp     *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Crc32Checksum uint32                 `protobuf:"fixed32,3,opt,name=crc32_checksum,json=crc32Checksum,proto3" json:"crc32_checksum,omitempty"`
	// contains filtered or unexported fields
}

func (*PutRequest) Descriptor deprecated 

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

Deprecated: Use PutRequest.ProtoReflect.Descriptor instead.

func (*PutRequest) GetCrc32Checksum 

func (x *PutRequest) GetCrc32Checksum() uint32

func (*PutRequest) GetKey 

func (x *PutRequest) GetKey() []byte

func (*PutRequest) GetTimestamp 

func (x *PutRequest) GetTimestamp() *timestamppb.Timestamp

func (*PutRequest) GetValue 

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

func (*PutRequest) ProtoMessage 

func (*PutRequest) ProtoMessage()

func (*PutRequest) ProtoReflect 

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

func (*PutRequest) Reset 

func (x *PutRequest) Reset()

func (*PutRequest) String 

func (x *PutRequest) String() string

type PutResponse 

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

func (*PutResponse) Descriptor deprecated 

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

Deprecated: Use PutResponse.ProtoReflect.Descriptor instead.

func (*PutResponse) ProtoMessage 

func (*PutResponse) ProtoMessage()

func (*PutResponse) ProtoReflect 

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

func (*PutResponse) Reset 

func (x *PutResponse) Reset()

func (*PutResponse) String 

func (x *PutResponse) String() string

type PutStreamChunksForKeyRequest 

type PutStreamChunksForKeyRequest struct {

	// Types that are valid to be assigned to RequestType:
	//
	//	*PutStreamChunksForKeyRequest_StartMarker
	//	*PutStreamChunksForKeyRequest_CommitMarker
	//	*PutStreamChunksForKeyRequest_Chunk
	RequestType isPutStreamChunksForKeyRequest_RequestType `protobuf_oneof:"request_type"`
	// contains filtered or unexported fields
}

func (*PutStreamChunksForKeyRequest) Descriptor deprecated 

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

Deprecated: Use PutStreamChunksForKeyRequest.ProtoReflect.Descriptor instead.

func (*PutStreamChunksForKeyRequest) GetChunk 

func (x *PutStreamChunksForKeyRequest) GetChunk() *ChunkPutValue

func (*PutStreamChunksForKeyRequest) GetCommitMarker 

func (x *PutStreamChunksForKeyRequest) GetCommitMarker() *ChunkCommitMarker

func (*PutStreamChunksForKeyRequest) GetRequestType 

func (x *PutStreamChunksForKeyRequest) GetRequestType() isPutStreamChunksForKeyRequest_RequestType

func (*PutStreamChunksForKeyRequest) GetStartMarker 

func (x *PutStreamChunksForKeyRequest) GetStartMarker() *ChunkStartMarker

func (*PutStreamChunksForKeyRequest) ProtoMessage 

func (*PutStreamChunksForKeyRequest) ProtoMessage()

func (*PutStreamChunksForKeyRequest) ProtoReflect 

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

func (*PutStreamChunksForKeyRequest) Reset 

func (x *PutStreamChunksForKeyRequest) Reset()

func (*PutStreamChunksForKeyRequest) String 

func (x *PutStreamChunksForKeyRequest) String() string

type PutStreamChunksForKeyRequest_Chunk 

type PutStreamChunksForKeyRequest_Chunk struct {
	Chunk *ChunkPutValue `protobuf:"bytes,3,opt,name=chunk,proto3,oneof"`
}

type PutStreamChunksForKeyRequest_CommitMarker 

type PutStreamChunksForKeyRequest_CommitMarker struct {
	CommitMarker *ChunkCommitMarker `protobuf:"bytes,2,opt,name=commit_marker,json=commitMarker,proto3,oneof"`
}

type PutStreamChunksForKeyRequest_StartMarker 

type PutStreamChunksForKeyRequest_StartMarker struct {
	StartMarker *ChunkStartMarker `protobuf:"bytes,1,opt,name=start_marker,json=startMarker,proto3,oneof"`
}

type PutStreamChunksForKeyResponse 

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

func (*PutStreamChunksForKeyResponse) Descriptor deprecated 

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

Deprecated: Use PutStreamChunksForKeyResponse.ProtoReflect.Descriptor instead.

func (*PutStreamChunksForKeyResponse) ProtoMessage 

func (*PutStreamChunksForKeyResponse) ProtoMessage()

func (*PutStreamChunksForKeyResponse) ProtoReflect 

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

func (*PutStreamChunksForKeyResponse) Reset 

func (x *PutStreamChunksForKeyResponse) Reset()

func (*PutStreamChunksForKeyResponse) String 

func (x *PutStreamChunksForKeyResponse) String() string

type PutStreamRequest 

type PutStreamRequest struct {
	KvPairs []*PutRequest `protobuf:"bytes,1,rep,name=kv_pairs,json=kvPairs,proto3" json:"kv_pairs,omitempty"`
	// contains filtered or unexported fields
}

func (*PutStreamRequest) Descriptor deprecated 

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

Deprecated: Use PutStreamRequest.ProtoReflect.Descriptor instead.

func (*PutStreamRequest) GetKvPairs 

func (x *PutStreamRequest) GetKvPairs() []*PutRequest

func (*PutStreamRequest) ProtoMessage 

func (*PutStreamRequest) ProtoMessage()

func (*PutStreamRequest) ProtoReflect 

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

func (*PutStreamRequest) Reset 

func (x *PutStreamRequest) Reset()

func (*PutStreamRequest) String 

func (x *PutStreamRequest) String() string

type PutStreamResponse 

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

func (*PutStreamResponse) Descriptor deprecated 

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

Deprecated: Use PutStreamResponse.ProtoReflect.Descriptor instead.

func (*PutStreamResponse) ProtoMessage 

func (*PutStreamResponse) ProtoMessage()

func (*PutStreamResponse) ProtoReflect 

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

func (*PutStreamResponse) Reset 

func (x *PutStreamResponse) Reset()

func (*PutStreamResponse) String 

func (x *PutStreamResponse) String() string

type StreamWALRequest 

type StreamWALRequest struct {
	Offset []byte `protobuf:"bytes,1,opt,name=offset,proto3,oneof" json:"offset,omitempty"` // Last applied WAL checkpoint offset.
	// contains filtered or unexported fields
}

func (*StreamWALRequest) Descriptor deprecated 

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

Deprecated: Use StreamWALRequest.ProtoReflect.Descriptor instead.

func (*StreamWALRequest) GetOffset 

func (x *StreamWALRequest) GetOffset() []byte

func (*StreamWALRequest) ProtoMessage 

func (*StreamWALRequest) ProtoMessage()

func (*StreamWALRequest) ProtoReflect 

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

func (*StreamWALRequest) Reset 

func (x *StreamWALRequest) Reset()

func (*StreamWALRequest) String 

func (x *StreamWALRequest) String() string

type StreamWALResponse 

type StreamWALResponse struct {
	WalRecords []*WALRecord           `protobuf:"bytes,1,rep,name=wal_records,json=walRecords,proto3" json:"wal_records,omitempty"` // A batch of WAL records
	SentAt     *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=sent_at,json=sentAt,proto3" json:"sent_at,omitempty"`             // Server timestamp when the batch was sent
	// contains filtered or unexported fields
}

Server's Response Message (Streaming)

func (*StreamWALResponse) Descriptor deprecated 

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

Deprecated: Use StreamWALResponse.ProtoReflect.Descriptor instead.

func (*StreamWALResponse) GetSentAt 

func (x *StreamWALResponse) GetSentAt() *timestamppb.Timestamp

func (*StreamWALResponse) GetWalRecords 

func (x *StreamWALResponse) GetWalRecords() []*WALRecord

func (*StreamWALResponse) ProtoMessage 

func (*StreamWALResponse) ProtoMessage()

func (*StreamWALResponse) ProtoReflect 

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

func (*StreamWALResponse) Reset 

func (x *StreamWALResponse) Reset()

func (*StreamWALResponse) String 

func (x *StreamWALResponse) String() string

type UnimplementedKVStoreReadServiceServer 

type UnimplementedKVStoreReadServiceServer struct{}

UnimplementedKVStoreReadServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedKVStoreReadServiceServer) Get 

func (UnimplementedKVStoreReadServiceServer) Get(*GetRequest, grpc.ServerStreamingServer[GetResponse]) error

type UnimplementedKVStoreWriteServiceServer 

type UnimplementedKVStoreWriteServiceServer struct{}

UnimplementedKVStoreWriteServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedKVStoreWriteServiceServer) Delete 

func (UnimplementedKVStoreWriteServiceServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)

func (UnimplementedKVStoreWriteServiceServer) DeleteStream 

func (UnimplementedKVStoreWriteServiceServer) DeleteStream(grpc.ClientStreamingServer[DeleteStreamRequest, DeleteStreamResponse]) error

func (UnimplementedKVStoreWriteServiceServer) Put 

func (UnimplementedKVStoreWriteServiceServer) Put(context.Context, *PutRequest) (*PutResponse, error)

func (UnimplementedKVStoreWriteServiceServer) PutStream 

func (UnimplementedKVStoreWriteServiceServer) PutStream(grpc.ClientStreamingServer[PutStreamRequest, PutStreamResponse]) error

func (UnimplementedKVStoreWriteServiceServer) PutStreamChunksForKey 

func (UnimplementedKVStoreWriteServiceServer) PutStreamChunksForKey(grpc.ClientStreamingServer[PutStreamChunksForKeyRequest, PutStreamChunksForKeyResponse]) error

type UnimplementedWALReplicationServiceServer 

type UnimplementedWALReplicationServiceServer struct{}

UnimplementedWALReplicationServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedWALReplicationServiceServer) StreamWAL 

func (UnimplementedWALReplicationServiceServer) StreamWAL(*StreamWALRequest, grpc.ServerStreamingServer[StreamWALResponse]) error

type UnsafeKVStoreReadServiceServer 

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

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

type UnsafeKVStoreWriteServiceServer 

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

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

type UnsafeWALReplicationServiceServer 

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

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

type WALRecord 

type WALRecord struct {
	Offset        []byte `protobuf:"bytes,1,opt,name=offset,proto3" json:"offset,omitempty"`
	Record        []byte `protobuf:"bytes,2,opt,name=record,proto3" json:"record,omitempty"`
	Crc32Checksum uint32 `protobuf:"fixed32,3,opt,name=crc32_checksum,json=crc32Checksum,proto3" json:"crc32_checksum,omitempty"`
	// contains filtered or unexported fields
}

WAL Record Format

func (*WALRecord) Descriptor deprecated 

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

Deprecated: Use WALRecord.ProtoReflect.Descriptor instead.

func (*WALRecord) GetCrc32Checksum 

func (x *WALRecord) GetCrc32Checksum() uint32

func (*WALRecord) GetOffset 

func (x *WALRecord) GetOffset() []byte

func (*WALRecord) GetRecord 

func (x *WALRecord) GetRecord() []byte

func (*WALRecord) ProtoMessage 

func (*WALRecord) ProtoMessage()

func (*WALRecord) ProtoReflect 

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

func (*WALRecord) Reset 

func (x *WALRecord) Reset()

func (*WALRecord) String 

func (x *WALRecord) String() string

type WALReplicationServiceClient 

type WALReplicationServiceClient interface {
	// / Stream WAL Logs
	StreamWAL(ctx context.Context, in *StreamWALRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[StreamWALResponse], error)
}

WALReplicationServiceClient is the client API for WALReplicationService 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 NewWALReplicationServiceClient 

func NewWALReplicationServiceClient(cc grpc.ClientConnInterface) WALReplicationServiceClient

type WALReplicationServiceServer 

type WALReplicationServiceServer interface {
	// / Stream WAL Logs
	StreamWAL(*StreamWALRequest, grpc.ServerStreamingServer[StreamWALResponse]) error
	// contains filtered or unexported methods
}

WALReplicationServiceServer is the server API for WALReplicationService service. All implementations must embed UnimplementedWALReplicationServiceServer for forward compatibility.

type WALReplicationService_StreamWALClient 

type WALReplicationService_StreamWALClient = grpc.ServerStreamingClient[StreamWALResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type WALReplicationService_StreamWALServer 

type WALReplicationService_StreamWALServer = grpc.ServerStreamingServer[StreamWALResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

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.