store

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Nov 28, 2024 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	StoreV1_SetFile_FullMethodName    = "/store.StoreV1/SetFile"
	StoreV1_GetFile_FullMethodName    = "/store.StoreV1/GetFile"
	StoreV1_GetKeys_FullMethodName    = "/store.StoreV1/GetKeys"
	StoreV1_DeleteFile_FullMethodName = "/store.StoreV1/DeleteFile"
	StoreV1_BeginTx_FullMethodName    = "/store.StoreV1/BeginTx"
	StoreV1_CommitTx_FullMethodName   = "/store.StoreV1/CommitTx"
	StoreV1_RollbackTx_FullMethodName = "/store.StoreV1/RollbackTx"
)

Variables

View Source 
var (
	ErrorCode_name = map[int32]string{
		0:   "ErrUnknown",
		1:   "ErrNoFreeSpace",
		2:   "ErrNotFound",
		3:   "ErrEmptyKey",
		4:   "ErrHeaderNotFound",
		100: "ErrTxNotFound",
		101: "ErrTxAlreadyExists",
		102: "ErrTxSerialization",
	}
	ErrorCode_value = map[string]int32{
		"ErrUnknown":         0,
		"ErrNoFreeSpace":     1,
		"ErrNotFound":        2,
		"ErrEmptyKey":        3,
		"ErrHeaderNotFound":  4,
		"ErrTxNotFound":      100,
		"ErrTxAlreadyExists": 101,
		"ErrTxSerialization": 102,
	}
)

Enum value maps for ErrorCode.

View Source 
var (
	ChunkSize_name = map[int32]string{
		0:    "EMPTY",
		2048: "MAX",
	}
	ChunkSize_value = map[string]int32{
		"EMPTY": 0,
		"MAX":   2048,
	}
)

Enum value maps for ChunkSize.

View Source 
var (
	TxIsoLevel_name = map[int32]string{
		0: "ISO_LEVEL_READ_UNCOMMITTED",
		1: "ISO_LEVEL_READ_COMMITTED",
		2: "ISO_LEVEL_REPEATABLE_READ",
		3: "ISO_LEVEL_SERIALIZABLE",
	}
	TxIsoLevel_value = map[string]int32{
		"ISO_LEVEL_READ_UNCOMMITTED": 0,
		"ISO_LEVEL_READ_COMMITTED":   1,
		"ISO_LEVEL_REPEATABLE_READ":  2,
		"ISO_LEVEL_SERIALIZABLE":     3,
	}
)

Enum value maps for TxIsoLevel.

View Source 
var File_error_proto protoreflect.FileDescriptor
View Source 
var File_store_service_proto protoreflect.FileDescriptor
View Source 
var StoreV1_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "store.StoreV1",
	HandlerType: (*StoreV1Server)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetKeys",
			Handler:    _StoreV1_GetKeys_Handler,
		},
		{
			MethodName: "DeleteFile",
			Handler:    _StoreV1_DeleteFile_Handler,
		},
		{
			MethodName: "BeginTx",
			Handler:    _StoreV1_BeginTx_Handler,
		},
		{
			MethodName: "CommitTx",
			Handler:    _StoreV1_CommitTx_Handler,
		},
		{
			MethodName: "RollbackTx",
			Handler:    _StoreV1_RollbackTx_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SetFile",
			Handler:       _StoreV1_SetFile_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "GetFile",
			Handler:       _StoreV1_GetFile_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "store_service.proto",
}

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

Functions

func RegisterStoreV1Server 

func RegisterStoreV1Server(s grpc.ServiceRegistrar, srv StoreV1Server)

Types

type BeginTxRequest added in v1.0.0 

type BeginTxRequest struct {
	IsoLevel TxIsoLevel `protobuf:"varint,1,opt,name=isoLevel,proto3,enum=store.TxIsoLevel" json:"isoLevel,omitempty"`
	// contains filtered or unexported fields
}

func (*BeginTxRequest) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use BeginTxRequest.ProtoReflect.Descriptor instead.

func (*BeginTxRequest) GetIsoLevel added in v1.0.0 

func (x *BeginTxRequest) GetIsoLevel() TxIsoLevel

func (*BeginTxRequest) ProtoMessage added in v1.0.0 

func (*BeginTxRequest) ProtoMessage()

func (*BeginTxRequest) ProtoReflect added in v1.0.0 

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

func (*BeginTxRequest) Reset added in v1.0.0 

func (x *BeginTxRequest) Reset()

func (*BeginTxRequest) String added in v1.0.0 

func (x *BeginTxRequest) String() string

type BeginTxResponse added in v1.0.0 

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

func (*BeginTxResponse) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use BeginTxResponse.ProtoReflect.Descriptor instead.

func (*BeginTxResponse) GetId added in v1.0.0 

func (x *BeginTxResponse) GetId() string

func (*BeginTxResponse) ProtoMessage added in v1.0.0 

func (*BeginTxResponse) ProtoMessage()

func (*BeginTxResponse) ProtoReflect added in v1.0.0 

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

func (*BeginTxResponse) Reset added in v1.0.0 

func (x *BeginTxResponse) Reset()

func (*BeginTxResponse) String added in v1.0.0 

func (x *BeginTxResponse) String() string

type ChunkSize 

type ChunkSize int32
const (
	ChunkSize_EMPTY ChunkSize = 0
	ChunkSize_MAX   ChunkSize = 2048
)

func (ChunkSize) Descriptor 

func (ChunkSize) Descriptor() protoreflect.EnumDescriptor

func (ChunkSize) Enum 

func (x ChunkSize) Enum() *ChunkSize

func (ChunkSize) EnumDescriptor deprecated 

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

Deprecated: Use ChunkSize.Descriptor instead.

func (ChunkSize) Number 

func (x ChunkSize) Number() protoreflect.EnumNumber

func (ChunkSize) String 

func (x ChunkSize) String() string

func (ChunkSize) Type 

func (ChunkSize) Type() protoreflect.EnumType

type CommitTxRequest added in v1.0.0 

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

func (*CommitTxRequest) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use CommitTxRequest.ProtoReflect.Descriptor instead.

func (*CommitTxRequest) ProtoMessage added in v1.0.0 

func (*CommitTxRequest) ProtoMessage()

func (*CommitTxRequest) ProtoReflect added in v1.0.0 

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

func (*CommitTxRequest) Reset added in v1.0.0 

func (x *CommitTxRequest) Reset()

func (*CommitTxRequest) String added in v1.0.0 

func (x *CommitTxRequest) String() string

type CommitTxResponse added in v1.0.0 

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

func (*CommitTxResponse) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use CommitTxResponse.ProtoReflect.Descriptor instead.

func (*CommitTxResponse) ProtoMessage added in v1.0.0 

func (*CommitTxResponse) ProtoMessage()

func (*CommitTxResponse) ProtoReflect added in v1.0.0 

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

func (*CommitTxResponse) Reset added in v1.0.0 

func (x *CommitTxResponse) Reset()

func (*CommitTxResponse) String added in v1.0.0 

func (x *CommitTxResponse) String() string

type DeleteFileRequest 

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

func (*DeleteFileRequest) Descriptor deprecated 

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

Deprecated: Use DeleteFileRequest.ProtoReflect.Descriptor instead.

func (*DeleteFileRequest) GetKey 

func (x *DeleteFileRequest) GetKey() string

func (*DeleteFileRequest) ProtoMessage 

func (*DeleteFileRequest) ProtoMessage()

func (*DeleteFileRequest) ProtoReflect 

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

func (*DeleteFileRequest) Reset 

func (x *DeleteFileRequest) Reset()

func (*DeleteFileRequest) String 

func (x *DeleteFileRequest) String() string

type DeleteFileResponse 

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

func (*DeleteFileResponse) Descriptor deprecated 

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

Deprecated: Use DeleteFileResponse.ProtoReflect.Descriptor instead.

func (*DeleteFileResponse) ProtoMessage 

func (*DeleteFileResponse) ProtoMessage()

func (*DeleteFileResponse) ProtoReflect 

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

func (*DeleteFileResponse) Reset 

func (x *DeleteFileResponse) Reset()

func (*DeleteFileResponse) String 

func (x *DeleteFileResponse) String() string

type Error added in v1.1.0 

type Error struct {
	Code    ErrorCode `protobuf:"varint,1,opt,name=code,proto3,enum=store.ErrorCode" json:"code,omitempty"`
	Message *string   `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Error) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetCode added in v1.1.0 

func (x *Error) GetCode() ErrorCode

func (*Error) GetMessage added in v1.1.0 

func (x *Error) GetMessage() string

func (*Error) ProtoMessage added in v1.1.0 

func (*Error) ProtoMessage()

func (*Error) ProtoReflect added in v1.1.0 

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

func (*Error) Reset added in v1.1.0 

func (x *Error) Reset()

func (*Error) String added in v1.1.0 

func (x *Error) String() string

type ErrorCode added in v1.1.0 

type ErrorCode int32
const (
	ErrorCode_ErrUnknown ErrorCode = 0
	// Main errors
	ErrorCode_ErrNoFreeSpace    ErrorCode = 1
	ErrorCode_ErrNotFound       ErrorCode = 2
	ErrorCode_ErrEmptyKey       ErrorCode = 3
	ErrorCode_ErrHeaderNotFound ErrorCode = 4
	// Tx errors
	ErrorCode_ErrTxNotFound      ErrorCode = 100
	ErrorCode_ErrTxAlreadyExists ErrorCode = 101
	ErrorCode_ErrTxSerialization ErrorCode = 102
)

func (ErrorCode) Descriptor added in v1.1.0 

func (ErrorCode) Descriptor() protoreflect.EnumDescriptor

func (ErrorCode) Enum added in v1.1.0 

func (x ErrorCode) Enum() *ErrorCode

func (ErrorCode) EnumDescriptor deprecated added in v1.1.0 

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

Deprecated: Use ErrorCode.Descriptor instead.

func (ErrorCode) Number added in v1.1.0 

func (x ErrorCode) Number() protoreflect.EnumNumber

func (ErrorCode) String added in v1.1.0 

func (x ErrorCode) String() string

func (ErrorCode) Type added in v1.1.0 

func (ErrorCode) Type() protoreflect.EnumType

type FileHeader added in v1.0.1 

type FileHeader struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Deprecated: Marked as deprecated in store_service.proto.
	Size uint64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*FileHeader) Descriptor deprecated added in v1.0.1 

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

Deprecated: Use FileHeader.ProtoReflect.Descriptor instead.

func (*FileHeader) GetKey added in v1.0.1 

func (x *FileHeader) GetKey() string

func (*FileHeader) GetSize deprecated added in v1.0.1 

func (x *FileHeader) GetSize() uint64

Deprecated: Marked as deprecated in store_service.proto.

func (*FileHeader) ProtoMessage added in v1.0.1 

func (*FileHeader) ProtoMessage()

func (*FileHeader) ProtoReflect added in v1.0.1 

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

func (*FileHeader) Reset added in v1.0.1 

func (x *FileHeader) Reset()

func (*FileHeader) String added in v1.0.1 

func (x *FileHeader) String() string

type GetFileRequest 

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

func (*GetFileRequest) Descriptor deprecated 

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

Deprecated: Use GetFileRequest.ProtoReflect.Descriptor instead.

func (*GetFileRequest) GetKey 

func (x *GetFileRequest) GetKey() string

func (*GetFileRequest) ProtoMessage 

func (*GetFileRequest) ProtoMessage()

func (*GetFileRequest) ProtoReflect 

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

func (*GetFileRequest) Reset 

func (x *GetFileRequest) Reset()

func (*GetFileRequest) String 

func (x *GetFileRequest) String() string

type GetFileResponse 

type GetFileResponse struct {

	// Types that are assignable to Data:
	//
	//	*GetFileResponse_Chunk
	//	*GetFileResponse_Header
	Data isGetFileResponse_Data `protobuf_oneof:"data"`
	// contains filtered or unexported fields
}

func (*GetFileResponse) Descriptor deprecated 

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

Deprecated: Use GetFileResponse.ProtoReflect.Descriptor instead.

func (*GetFileResponse) GetChunk 

func (x *GetFileResponse) GetChunk() []byte

func (*GetFileResponse) GetData added in v1.0.1 

func (m *GetFileResponse) GetData() isGetFileResponse_Data

func (*GetFileResponse) GetHeader added in v1.0.1 

func (x *GetFileResponse) GetHeader() *FileHeader

func (*GetFileResponse) ProtoMessage 

func (*GetFileResponse) ProtoMessage()

func (*GetFileResponse) ProtoReflect 

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

func (*GetFileResponse) Reset 

func (x *GetFileResponse) Reset()

func (*GetFileResponse) String 

func (x *GetFileResponse) String() string

type GetFileResponse_Chunk added in v1.0.1 

type GetFileResponse_Chunk struct {
	Chunk []byte `protobuf:"bytes,1,opt,name=chunk,proto3,oneof"`
}

type GetFileResponse_Header added in v1.0.1 

type GetFileResponse_Header struct {
	Header *FileHeader `protobuf:"bytes,2,opt,name=header,proto3,oneof"`
}

type GetKeysRequest added in v1.1.0 

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

func (*GetKeysRequest) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use GetKeysRequest.ProtoReflect.Descriptor instead.

func (*GetKeysRequest) ProtoMessage added in v1.1.0 

func (*GetKeysRequest) ProtoMessage()

func (*GetKeysRequest) ProtoReflect added in v1.1.0 

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

func (*GetKeysRequest) Reset added in v1.1.0 

func (x *GetKeysRequest) Reset()

func (*GetKeysRequest) String added in v1.1.0 

func (x *GetKeysRequest) String() string

type GetKeysResponse added in v1.1.0 

type GetKeysResponse struct {
	Keys []string `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*GetKeysResponse) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use GetKeysResponse.ProtoReflect.Descriptor instead.

func (*GetKeysResponse) GetKeys added in v1.1.0 

func (x *GetKeysResponse) GetKeys() []string

func (*GetKeysResponse) ProtoMessage added in v1.1.0 

func (*GetKeysResponse) ProtoMessage()

func (*GetKeysResponse) ProtoReflect added in v1.1.0 

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

func (*GetKeysResponse) Reset added in v1.1.0 

func (x *GetKeysResponse) Reset()

func (*GetKeysResponse) String added in v1.1.0 

func (x *GetKeysResponse) String() string

type RollbackTxRequest added in v1.0.0 

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

func (*RollbackTxRequest) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use RollbackTxRequest.ProtoReflect.Descriptor instead.

func (*RollbackTxRequest) ProtoMessage added in v1.0.0 

func (*RollbackTxRequest) ProtoMessage()

func (*RollbackTxRequest) ProtoReflect added in v1.0.0 

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

func (*RollbackTxRequest) Reset added in v1.0.0 

func (x *RollbackTxRequest) Reset()

func (*RollbackTxRequest) String added in v1.0.0 

func (x *RollbackTxRequest) String() string

type RollbackTxResponse added in v1.0.0 

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

func (*RollbackTxResponse) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use RollbackTxResponse.ProtoReflect.Descriptor instead.

func (*RollbackTxResponse) ProtoMessage added in v1.0.0 

func (*RollbackTxResponse) ProtoMessage()

func (*RollbackTxResponse) ProtoReflect added in v1.0.0 

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

func (*RollbackTxResponse) Reset added in v1.0.0 

func (x *RollbackTxResponse) Reset()

func (*RollbackTxResponse) String added in v1.0.0 

func (x *RollbackTxResponse) String() string

type SetFileRequest 

type SetFileRequest struct {

	// Types that are assignable to Data:
	//
	//	*SetFileRequest_Header
	//	*SetFileRequest_Chunk
	Data isSetFileRequest_Data `protobuf_oneof:"data"`
	// contains filtered or unexported fields
}

func (*SetFileRequest) Descriptor deprecated 

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

Deprecated: Use SetFileRequest.ProtoReflect.Descriptor instead.

func (*SetFileRequest) GetChunk 

func (x *SetFileRequest) GetChunk() []byte

func (*SetFileRequest) GetData 

func (m *SetFileRequest) GetData() isSetFileRequest_Data

func (*SetFileRequest) GetHeader 

func (x *SetFileRequest) GetHeader() *FileHeader

func (*SetFileRequest) ProtoMessage 

func (*SetFileRequest) ProtoMessage()

func (*SetFileRequest) ProtoReflect 

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

func (*SetFileRequest) Reset 

func (x *SetFileRequest) Reset()

func (*SetFileRequest) String 

func (x *SetFileRequest) String() string

type SetFileRequest_Chunk 

type SetFileRequest_Chunk struct {
	Chunk []byte `protobuf:"bytes,2,opt,name=chunk,proto3,oneof"`
}

type SetFileRequest_Header 

type SetFileRequest_Header struct {
	Header *FileHeader `protobuf:"bytes,1,opt,name=header,proto3,oneof"`
}

type SetFileResponse 

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

func (*SetFileResponse) Descriptor deprecated 

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

Deprecated: Use SetFileResponse.ProtoReflect.Descriptor instead.

func (*SetFileResponse) ProtoMessage 

func (*SetFileResponse) ProtoMessage()

func (*SetFileResponse) ProtoReflect 

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

func (*SetFileResponse) Reset 

func (x *SetFileResponse) Reset()

func (*SetFileResponse) String 

func (x *SetFileResponse) String() string

type StoreV1Client 

type StoreV1Client interface {
	SetFile(ctx context.Context, opts ...grpc.CallOption) (StoreV1_SetFileClient, error)
	GetFile(ctx context.Context, in *GetFileRequest, opts ...grpc.CallOption) (StoreV1_GetFileClient, error)
	GetKeys(ctx context.Context, in *GetKeysRequest, opts ...grpc.CallOption) (*GetKeysResponse, error)
	DeleteFile(ctx context.Context, in *DeleteFileRequest, opts ...grpc.CallOption) (*DeleteFileResponse, error)
	// Tx
	BeginTx(ctx context.Context, in *BeginTxRequest, opts ...grpc.CallOption) (*BeginTxResponse, error)
	CommitTx(ctx context.Context, in *CommitTxRequest, opts ...grpc.CallOption) (*CommitTxResponse, error)
	RollbackTx(ctx context.Context, in *RollbackTxRequest, opts ...grpc.CallOption) (*RollbackTxResponse, error)
}

StoreV1Client is the client API for StoreV1 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 NewStoreV1Client 

func NewStoreV1Client(cc grpc.ClientConnInterface) StoreV1Client

type StoreV1Server 

type StoreV1Server interface {
	SetFile(StoreV1_SetFileServer) error
	GetFile(*GetFileRequest, StoreV1_GetFileServer) error
	GetKeys(context.Context, *GetKeysRequest) (*GetKeysResponse, error)
	DeleteFile(context.Context, *DeleteFileRequest) (*DeleteFileResponse, error)
	// Tx
	BeginTx(context.Context, *BeginTxRequest) (*BeginTxResponse, error)
	CommitTx(context.Context, *CommitTxRequest) (*CommitTxResponse, error)
	RollbackTx(context.Context, *RollbackTxRequest) (*RollbackTxResponse, error)
	// contains filtered or unexported methods
}

StoreV1Server is the server API for StoreV1 service. All implementations must embed UnimplementedStoreV1Server for forward compatibility

type StoreV1_GetFileClient 

type StoreV1_GetFileClient interface {
	Recv() (*GetFileResponse, error)
	grpc.ClientStream
}

type StoreV1_GetFileServer 

type StoreV1_GetFileServer interface {
	Send(*GetFileResponse) error
	grpc.ServerStream
}

type StoreV1_SetFileClient 

type StoreV1_SetFileClient interface {
	Send(*SetFileRequest) error
	CloseAndRecv() (*SetFileResponse, error)
	grpc.ClientStream
}

type StoreV1_SetFileServer 

type StoreV1_SetFileServer interface {
	SendAndClose(*SetFileResponse) error
	Recv() (*SetFileRequest, error)
	grpc.ServerStream
}

type TxIsoLevel added in v1.0.0 

type TxIsoLevel int32
const (
	TxIsoLevel_ISO_LEVEL_READ_UNCOMMITTED TxIsoLevel = 0
	TxIsoLevel_ISO_LEVEL_READ_COMMITTED   TxIsoLevel = 1
	TxIsoLevel_ISO_LEVEL_REPEATABLE_READ  TxIsoLevel = 2
	TxIsoLevel_ISO_LEVEL_SERIALIZABLE     TxIsoLevel = 3
)

func (TxIsoLevel) Descriptor added in v1.0.0 

func (TxIsoLevel) Descriptor() protoreflect.EnumDescriptor

func (TxIsoLevel) Enum added in v1.0.0 

func (x TxIsoLevel) Enum() *TxIsoLevel

func (TxIsoLevel) EnumDescriptor deprecated added in v1.0.0 

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

Deprecated: Use TxIsoLevel.Descriptor instead.

func (TxIsoLevel) Number added in v1.0.0 

func (x TxIsoLevel) Number() protoreflect.EnumNumber

func (TxIsoLevel) String added in v1.0.0 

func (x TxIsoLevel) String() string

func (TxIsoLevel) Type added in v1.0.0 

func (TxIsoLevel) Type() protoreflect.EnumType

type UnimplementedStoreV1Server 

type UnimplementedStoreV1Server struct {
}

UnimplementedStoreV1Server must be embedded to have forward compatible implementations.

func (UnimplementedStoreV1Server) BeginTx added in v1.0.0 

func (UnimplementedStoreV1Server) BeginTx(context.Context, *BeginTxRequest) (*BeginTxResponse, error)

func (UnimplementedStoreV1Server) CommitTx added in v1.0.0 

func (UnimplementedStoreV1Server) CommitTx(context.Context, *CommitTxRequest) (*CommitTxResponse, error)

func (UnimplementedStoreV1Server) DeleteFile 

func (UnimplementedStoreV1Server) DeleteFile(context.Context, *DeleteFileRequest) (*DeleteFileResponse, error)

func (UnimplementedStoreV1Server) GetFile 

func (UnimplementedStoreV1Server) GetFile(*GetFileRequest, StoreV1_GetFileServer) error

func (UnimplementedStoreV1Server) GetKeys added in v1.1.0 

func (UnimplementedStoreV1Server) GetKeys(context.Context, *GetKeysRequest) (*GetKeysResponse, error)

func (UnimplementedStoreV1Server) RollbackTx added in v1.0.0 

func (UnimplementedStoreV1Server) RollbackTx(context.Context, *RollbackTxRequest) (*RollbackTxResponse, error)

func (UnimplementedStoreV1Server) SetFile 

func (UnimplementedStoreV1Server) SetFile(StoreV1_SetFileServer) error

type UnsafeStoreV1Server 

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

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

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.