pb

package
v0.0.0-...-81f4bad Latest Latest
Warning

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

 Go to latest Published: May 17, 2024 License: ISC Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Operation_name = map[int32]string{
		0: "OPERATION_UNSPECIFIED",
		1: "OPERATION_INSERT",
		2: "OPERATION_DELETE",
	}
	Operation_value = map[string]int32{
		"OPERATION_UNSPECIFIED": 0,
		"OPERATION_INSERT":      1,
		"OPERATION_DELETE":      2,
	}
)

Enum value maps for Operation.

View Source 
var (
	ManifestEntry_Op_name = map[int32]string{
		0: "OP_UNSPECIFIED",
		1: "OP_ADDTABLE",
		2: "OP_REMOVETABLE",
		3: "OP_CLEARTABLE",
	}
	ManifestEntry_Op_value = map[string]int32{
		"OP_UNSPECIFIED": 0,
		"OP_ADDTABLE":    1,
		"OP_REMOVETABLE": 2,
		"OP_CLEARTABLE":  3,
	}
)

Enum value maps for ManifestEntry_Op.

View Source 
var File_gostore_proto protoreflect.FileDescriptor
View Source 
var File_sstable_proto protoreflect.FileDescriptor
View Source 
var GoStore_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gostore.proto.GoStore",
	HandlerType: (*GoStoreServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Write",
			Handler:    _GoStore_Write_Handler,
		},
		{
			MethodName: "Read",
			Handler:    _GoStore_Read_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _GoStore_Update_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _GoStore_Delete_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "gostore.proto",
}

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

Functions

func RegisterGoStoreServer 

func RegisterGoStoreServer(s grpc.ServiceRegistrar, srv GoStoreServer)

Types

type GoStoreClient 

type GoStoreClient interface {
	Write(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteReply, error)
	Read(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadReply, error)
	Update(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteReply, error)
	Delete(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*WriteReply, error)
}

GoStoreClient is the client API for GoStore 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 NewGoStoreClient 

func NewGoStoreClient(cc grpc.ClientConnInterface) GoStoreClient

type GoStoreServer 

type GoStoreServer interface {
	Write(context.Context, *WriteRequest) (*WriteReply, error)
	Read(context.Context, *ReadRequest) (*ReadReply, error)
	Update(context.Context, *WriteRequest) (*WriteReply, error)
	Delete(context.Context, *ReadRequest) (*WriteReply, error)
	// contains filtered or unexported methods
}

GoStoreServer is the server API for GoStore service. All implementations must embed UnimplementedGoStoreServer for forward compatibility

type ManifestEntry 

type ManifestEntry struct {
	Op    ManifestEntry_Op `protobuf:"varint,1,opt,name=op,proto3,enum=gostore.proto.ManifestEntry_Op" json:"op,omitempty"`
	Level int32            `protobuf:"varint,2,opt,name=level,proto3" json:"level,omitempty"`
	Table *SSTable         `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"`
	// contains filtered or unexported fields
}

func (*ManifestEntry) Descriptor deprecated 

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

Deprecated: Use ManifestEntry.ProtoReflect.Descriptor instead.

func (*ManifestEntry) GetLevel 

func (x *ManifestEntry) GetLevel() int32

func (*ManifestEntry) GetOp 

func (x *ManifestEntry) GetOp() ManifestEntry_Op

func (*ManifestEntry) GetTable 

func (x *ManifestEntry) GetTable() *SSTable

func (*ManifestEntry) ProtoMessage 

func (*ManifestEntry) ProtoMessage()

func (*ManifestEntry) ProtoReflect 

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

func (*ManifestEntry) Reset 

func (x *ManifestEntry) Reset()

func (*ManifestEntry) String 

func (x *ManifestEntry) String() string

type ManifestEntry_Op 

type ManifestEntry_Op int32
const (
	ManifestEntry_OP_UNSPECIFIED ManifestEntry_Op = 0
	ManifestEntry_OP_ADDTABLE    ManifestEntry_Op = 1
	ManifestEntry_OP_REMOVETABLE ManifestEntry_Op = 2
	ManifestEntry_OP_CLEARTABLE  ManifestEntry_Op = 3
)

func (ManifestEntry_Op) Descriptor 

func (ManifestEntry_Op) Descriptor() protoreflect.EnumDescriptor

func (ManifestEntry_Op) Enum 

func (x ManifestEntry_Op) Enum() *ManifestEntry_Op

func (ManifestEntry_Op) EnumDescriptor deprecated 

func (ManifestEntry_Op) EnumDescriptor() ([]byte, []int)

Deprecated: Use ManifestEntry_Op.Descriptor instead.

func (ManifestEntry_Op) Number 

func (x ManifestEntry_Op) Number() protoreflect.EnumNumber

func (ManifestEntry_Op) String 

func (x ManifestEntry_Op) String() string

func (ManifestEntry_Op) Type 

func (ManifestEntry_Op) Type() protoreflect.EnumType

type Operation 

type Operation int32
const (
	Operation_OPERATION_UNSPECIFIED Operation = 0
	Operation_OPERATION_INSERT      Operation = 1
	Operation_OPERATION_DELETE      Operation = 2
)

func (Operation) Descriptor 

func (Operation) Descriptor() protoreflect.EnumDescriptor

func (Operation) Enum 

func (x Operation) Enum() *Operation

func (Operation) EnumDescriptor deprecated 

func (Operation) EnumDescriptor() ([]byte, []int)

Deprecated: Use Operation.Descriptor instead.

func (Operation) Number 

func (x Operation) Number() protoreflect.EnumNumber

func (Operation) String 

func (x Operation) String() string

func (Operation) Type 

func (Operation) Type() protoreflect.EnumType

type ReadReply 

type ReadReply struct {
	Status  int32  `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Data    []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadReply) Descriptor deprecated 

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

Deprecated: Use ReadReply.ProtoReflect.Descriptor instead.

func (*ReadReply) GetData 

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

func (*ReadReply) GetMessage 

func (x *ReadReply) GetMessage() string

func (*ReadReply) GetStatus 

func (x *ReadReply) GetStatus() int32

func (*ReadReply) ProtoMessage 

func (*ReadReply) ProtoMessage()

func (*ReadReply) ProtoReflect 

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

func (*ReadReply) Reset 

func (x *ReadReply) Reset()

func (*ReadReply) String 

func (x *ReadReply) String() string

type ReadRequest 

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

func (*ReadRequest) Descriptor deprecated 

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

Deprecated: Use ReadRequest.ProtoReflect.Descriptor instead.

func (*ReadRequest) GetKey 

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

func (*ReadRequest) ProtoMessage 

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) ProtoReflect 

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

func (*ReadRequest) Reset 

func (x *ReadRequest) Reset()

func (*ReadRequest) String 

func (x *ReadRequest) String() string

type SSTable 

type SSTable struct {
	Entries   []*SSTable_Entry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	Name      *string          `protobuf:"bytes,2,opt,name=name,proto3,oneof" json:"name,omitempty"`
	Filter    *SSTable_Filter  `protobuf:"bytes,3,opt,name=filter,proto3,oneof" json:"filter,omitempty"`
	First     []byte           `protobuf:"bytes,4,opt,name=first,proto3,oneof" json:"first,omitempty"`
	Last      []byte           `protobuf:"bytes,5,opt,name=last,proto3,oneof" json:"last,omitempty"`
	CreatedOn []byte           `protobuf:"bytes,6,opt,name=created_on,json=createdOn,proto3,oneof" json:"created_on,omitempty"`
	Size      *int64           `protobuf:"varint,7,opt,name=size,proto3,oneof" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*SSTable) Descriptor deprecated 

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

Deprecated: Use SSTable.ProtoReflect.Descriptor instead.

func (*SSTable) GetCreatedOn 

func (x *SSTable) GetCreatedOn() []byte

func (*SSTable) GetEntries 

func (x *SSTable) GetEntries() []*SSTable_Entry

func (*SSTable) GetFilter 

func (x *SSTable) GetFilter() *SSTable_Filter

func (*SSTable) GetFirst 

func (x *SSTable) GetFirst() []byte

func (*SSTable) GetLast 

func (x *SSTable) GetLast() []byte

func (*SSTable) GetName 

func (x *SSTable) GetName() string

func (*SSTable) GetSize 

func (x *SSTable) GetSize() int64

func (*SSTable) ProtoMessage 

func (*SSTable) ProtoMessage()

func (*SSTable) ProtoReflect 

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

func (*SSTable) Reset 

func (x *SSTable) Reset()

func (*SSTable) String 

func (x *SSTable) String() string

type SSTable_Entry 

type SSTable_Entry 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"`
	Op    Operation `protobuf:"varint,3,opt,name=op,proto3,enum=gostore.proto.Operation" json:"op,omitempty"`
	// contains filtered or unexported fields
}

func (*SSTable_Entry) Apply 

func (e *SSTable_Entry) Apply(c interface{}) error

func (*SSTable_Entry) Descriptor deprecated 

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

Deprecated: Use SSTable_Entry.ProtoReflect.Descriptor instead.

func (*SSTable_Entry) GetKey 

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

func (*SSTable_Entry) GetOp 

func (x *SSTable_Entry) GetOp() Operation

func (*SSTable_Entry) GetValue 

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

func (*SSTable_Entry) MarshalProto 

func (e *SSTable_Entry) MarshalProto() proto.Message

func (*SSTable_Entry) ProtoMessage 

func (*SSTable_Entry) ProtoMessage()

func (*SSTable_Entry) ProtoReflect 

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

func (*SSTable_Entry) Reset 

func (x *SSTable_Entry) Reset()

func (*SSTable_Entry) String 

func (x *SSTable_Entry) String() string

type SSTable_Filter 

type SSTable_Filter struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Size uint64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*SSTable_Filter) Descriptor deprecated 

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

Deprecated: Use SSTable_Filter.ProtoReflect.Descriptor instead.

func (*SSTable_Filter) GetName 

func (x *SSTable_Filter) GetName() string

func (*SSTable_Filter) GetSize 

func (x *SSTable_Filter) GetSize() uint64

func (*SSTable_Filter) ProtoMessage 

func (*SSTable_Filter) ProtoMessage()

func (*SSTable_Filter) ProtoReflect 

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

func (*SSTable_Filter) Reset 

func (x *SSTable_Filter) Reset()

func (*SSTable_Filter) String 

func (x *SSTable_Filter) String() string

type UnimplementedGoStoreServer 

type UnimplementedGoStoreServer struct {
}

UnimplementedGoStoreServer must be embedded to have forward compatible implementations.

func (UnimplementedGoStoreServer) Delete 

func (UnimplementedGoStoreServer) Delete(context.Context, *ReadRequest) (*WriteReply, error)

func (UnimplementedGoStoreServer) Read 

func (UnimplementedGoStoreServer) Read(context.Context, *ReadRequest) (*ReadReply, error)

func (UnimplementedGoStoreServer) Update 

func (UnimplementedGoStoreServer) Update(context.Context, *WriteRequest) (*WriteReply, error)

func (UnimplementedGoStoreServer) Write 

func (UnimplementedGoStoreServer) Write(context.Context, *WriteRequest) (*WriteReply, error)

type UnsafeGoStoreServer 

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

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

type WriteReply 

type WriteReply struct {
	Status  int32  `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteReply) Descriptor deprecated 

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

Deprecated: Use WriteReply.ProtoReflect.Descriptor instead.

func (*WriteReply) GetMessage 

func (x *WriteReply) GetMessage() string

func (*WriteReply) GetStatus 

func (x *WriteReply) GetStatus() int32

func (*WriteReply) ProtoMessage 

func (*WriteReply) ProtoMessage()

func (*WriteReply) ProtoReflect 

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

func (*WriteReply) Reset 

func (x *WriteReply) Reset()

func (*WriteReply) String 

func (x *WriteReply) String() string

type WriteRequest 

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

func (*WriteRequest) Descriptor deprecated 

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

Deprecated: Use WriteRequest.ProtoReflect.Descriptor instead.

func (*WriteRequest) GetKey 

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

func (*WriteRequest) GetPayload 

func (x *WriteRequest) GetPayload() []byte

func (*WriteRequest) ProtoMessage 

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) ProtoReflect 

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

func (*WriteRequest) Reset 

func (x *WriteRequest) Reset()

func (*WriteRequest) String 

func (x *WriteRequest) String() string

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.