Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterStoreServer(s grpc.ServiceRegistrar, srv StoreServer)
- type CloseRequest
- type CloseResponse
- type CreateRequest
- type CreateResponse
- type DeleteRequest
- func (*DeleteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteRequest) GetFlags() StorageFlags
- func (x *DeleteRequest) GetMac() []byte
- func (x *DeleteRequest) GetType() StorageResource
- func (*DeleteRequest) ProtoMessage()
- func (x *DeleteRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteRequest) Reset()
- func (x *DeleteRequest) String() string
- type DeleteResponse
- type GetRequest
- func (*GetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetRequest) GetFlags() StorageFlags
- func (x *GetRequest) GetMac() []byte
- func (x *GetRequest) GetRange() *GetRequest_Range
- func (x *GetRequest) GetType() StorageResource
- func (*GetRequest) ProtoMessage()
- func (x *GetRequest) ProtoReflect() protoreflect.Message
- func (x *GetRequest) Reset()
- func (x *GetRequest) String() string
- type GetRequest_Range
- func (*GetRequest_Range) Descriptor() ([]byte, []int)deprecated
- func (x *GetRequest_Range) GetLength() uint32
- func (x *GetRequest_Range) GetOffset() uint64
- func (*GetRequest_Range) ProtoMessage()
- func (x *GetRequest_Range) ProtoReflect() protoreflect.Message
- func (x *GetRequest_Range) Reset()
- func (x *GetRequest_Range) String() string
- type GetResponse
- type InitRequest
- func (*InitRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InitRequest) GetConfig() map[string]string
- func (x *InitRequest) GetProto() string
- func (*InitRequest) ProtoMessage()
- func (x *InitRequest) ProtoReflect() protoreflect.Message
- func (x *InitRequest) Reset()
- func (x *InitRequest) String() string
- type InitResponse
- func (*InitResponse) Descriptor() ([]byte, []int)deprecated
- func (x *InitResponse) GetFlags() uint32
- func (x *InitResponse) GetOrigin() string
- func (x *InitResponse) GetRoot() string
- func (x *InitResponse) GetType() string
- func (*InitResponse) ProtoMessage()
- func (x *InitResponse) ProtoReflect() protoreflect.Message
- func (x *InitResponse) Reset()
- func (x *InitResponse) String() string
- type ListRequest
- func (*ListRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListRequest) GetFlags() StorageFlags
- func (x *ListRequest) GetType() StorageResource
- func (*ListRequest) ProtoMessage()
- func (x *ListRequest) ProtoReflect() protoreflect.Message
- func (x *ListRequest) Reset()
- func (x *ListRequest) String() string
- type ListResponse
- type ModeRequest
- type ModeResponse
- type OpenRequest
- type OpenResponse
- type PingRequest
- type PingResponse
- type PutRequest
- func (*PutRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PutRequest) GetChunk() []byte
- func (x *PutRequest) GetFlags() StorageFlags
- func (x *PutRequest) GetMac() []byte
- func (x *PutRequest) GetType() StorageResource
- func (*PutRequest) ProtoMessage()
- func (x *PutRequest) ProtoReflect() protoreflect.Message
- func (x *PutRequest) Reset()
- func (x *PutRequest) String() string
- type PutResponse
- type SizeRequest
- type SizeResponse
- type StorageFlags
- func (StorageFlags) Descriptor() protoreflect.EnumDescriptor
- func (x StorageFlags) Enum() *StorageFlags
- func (StorageFlags) EnumDescriptor() ([]byte, []int)deprecated
- func (x StorageFlags) Number() protoreflect.EnumNumber
- func (x StorageFlags) String() string
- func (StorageFlags) Type() protoreflect.EnumType
- type StorageResource
- func (StorageResource) Descriptor() protoreflect.EnumDescriptor
- func (x StorageResource) Enum() *StorageResource
- func (StorageResource) EnumDescriptor() ([]byte, []int)deprecated
- func (x StorageResource) Number() protoreflect.EnumNumber
- func (x StorageResource) String() string
- func (StorageResource) Type() protoreflect.EnumType
- type StoreClient
- type StoreServer
- type Store_GetClient
- type Store_GetServer
- type Store_PutClient
- type Store_PutServer
- type UnimplementedStoreServer
- func (UnimplementedStoreServer) Close(context.Context, *CloseRequest) (*CloseResponse, error)
- func (UnimplementedStoreServer) Create(context.Context, *CreateRequest) (*CreateResponse, error)
- func (UnimplementedStoreServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
- func (UnimplementedStoreServer) Get(*GetRequest, grpc.ServerStreamingServer[GetResponse]) error
- func (UnimplementedStoreServer) Init(context.Context, *InitRequest) (*InitResponse, error)
- func (UnimplementedStoreServer) List(context.Context, *ListRequest) (*ListResponse, error)
- func (UnimplementedStoreServer) Mode(context.Context, *ModeRequest) (*ModeResponse, error)
- func (UnimplementedStoreServer) Open(context.Context, *OpenRequest) (*OpenResponse, error)
- func (UnimplementedStoreServer) Ping(context.Context, *PingRequest) (*PingResponse, error)
- func (UnimplementedStoreServer) Put(grpc.ClientStreamingServer[PutRequest, PutResponse]) error
- func (UnimplementedStoreServer) Size(context.Context, *SizeRequest) (*SizeResponse, error)
- type UnsafeStoreServer
Constants ¶
const ( Store_Init_FullMethodName = "/store.Store/Init" Store_Create_FullMethodName = "/store.Store/Create" Store_Open_FullMethodName = "/store.Store/Open" Store_Ping_FullMethodName = "/store.Store/Ping" Store_Mode_FullMethodName = "/store.Store/Mode" Store_Size_FullMethodName = "/store.Store/Size" Store_List_FullMethodName = "/store.Store/List" Store_Put_FullMethodName = "/store.Store/Put" Store_Get_FullMethodName = "/store.Store/Get" Store_Delete_FullMethodName = "/store.Store/Delete" Store_Close_FullMethodName = "/store.Store/Close" )
Variables ¶
var ( StorageResource_name = map[int32]string{ 0: "STORAGE_RESOURCE_UNDEFINED", 1: "STORAGE_RESOURCE_PACKFILE", 2: "STORAGE_RESOURCE_STATE", 3: "STORAGE_RESOURCE_LOCK", 4: "STORAGE_RESOURCE_ECC_PACKFILE", 5: "STORAGE_RESOURCE_ECC_STATE", } StorageResource_value = map[string]int32{ "STORAGE_RESOURCE_UNDEFINED": 0, "STORAGE_RESOURCE_PACKFILE": 1, "STORAGE_RESOURCE_STATE": 2, "STORAGE_RESOURCE_LOCK": 3, "STORAGE_RESOURCE_ECC_PACKFILE": 4, "STORAGE_RESOURCE_ECC_STATE": 5, } )
Enum value maps for StorageResource.
var ( StorageFlags_name = map[int32]string{ 0: "STORAGE_FLAGS_UNDEFINED", 1: "STORAGE_FLAGS_HOT", } StorageFlags_value = map[string]int32{ "STORAGE_FLAGS_UNDEFINED": 0, "STORAGE_FLAGS_HOT": 1, } )
Enum value maps for StorageFlags.
var File_storage_proto protoreflect.FileDescriptor
var Store_ServiceDesc = grpc.ServiceDesc{ ServiceName: "store.Store", HandlerType: (*StoreServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Init", Handler: _Store_Init_Handler, }, { MethodName: "Create", Handler: _Store_Create_Handler, }, { MethodName: "Open", Handler: _Store_Open_Handler, }, { MethodName: "Ping", Handler: _Store_Ping_Handler, }, { MethodName: "Mode", Handler: _Store_Mode_Handler, }, { MethodName: "Size", Handler: _Store_Size_Handler, }, { MethodName: "List", Handler: _Store_List_Handler, }, { MethodName: "Delete", Handler: _Store_Delete_Handler, }, { MethodName: "Close", Handler: _Store_Close_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Put", Handler: _Store_Put_Handler, ClientStreams: true, }, { StreamName: "Get", Handler: _Store_Get_Handler, ServerStreams: true, }, }, Metadata: "storage.proto", }
Store_ServiceDesc is the grpc.ServiceDesc for Store service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterStoreServer ¶
func RegisterStoreServer(s grpc.ServiceRegistrar, srv StoreServer)
Types ¶
type CloseRequest ¶
type CloseRequest struct {
// contains filtered or unexported fields
}
func (*CloseRequest) Descriptor
deprecated
func (*CloseRequest) Descriptor() ([]byte, []int)
Deprecated: Use CloseRequest.ProtoReflect.Descriptor instead.
func (*CloseRequest) ProtoMessage ¶
func (*CloseRequest) ProtoMessage()
func (*CloseRequest) ProtoReflect ¶
func (x *CloseRequest) ProtoReflect() protoreflect.Message
func (*CloseRequest) Reset ¶
func (x *CloseRequest) Reset()
func (*CloseRequest) String ¶
func (x *CloseRequest) String() string
type CloseResponse ¶
type CloseResponse struct {
// contains filtered or unexported fields
}
func (*CloseResponse) Descriptor
deprecated
func (*CloseResponse) Descriptor() ([]byte, []int)
Deprecated: Use CloseResponse.ProtoReflect.Descriptor instead.
func (*CloseResponse) ProtoMessage ¶
func (*CloseResponse) ProtoMessage()
func (*CloseResponse) ProtoReflect ¶
func (x *CloseResponse) ProtoReflect() protoreflect.Message
func (*CloseResponse) Reset ¶
func (x *CloseResponse) Reset()
func (*CloseResponse) String ¶
func (x *CloseResponse) String() string
type CreateRequest ¶
type CreateRequest struct {
Config []byte `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
// contains filtered or unexported fields
}
func (*CreateRequest) Descriptor
deprecated
func (*CreateRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateRequest.ProtoReflect.Descriptor instead.
func (*CreateRequest) GetConfig ¶
func (x *CreateRequest) GetConfig() []byte
func (*CreateRequest) ProtoMessage ¶
func (*CreateRequest) ProtoMessage()
func (*CreateRequest) ProtoReflect ¶
func (x *CreateRequest) ProtoReflect() protoreflect.Message
func (*CreateRequest) Reset ¶
func (x *CreateRequest) Reset()
func (*CreateRequest) String ¶
func (x *CreateRequest) String() string
type CreateResponse ¶
type CreateResponse struct {
// contains filtered or unexported fields
}
func (*CreateResponse) Descriptor
deprecated
func (*CreateResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateResponse.ProtoReflect.Descriptor instead.
func (*CreateResponse) ProtoMessage ¶
func (*CreateResponse) ProtoMessage()
func (*CreateResponse) ProtoReflect ¶
func (x *CreateResponse) ProtoReflect() protoreflect.Message
func (*CreateResponse) Reset ¶
func (x *CreateResponse) Reset()
func (*CreateResponse) String ¶
func (x *CreateResponse) String() string
type DeleteRequest ¶
type DeleteRequest struct {
Mac []byte `protobuf:"bytes,1,opt,name=mac,proto3" json:"mac,omitempty"`
Type StorageResource `protobuf:"varint,2,opt,name=type,proto3,enum=store.StorageResource" json:"type,omitempty"`
Flags StorageFlags `protobuf:"varint,3,opt,name=flags,proto3,enum=store.StorageFlags" json:"flags,omitempty"`
// contains filtered or unexported fields
}
func (*DeleteRequest) Descriptor
deprecated
func (*DeleteRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.
func (*DeleteRequest) GetFlags ¶
func (x *DeleteRequest) GetFlags() StorageFlags
func (*DeleteRequest) GetMac ¶
func (x *DeleteRequest) GetMac() []byte
func (*DeleteRequest) GetType ¶
func (x *DeleteRequest) GetType() StorageResource
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 GetRequest ¶
type GetRequest struct {
Mac []byte `protobuf:"bytes,1,opt,name=mac,proto3" json:"mac,omitempty"`
Type StorageResource `protobuf:"varint,2,opt,name=type,proto3,enum=store.StorageResource" json:"type,omitempty"`
Range *GetRequest_Range `protobuf:"bytes,3,opt,name=range,proto3,oneof" json:"range,omitempty"`
Flags StorageFlags `protobuf:"varint,4,opt,name=flags,proto3,enum=store.StorageFlags" json:"flags,omitempty"`
// contains filtered or unexported fields
}
func (*GetRequest) Descriptor
deprecated
func (*GetRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.
func (*GetRequest) GetFlags ¶
func (x *GetRequest) GetFlags() StorageFlags
func (*GetRequest) GetMac ¶
func (x *GetRequest) GetMac() []byte
func (*GetRequest) GetRange ¶
func (x *GetRequest) GetRange() *GetRequest_Range
func (*GetRequest) GetType ¶
func (x *GetRequest) GetType() StorageResource
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 GetRequest_Range ¶
type GetRequest_Range struct {
Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
Length uint32 `protobuf:"varint,2,opt,name=length,proto3" json:"length,omitempty"`
// contains filtered or unexported fields
}
func (*GetRequest_Range) Descriptor
deprecated
func (*GetRequest_Range) Descriptor() ([]byte, []int)
Deprecated: Use GetRequest_Range.ProtoReflect.Descriptor instead.
func (*GetRequest_Range) GetLength ¶
func (x *GetRequest_Range) GetLength() uint32
func (*GetRequest_Range) GetOffset ¶
func (x *GetRequest_Range) GetOffset() uint64
func (*GetRequest_Range) ProtoMessage ¶
func (*GetRequest_Range) ProtoMessage()
func (*GetRequest_Range) ProtoReflect ¶
func (x *GetRequest_Range) ProtoReflect() protoreflect.Message
func (*GetRequest_Range) Reset ¶
func (x *GetRequest_Range) Reset()
func (*GetRequest_Range) String ¶
func (x *GetRequest_Range) String() string
type GetResponse ¶
type GetResponse struct {
Chunk []byte `protobuf:"bytes,1,opt,name=chunk,proto3" json:"chunk,omitempty"`
// contains filtered or unexported fields
}
func (*GetResponse) Descriptor
deprecated
func (*GetResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.
func (*GetResponse) GetChunk ¶
func (x *GetResponse) GetChunk() []byte
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 InitRequest ¶
type InitRequest struct {
Proto string `protobuf:"bytes,1,opt,name=proto,proto3" json:"proto,omitempty"`
Config map[string]string `` /* 139-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*InitRequest) Descriptor
deprecated
func (*InitRequest) Descriptor() ([]byte, []int)
Deprecated: Use InitRequest.ProtoReflect.Descriptor instead.
func (*InitRequest) GetConfig ¶
func (x *InitRequest) GetConfig() map[string]string
func (*InitRequest) GetProto ¶
func (x *InitRequest) GetProto() string
func (*InitRequest) ProtoMessage ¶
func (*InitRequest) ProtoMessage()
func (*InitRequest) ProtoReflect ¶
func (x *InitRequest) ProtoReflect() protoreflect.Message
func (*InitRequest) Reset ¶
func (x *InitRequest) Reset()
func (*InitRequest) String ¶
func (x *InitRequest) String() string
type InitResponse ¶
type InitResponse struct {
Origin string `protobuf:"bytes,1,opt,name=origin,proto3" json:"origin,omitempty"`
Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
Root string `protobuf:"bytes,3,opt,name=root,proto3" json:"root,omitempty"`
Flags uint32 `protobuf:"varint,5,opt,name=flags,proto3" json:"flags,omitempty"`
// contains filtered or unexported fields
}
func (*InitResponse) Descriptor
deprecated
func (*InitResponse) Descriptor() ([]byte, []int)
Deprecated: Use InitResponse.ProtoReflect.Descriptor instead.
func (*InitResponse) GetFlags ¶
func (x *InitResponse) GetFlags() uint32
func (*InitResponse) GetOrigin ¶
func (x *InitResponse) GetOrigin() string
func (*InitResponse) GetRoot ¶
func (x *InitResponse) GetRoot() string
func (*InitResponse) GetType ¶
func (x *InitResponse) GetType() string
func (*InitResponse) ProtoMessage ¶
func (*InitResponse) ProtoMessage()
func (*InitResponse) ProtoReflect ¶
func (x *InitResponse) ProtoReflect() protoreflect.Message
func (*InitResponse) Reset ¶
func (x *InitResponse) Reset()
func (*InitResponse) String ¶
func (x *InitResponse) String() string
type ListRequest ¶
type ListRequest struct {
Type StorageResource `protobuf:"varint,1,opt,name=type,proto3,enum=store.StorageResource" json:"type,omitempty"`
Flags StorageFlags `protobuf:"varint,2,opt,name=flags,proto3,enum=store.StorageFlags" json:"flags,omitempty"`
// contains filtered or unexported fields
}
func (*ListRequest) Descriptor
deprecated
func (*ListRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.
func (*ListRequest) GetFlags ¶
func (x *ListRequest) GetFlags() StorageFlags
func (*ListRequest) GetType ¶
func (x *ListRequest) GetType() StorageResource
func (*ListRequest) ProtoMessage ¶
func (*ListRequest) ProtoMessage()
func (*ListRequest) ProtoReflect ¶
func (x *ListRequest) ProtoReflect() protoreflect.Message
func (*ListRequest) Reset ¶
func (x *ListRequest) Reset()
func (*ListRequest) String ¶
func (x *ListRequest) String() string
type ListResponse ¶
type ListResponse struct {
Macs [][]byte `protobuf:"bytes,1,rep,name=macs,proto3" json:"macs,omitempty"`
// contains filtered or unexported fields
}
func (*ListResponse) Descriptor
deprecated
func (*ListResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.
func (*ListResponse) GetMacs ¶
func (x *ListResponse) GetMacs() [][]byte
func (*ListResponse) ProtoMessage ¶
func (*ListResponse) ProtoMessage()
func (*ListResponse) ProtoReflect ¶
func (x *ListResponse) ProtoReflect() protoreflect.Message
func (*ListResponse) Reset ¶
func (x *ListResponse) Reset()
func (*ListResponse) String ¶
func (x *ListResponse) String() string
type ModeRequest ¶
type ModeRequest struct {
// contains filtered or unexported fields
}
func (*ModeRequest) Descriptor
deprecated
func (*ModeRequest) Descriptor() ([]byte, []int)
Deprecated: Use ModeRequest.ProtoReflect.Descriptor instead.
func (*ModeRequest) ProtoMessage ¶
func (*ModeRequest) ProtoMessage()
func (*ModeRequest) ProtoReflect ¶
func (x *ModeRequest) ProtoReflect() protoreflect.Message
func (*ModeRequest) Reset ¶
func (x *ModeRequest) Reset()
func (*ModeRequest) String ¶
func (x *ModeRequest) String() string
type ModeResponse ¶
type ModeResponse struct {
Mode int32 `protobuf:"varint,1,opt,name=mode,proto3" json:"mode,omitempty"`
// contains filtered or unexported fields
}
func (*ModeResponse) Descriptor
deprecated
func (*ModeResponse) Descriptor() ([]byte, []int)
Deprecated: Use ModeResponse.ProtoReflect.Descriptor instead.
func (*ModeResponse) GetMode ¶
func (x *ModeResponse) GetMode() int32
func (*ModeResponse) ProtoMessage ¶
func (*ModeResponse) ProtoMessage()
func (*ModeResponse) ProtoReflect ¶
func (x *ModeResponse) ProtoReflect() protoreflect.Message
func (*ModeResponse) Reset ¶
func (x *ModeResponse) Reset()
func (*ModeResponse) String ¶
func (x *ModeResponse) String() string
type OpenRequest ¶
type OpenRequest struct {
// contains filtered or unexported fields
}
func (*OpenRequest) Descriptor
deprecated
func (*OpenRequest) Descriptor() ([]byte, []int)
Deprecated: Use OpenRequest.ProtoReflect.Descriptor instead.
func (*OpenRequest) ProtoMessage ¶
func (*OpenRequest) ProtoMessage()
func (*OpenRequest) ProtoReflect ¶
func (x *OpenRequest) ProtoReflect() protoreflect.Message
func (*OpenRequest) Reset ¶
func (x *OpenRequest) Reset()
func (*OpenRequest) String ¶
func (x *OpenRequest) String() string
type OpenResponse ¶
type OpenResponse struct {
Config []byte `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
// contains filtered or unexported fields
}
func (*OpenResponse) Descriptor
deprecated
func (*OpenResponse) Descriptor() ([]byte, []int)
Deprecated: Use OpenResponse.ProtoReflect.Descriptor instead.
func (*OpenResponse) GetConfig ¶
func (x *OpenResponse) GetConfig() []byte
func (*OpenResponse) ProtoMessage ¶
func (*OpenResponse) ProtoMessage()
func (*OpenResponse) ProtoReflect ¶
func (x *OpenResponse) ProtoReflect() protoreflect.Message
func (*OpenResponse) Reset ¶
func (x *OpenResponse) Reset()
func (*OpenResponse) String ¶
func (x *OpenResponse) String() string
type PingRequest ¶
type PingRequest struct {
// contains filtered or unexported fields
}
func (*PingRequest) Descriptor
deprecated
func (*PingRequest) Descriptor() ([]byte, []int)
Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.
func (*PingRequest) ProtoMessage ¶
func (*PingRequest) ProtoMessage()
func (*PingRequest) ProtoReflect ¶
func (x *PingRequest) ProtoReflect() protoreflect.Message
func (*PingRequest) Reset ¶
func (x *PingRequest) Reset()
func (*PingRequest) String ¶
func (x *PingRequest) String() string
type PingResponse ¶
type PingResponse struct {
// contains filtered or unexported fields
}
func (*PingResponse) Descriptor
deprecated
func (*PingResponse) Descriptor() ([]byte, []int)
Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.
func (*PingResponse) ProtoMessage ¶
func (*PingResponse) ProtoMessage()
func (*PingResponse) ProtoReflect ¶
func (x *PingResponse) ProtoReflect() protoreflect.Message
func (*PingResponse) Reset ¶
func (x *PingResponse) Reset()
func (*PingResponse) String ¶
func (x *PingResponse) String() string
type PutRequest ¶
type PutRequest struct {
Mac []byte `protobuf:"bytes,1,opt,name=mac,proto3" json:"mac,omitempty"`
Type StorageResource `protobuf:"varint,2,opt,name=type,proto3,enum=store.StorageResource" json:"type,omitempty"`
Chunk []byte `protobuf:"bytes,3,opt,name=chunk,proto3" json:"chunk,omitempty"`
Flags StorageFlags `protobuf:"varint,4,opt,name=flags,proto3,enum=store.StorageFlags" json:"flags,omitempty"`
// contains filtered or unexported fields
}
func (*PutRequest) Descriptor
deprecated
func (*PutRequest) Descriptor() ([]byte, []int)
Deprecated: Use PutRequest.ProtoReflect.Descriptor instead.
func (*PutRequest) GetChunk ¶
func (x *PutRequest) GetChunk() []byte
func (*PutRequest) GetFlags ¶
func (x *PutRequest) GetFlags() StorageFlags
func (*PutRequest) GetMac ¶
func (x *PutRequest) GetMac() []byte
func (*PutRequest) GetType ¶
func (x *PutRequest) GetType() StorageResource
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 {
BytesWritten int64 `protobuf:"varint,1,opt,name=bytes_written,json=bytesWritten,proto3" json:"bytes_written,omitempty"`
// contains filtered or unexported fields
}
func (*PutResponse) Descriptor
deprecated
func (*PutResponse) Descriptor() ([]byte, []int)
Deprecated: Use PutResponse.ProtoReflect.Descriptor instead.
func (*PutResponse) GetBytesWritten ¶
func (x *PutResponse) GetBytesWritten() int64
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 SizeRequest ¶
type SizeRequest struct {
// contains filtered or unexported fields
}
func (*SizeRequest) Descriptor
deprecated
func (*SizeRequest) Descriptor() ([]byte, []int)
Deprecated: Use SizeRequest.ProtoReflect.Descriptor instead.
func (*SizeRequest) ProtoMessage ¶
func (*SizeRequest) ProtoMessage()
func (*SizeRequest) ProtoReflect ¶
func (x *SizeRequest) ProtoReflect() protoreflect.Message
func (*SizeRequest) Reset ¶
func (x *SizeRequest) Reset()
func (*SizeRequest) String ¶
func (x *SizeRequest) String() string
type SizeResponse ¶
type SizeResponse struct {
Size int64 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
// contains filtered or unexported fields
}
func (*SizeResponse) Descriptor
deprecated
func (*SizeResponse) Descriptor() ([]byte, []int)
Deprecated: Use SizeResponse.ProtoReflect.Descriptor instead.
func (*SizeResponse) GetSize ¶
func (x *SizeResponse) GetSize() int64
func (*SizeResponse) ProtoMessage ¶
func (*SizeResponse) ProtoMessage()
func (*SizeResponse) ProtoReflect ¶
func (x *SizeResponse) ProtoReflect() protoreflect.Message
func (*SizeResponse) Reset ¶
func (x *SizeResponse) Reset()
func (*SizeResponse) String ¶
func (x *SizeResponse) String() string
type StorageFlags ¶
type StorageFlags int32
const ( StorageFlags_STORAGE_FLAGS_UNDEFINED StorageFlags = 0 StorageFlags_STORAGE_FLAGS_HOT StorageFlags = 1 )
func (StorageFlags) Descriptor ¶
func (StorageFlags) Descriptor() protoreflect.EnumDescriptor
func (StorageFlags) Enum ¶
func (x StorageFlags) Enum() *StorageFlags
func (StorageFlags) EnumDescriptor
deprecated
func (StorageFlags) EnumDescriptor() ([]byte, []int)
Deprecated: Use StorageFlags.Descriptor instead.
func (StorageFlags) Number ¶
func (x StorageFlags) Number() protoreflect.EnumNumber
func (StorageFlags) String ¶
func (x StorageFlags) String() string
func (StorageFlags) Type ¶
func (StorageFlags) Type() protoreflect.EnumType
type StorageResource ¶
type StorageResource int32
const ( StorageResource_STORAGE_RESOURCE_UNDEFINED StorageResource = 0 StorageResource_STORAGE_RESOURCE_PACKFILE StorageResource = 1 StorageResource_STORAGE_RESOURCE_STATE StorageResource = 2 StorageResource_STORAGE_RESOURCE_LOCK StorageResource = 3 StorageResource_STORAGE_RESOURCE_ECC_PACKFILE StorageResource = 4 StorageResource_STORAGE_RESOURCE_ECC_STATE StorageResource = 5 )
func (StorageResource) Descriptor ¶
func (StorageResource) Descriptor() protoreflect.EnumDescriptor
func (StorageResource) Enum ¶
func (x StorageResource) Enum() *StorageResource
func (StorageResource) EnumDescriptor
deprecated
func (StorageResource) EnumDescriptor() ([]byte, []int)
Deprecated: Use StorageResource.Descriptor instead.
func (StorageResource) Number ¶
func (x StorageResource) Number() protoreflect.EnumNumber
func (StorageResource) String ¶
func (x StorageResource) String() string
func (StorageResource) Type ¶
func (StorageResource) Type() protoreflect.EnumType
type StoreClient ¶
type StoreClient interface {
Init(ctx context.Context, in *InitRequest, opts ...grpc.CallOption) (*InitResponse, error)
Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
Open(ctx context.Context, in *OpenRequest, opts ...grpc.CallOption) (*OpenResponse, error)
Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
Mode(ctx context.Context, in *ModeRequest, opts ...grpc.CallOption) (*ModeResponse, error)
Size(ctx context.Context, in *SizeRequest, opts ...grpc.CallOption) (*SizeResponse, error)
List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
Put(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[PutRequest, PutResponse], error)
Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[GetResponse], error)
Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
Close(ctx context.Context, in *CloseRequest, opts ...grpc.CallOption) (*CloseResponse, error)
}
StoreClient is the client API for Store 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 NewStoreClient ¶
func NewStoreClient(cc grpc.ClientConnInterface) StoreClient
type StoreServer ¶
type StoreServer interface {
Init(context.Context, *InitRequest) (*InitResponse, error)
Create(context.Context, *CreateRequest) (*CreateResponse, error)
Open(context.Context, *OpenRequest) (*OpenResponse, error)
Ping(context.Context, *PingRequest) (*PingResponse, error)
Mode(context.Context, *ModeRequest) (*ModeResponse, error)
Size(context.Context, *SizeRequest) (*SizeResponse, error)
List(context.Context, *ListRequest) (*ListResponse, error)
Put(grpc.ClientStreamingServer[PutRequest, PutResponse]) error
Get(*GetRequest, grpc.ServerStreamingServer[GetResponse]) error
Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
Close(context.Context, *CloseRequest) (*CloseResponse, error)
// contains filtered or unexported methods
}
StoreServer is the server API for Store service. All implementations must embed UnimplementedStoreServer for forward compatibility.
type Store_GetClient ¶
type Store_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 Store_GetServer ¶
type Store_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 Store_PutClient ¶
type Store_PutClient = grpc.ClientStreamingClient[PutRequest, PutResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type Store_PutServer ¶
type Store_PutServer = grpc.ClientStreamingServer[PutRequest, PutResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type UnimplementedStoreServer ¶
type UnimplementedStoreServer struct{}
UnimplementedStoreServer 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 (UnimplementedStoreServer) Close ¶
func (UnimplementedStoreServer) Close(context.Context, *CloseRequest) (*CloseResponse, error)
func (UnimplementedStoreServer) Create ¶
func (UnimplementedStoreServer) Create(context.Context, *CreateRequest) (*CreateResponse, error)
func (UnimplementedStoreServer) Delete ¶
func (UnimplementedStoreServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
func (UnimplementedStoreServer) Get ¶
func (UnimplementedStoreServer) Get(*GetRequest, grpc.ServerStreamingServer[GetResponse]) error
func (UnimplementedStoreServer) Init ¶
func (UnimplementedStoreServer) Init(context.Context, *InitRequest) (*InitResponse, error)
func (UnimplementedStoreServer) List ¶
func (UnimplementedStoreServer) List(context.Context, *ListRequest) (*ListResponse, error)
func (UnimplementedStoreServer) Mode ¶
func (UnimplementedStoreServer) Mode(context.Context, *ModeRequest) (*ModeResponse, error)
func (UnimplementedStoreServer) Open ¶
func (UnimplementedStoreServer) Open(context.Context, *OpenRequest) (*OpenResponse, error)
func (UnimplementedStoreServer) Ping ¶
func (UnimplementedStoreServer) Ping(context.Context, *PingRequest) (*PingResponse, error)
func (UnimplementedStoreServer) Put ¶
func (UnimplementedStoreServer) Put(grpc.ClientStreamingServer[PutRequest, PutResponse]) error
func (UnimplementedStoreServer) Size ¶
func (UnimplementedStoreServer) Size(context.Context, *SizeRequest) (*SizeResponse, error)
type UnsafeStoreServer ¶
type UnsafeStoreServer interface {
// contains filtered or unexported methods
}
UnsafeStoreServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StoreServer will result in compilation errors.