Documentation
¶
Index ¶
- Constants
- Variables
- func Receive(ctx context.Context, client StorageV2Client, key string, out io.Writer) (int, error)
- func RegisterStorageV2Server(s grpc.ServiceRegistrar, srv StorageV2Server)
- type StorageV2Client
- type StorageV2DeleteObjectRequest
- func (*StorageV2DeleteObjectRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StorageV2DeleteObjectRequest) GetPath() *StorageV2Path
- func (*StorageV2DeleteObjectRequest) ProtoMessage()
- func (x *StorageV2DeleteObjectRequest) ProtoReflect() protoreflect.Message
- func (x *StorageV2DeleteObjectRequest) Reset()
- func (x *StorageV2DeleteObjectRequest) String() string
- type StorageV2DeleteObjectResponse
- func (*StorageV2DeleteObjectResponse) Descriptor() ([]byte, []int)deprecated
- func (*StorageV2DeleteObjectResponse) ProtoMessage()
- func (x *StorageV2DeleteObjectResponse) ProtoReflect() protoreflect.Message
- func (x *StorageV2DeleteObjectResponse) Reset()
- func (x *StorageV2DeleteObjectResponse) String() string
- type StorageV2HeadObjectRequest
- func (*StorageV2HeadObjectRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StorageV2HeadObjectRequest) GetPath() *StorageV2Path
- func (*StorageV2HeadObjectRequest) ProtoMessage()
- func (x *StorageV2HeadObjectRequest) ProtoReflect() protoreflect.Message
- func (x *StorageV2HeadObjectRequest) Reset()
- func (x *StorageV2HeadObjectRequest) String() string
- type StorageV2HeadObjectResponse
- func (*StorageV2HeadObjectResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StorageV2HeadObjectResponse) GetInfo() *StorageV2ObjectInfo
- func (*StorageV2HeadObjectResponse) ProtoMessage()
- func (x *StorageV2HeadObjectResponse) ProtoReflect() protoreflect.Message
- func (x *StorageV2HeadObjectResponse) Reset()
- func (x *StorageV2HeadObjectResponse) String() string
- type StorageV2InitRequest
- func (*StorageV2InitRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StorageV2InitRequest) GetCreate() bool
- func (*StorageV2InitRequest) ProtoMessage()
- func (x *StorageV2InitRequest) ProtoReflect() protoreflect.Message
- func (x *StorageV2InitRequest) Reset()
- func (x *StorageV2InitRequest) String() string
- type StorageV2InitResponse
- type StorageV2ListObjectsRequest
- func (*StorageV2ListObjectsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StorageV2ListObjectsRequest) GetPath() *StorageV2Path
- func (*StorageV2ListObjectsRequest) ProtoMessage()
- func (x *StorageV2ListObjectsRequest) ProtoReflect() protoreflect.Message
- func (x *StorageV2ListObjectsRequest) Reset()
- func (x *StorageV2ListObjectsRequest) String() string
- type StorageV2ListObjectsResponse
- func (*StorageV2ListObjectsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StorageV2ListObjectsResponse) GetFiles() []*StorageV2Object
- func (*StorageV2ListObjectsResponse) ProtoMessage()
- func (x *StorageV2ListObjectsResponse) ProtoReflect() protoreflect.Message
- func (x *StorageV2ListObjectsResponse) Reset()
- func (x *StorageV2ListObjectsResponse) String() string
- type StorageV2Object
- func (*StorageV2Object) Descriptor() ([]byte, []int)deprecated
- func (x *StorageV2Object) GetInfo() *StorageV2ObjectInfo
- func (x *StorageV2Object) GetPath() *StorageV2Path
- func (*StorageV2Object) ProtoMessage()
- func (x *StorageV2Object) ProtoReflect() protoreflect.Message
- func (x *StorageV2Object) Reset()
- func (x *StorageV2Object) String() string
- type StorageV2ObjectInfo
- func (*StorageV2ObjectInfo) Descriptor() ([]byte, []int)deprecated
- func (x *StorageV2ObjectInfo) GetLastUpdated() *timestamppb.Timestamp
- func (x *StorageV2ObjectInfo) GetSize() uint64
- func (*StorageV2ObjectInfo) ProtoMessage()
- func (x *StorageV2ObjectInfo) ProtoReflect() protoreflect.Message
- func (x *StorageV2ObjectInfo) Reset()
- func (x *StorageV2ObjectInfo) String() string
- type StorageV2Path
- type StorageV2ReadObjectRequest
- func (*StorageV2ReadObjectRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StorageV2ReadObjectRequest) GetPath() *StorageV2Path
- func (*StorageV2ReadObjectRequest) ProtoMessage()
- func (x *StorageV2ReadObjectRequest) ProtoReflect() protoreflect.Message
- func (x *StorageV2ReadObjectRequest) Reset()
- func (x *StorageV2ReadObjectRequest) String() string
- type StorageV2ReadObjectResponse
- func (*StorageV2ReadObjectResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StorageV2ReadObjectResponse) GetChunk() []byte
- func (*StorageV2ReadObjectResponse) ProtoMessage()
- func (x *StorageV2ReadObjectResponse) ProtoReflect() protoreflect.Message
- func (x *StorageV2ReadObjectResponse) Reset()
- func (x *StorageV2ReadObjectResponse) String() string
- type StorageV2Server
- type StorageV2WriteObjectRequest
- func (*StorageV2WriteObjectRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StorageV2WriteObjectRequest) GetChunk() []byte
- func (x *StorageV2WriteObjectRequest) GetPath() *StorageV2Path
- func (*StorageV2WriteObjectRequest) ProtoMessage()
- func (x *StorageV2WriteObjectRequest) ProtoReflect() protoreflect.Message
- func (x *StorageV2WriteObjectRequest) Reset()
- func (x *StorageV2WriteObjectRequest) String() string
- type StorageV2WriteObjectResponse
- func (*StorageV2WriteObjectResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StorageV2WriteObjectResponse) GetBytes() int64
- func (x *StorageV2WriteObjectResponse) GetChecksum() string
- func (*StorageV2WriteObjectResponse) ProtoMessage()
- func (x *StorageV2WriteObjectResponse) ProtoReflect() protoreflect.Message
- func (x *StorageV2WriteObjectResponse) Reset()
- func (x *StorageV2WriteObjectResponse) String() string
- type StorageV2_ListObjectsClient
- type StorageV2_ListObjectsServer
- type StorageV2_ReadObjectClient
- type StorageV2_ReadObjectServer
- type StorageV2_WriteObjectClient
- type StorageV2_WriteObjectServer
- type UnimplementedStorageV2Server
- func (UnimplementedStorageV2Server) DeleteObject(context.Context, *StorageV2DeleteObjectRequest) (*StorageV2DeleteObjectResponse, error)
- func (UnimplementedStorageV2Server) HeadObject(context.Context, *StorageV2HeadObjectRequest) (*StorageV2HeadObjectResponse, error)
- func (UnimplementedStorageV2Server) Init(context.Context, *StorageV2InitRequest) (*StorageV2InitResponse, error)
- func (UnimplementedStorageV2Server) ListObjects(*StorageV2ListObjectsRequest, StorageV2_ListObjectsServer) error
- func (UnimplementedStorageV2Server) ReadObject(*StorageV2ReadObjectRequest, StorageV2_ReadObjectServer) error
- func (UnimplementedStorageV2Server) WriteObject(StorageV2_WriteObjectServer) error
- type UnsafeStorageV2Server
Constants ¶
const BufferSize = 4094
const (
Name = "storage.v2"
)
Variables ¶
var File_integrations_storage_v2_definition_storage_proto protoreflect.FileDescriptor
var StorageV2_ServiceDesc = grpc.ServiceDesc{ ServiceName: "storage.StorageV2", HandlerType: (*StorageV2Server)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Init", Handler: _StorageV2_Init_Handler, }, { MethodName: "HeadObject", Handler: _StorageV2_HeadObject_Handler, }, { MethodName: "DeleteObject", Handler: _StorageV2_DeleteObject_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "ReadObject", Handler: _StorageV2_ReadObject_Handler, ServerStreams: true, }, { StreamName: "WriteObject", Handler: _StorageV2_WriteObject_Handler, ClientStreams: true, }, { StreamName: "ListObjects", Handler: _StorageV2_ListObjects_Handler, ServerStreams: true, }, }, Metadata: "integrations/storage/v2/definition/storage.proto", }
StorageV2_ServiceDesc is the grpc.ServiceDesc for StorageV2 service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterStorageV2Server ¶
func RegisterStorageV2Server(s grpc.ServiceRegistrar, srv StorageV2Server)
Types ¶
type StorageV2Client ¶
type StorageV2Client interface { // Allows to init the Storage settings (like bucket creation) Init(ctx context.Context, in *StorageV2InitRequest, opts ...grpc.CallOption) (*StorageV2InitResponse, error) // Allows to Read Objects using stream ReadObject(ctx context.Context, in *StorageV2ReadObjectRequest, opts ...grpc.CallOption) (StorageV2_ReadObjectClient, error) // Allows to Write Objects using stream WriteObject(ctx context.Context, opts ...grpc.CallOption) (StorageV2_WriteObjectClient, error) // Gets basic info about object HeadObject(ctx context.Context, in *StorageV2HeadObjectRequest, opts ...grpc.CallOption) (*StorageV2HeadObjectResponse, error) // Deletes object DeleteObject(ctx context.Context, in *StorageV2DeleteObjectRequest, opts ...grpc.CallOption) (*StorageV2DeleteObjectResponse, error) // List all objects in batches ListObjects(ctx context.Context, in *StorageV2ListObjectsRequest, opts ...grpc.CallOption) (StorageV2_ListObjectsClient, error) }
StorageV2Client is the client API for StorageV2 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 NewStorageV2Client ¶
func NewStorageV2Client(cc grpc.ClientConnInterface) StorageV2Client
type StorageV2DeleteObjectRequest ¶
type StorageV2DeleteObjectRequest struct { // Defines Object Path/Key Path *StorageV2Path `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` // contains filtered or unexported fields }
StorageV2 DeleteObject Request
func (*StorageV2DeleteObjectRequest) Descriptor
deprecated
func (*StorageV2DeleteObjectRequest) Descriptor() ([]byte, []int)
Deprecated: Use StorageV2DeleteObjectRequest.ProtoReflect.Descriptor instead.
func (*StorageV2DeleteObjectRequest) GetPath ¶
func (x *StorageV2DeleteObjectRequest) GetPath() *StorageV2Path
func (*StorageV2DeleteObjectRequest) ProtoMessage ¶
func (*StorageV2DeleteObjectRequest) ProtoMessage()
func (*StorageV2DeleteObjectRequest) ProtoReflect ¶
func (x *StorageV2DeleteObjectRequest) ProtoReflect() protoreflect.Message
func (*StorageV2DeleteObjectRequest) Reset ¶
func (x *StorageV2DeleteObjectRequest) Reset()
func (*StorageV2DeleteObjectRequest) String ¶
func (x *StorageV2DeleteObjectRequest) String() string
type StorageV2DeleteObjectResponse ¶
type StorageV2DeleteObjectResponse struct {
// contains filtered or unexported fields
}
StorageV2 DeleteObject Response
func (*StorageV2DeleteObjectResponse) Descriptor
deprecated
func (*StorageV2DeleteObjectResponse) Descriptor() ([]byte, []int)
Deprecated: Use StorageV2DeleteObjectResponse.ProtoReflect.Descriptor instead.
func (*StorageV2DeleteObjectResponse) ProtoMessage ¶
func (*StorageV2DeleteObjectResponse) ProtoMessage()
func (*StorageV2DeleteObjectResponse) ProtoReflect ¶
func (x *StorageV2DeleteObjectResponse) ProtoReflect() protoreflect.Message
func (*StorageV2DeleteObjectResponse) Reset ¶
func (x *StorageV2DeleteObjectResponse) Reset()
func (*StorageV2DeleteObjectResponse) String ¶
func (x *StorageV2DeleteObjectResponse) String() string
type StorageV2HeadObjectRequest ¶
type StorageV2HeadObjectRequest struct { // Defines Object Path/Key Path *StorageV2Path `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` // contains filtered or unexported fields }
StorageV2 HeadObject Request
func (*StorageV2HeadObjectRequest) Descriptor
deprecated
func (*StorageV2HeadObjectRequest) Descriptor() ([]byte, []int)
Deprecated: Use StorageV2HeadObjectRequest.ProtoReflect.Descriptor instead.
func (*StorageV2HeadObjectRequest) GetPath ¶
func (x *StorageV2HeadObjectRequest) GetPath() *StorageV2Path
func (*StorageV2HeadObjectRequest) ProtoMessage ¶
func (*StorageV2HeadObjectRequest) ProtoMessage()
func (*StorageV2HeadObjectRequest) ProtoReflect ¶
func (x *StorageV2HeadObjectRequest) ProtoReflect() protoreflect.Message
func (*StorageV2HeadObjectRequest) Reset ¶
func (x *StorageV2HeadObjectRequest) Reset()
func (*StorageV2HeadObjectRequest) String ¶
func (x *StorageV2HeadObjectRequest) String() string
type StorageV2HeadObjectResponse ¶
type StorageV2HeadObjectResponse struct { // Defines Object Info Info *StorageV2ObjectInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"` // contains filtered or unexported fields }
StorageV2 HeadObject Response
func (*StorageV2HeadObjectResponse) Descriptor
deprecated
func (*StorageV2HeadObjectResponse) Descriptor() ([]byte, []int)
Deprecated: Use StorageV2HeadObjectResponse.ProtoReflect.Descriptor instead.
func (*StorageV2HeadObjectResponse) GetInfo ¶
func (x *StorageV2HeadObjectResponse) GetInfo() *StorageV2ObjectInfo
func (*StorageV2HeadObjectResponse) ProtoMessage ¶
func (*StorageV2HeadObjectResponse) ProtoMessage()
func (*StorageV2HeadObjectResponse) ProtoReflect ¶
func (x *StorageV2HeadObjectResponse) ProtoReflect() protoreflect.Message
func (*StorageV2HeadObjectResponse) Reset ¶
func (x *StorageV2HeadObjectResponse) Reset()
func (*StorageV2HeadObjectResponse) String ¶
func (x *StorageV2HeadObjectResponse) String() string
type StorageV2InitRequest ¶
type StorageV2InitRequest struct { // Defines if required resources should be created Create *bool `protobuf:"varint,1,opt,name=create,proto3,oneof" json:"create,omitempty"` // contains filtered or unexported fields }
StorageV2 Init Request
func (*StorageV2InitRequest) Descriptor
deprecated
func (*StorageV2InitRequest) Descriptor() ([]byte, []int)
Deprecated: Use StorageV2InitRequest.ProtoReflect.Descriptor instead.
func (*StorageV2InitRequest) GetCreate ¶
func (x *StorageV2InitRequest) GetCreate() bool
func (*StorageV2InitRequest) ProtoMessage ¶
func (*StorageV2InitRequest) ProtoMessage()
func (*StorageV2InitRequest) ProtoReflect ¶
func (x *StorageV2InitRequest) ProtoReflect() protoreflect.Message
func (*StorageV2InitRequest) Reset ¶
func (x *StorageV2InitRequest) Reset()
func (*StorageV2InitRequest) String ¶
func (x *StorageV2InitRequest) String() string
type StorageV2InitResponse ¶
type StorageV2InitResponse struct {
// contains filtered or unexported fields
}
StorageV2 Init Response
func (*StorageV2InitResponse) Descriptor
deprecated
func (*StorageV2InitResponse) Descriptor() ([]byte, []int)
Deprecated: Use StorageV2InitResponse.ProtoReflect.Descriptor instead.
func (*StorageV2InitResponse) ProtoMessage ¶
func (*StorageV2InitResponse) ProtoMessage()
func (*StorageV2InitResponse) ProtoReflect ¶
func (x *StorageV2InitResponse) ProtoReflect() protoreflect.Message
func (*StorageV2InitResponse) Reset ¶
func (x *StorageV2InitResponse) Reset()
func (*StorageV2InitResponse) String ¶
func (x *StorageV2InitResponse) String() string
type StorageV2ListObjectsRequest ¶
type StorageV2ListObjectsRequest struct { // Defines Object Path/Key Path *StorageV2Path `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` // contains filtered or unexported fields }
StorageV2 ListObjects Request
func (*StorageV2ListObjectsRequest) Descriptor
deprecated
func (*StorageV2ListObjectsRequest) Descriptor() ([]byte, []int)
Deprecated: Use StorageV2ListObjectsRequest.ProtoReflect.Descriptor instead.
func (*StorageV2ListObjectsRequest) GetPath ¶
func (x *StorageV2ListObjectsRequest) GetPath() *StorageV2Path
func (*StorageV2ListObjectsRequest) ProtoMessage ¶
func (*StorageV2ListObjectsRequest) ProtoMessage()
func (*StorageV2ListObjectsRequest) ProtoReflect ¶
func (x *StorageV2ListObjectsRequest) ProtoReflect() protoreflect.Message
func (*StorageV2ListObjectsRequest) Reset ¶
func (x *StorageV2ListObjectsRequest) Reset()
func (*StorageV2ListObjectsRequest) String ¶
func (x *StorageV2ListObjectsRequest) String() string
type StorageV2ListObjectsResponse ¶
type StorageV2ListObjectsResponse struct { // List of the objects Files []*StorageV2Object `protobuf:"bytes,1,rep,name=files,proto3" json:"files,omitempty"` // contains filtered or unexported fields }
StorageV2 ListObjects Response
func (*StorageV2ListObjectsResponse) Descriptor
deprecated
func (*StorageV2ListObjectsResponse) Descriptor() ([]byte, []int)
Deprecated: Use StorageV2ListObjectsResponse.ProtoReflect.Descriptor instead.
func (*StorageV2ListObjectsResponse) GetFiles ¶
func (x *StorageV2ListObjectsResponse) GetFiles() []*StorageV2Object
func (*StorageV2ListObjectsResponse) ProtoMessage ¶
func (*StorageV2ListObjectsResponse) ProtoMessage()
func (*StorageV2ListObjectsResponse) ProtoReflect ¶
func (x *StorageV2ListObjectsResponse) ProtoReflect() protoreflect.Message
func (*StorageV2ListObjectsResponse) Reset ¶
func (x *StorageV2ListObjectsResponse) Reset()
func (*StorageV2ListObjectsResponse) String ¶
func (x *StorageV2ListObjectsResponse) String() string
type StorageV2Object ¶
type StorageV2Object struct { // Defines Object Path/Key Path *StorageV2Path `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` // Defines Object Info Info *StorageV2ObjectInfo `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"` // contains filtered or unexported fields }
Defines Object Details
func List ¶
func List(ctx context.Context, client StorageV2Client, prefix string) ([]*StorageV2Object, error)
func (*StorageV2Object) Descriptor
deprecated
func (*StorageV2Object) Descriptor() ([]byte, []int)
Deprecated: Use StorageV2Object.ProtoReflect.Descriptor instead.
func (*StorageV2Object) GetInfo ¶
func (x *StorageV2Object) GetInfo() *StorageV2ObjectInfo
func (*StorageV2Object) GetPath ¶
func (x *StorageV2Object) GetPath() *StorageV2Path
func (*StorageV2Object) ProtoMessage ¶
func (*StorageV2Object) ProtoMessage()
func (*StorageV2Object) ProtoReflect ¶
func (x *StorageV2Object) ProtoReflect() protoreflect.Message
func (*StorageV2Object) Reset ¶
func (x *StorageV2Object) Reset()
func (*StorageV2Object) String ¶
func (x *StorageV2Object) String() string
type StorageV2ObjectInfo ¶
type StorageV2ObjectInfo struct { // Size in bytes of the object Size uint64 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"` // Timestamp of last update LastUpdated *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=last_updated,json=lastUpdated,proto3" json:"last_updated,omitempty"` // contains filtered or unexported fields }
Defines Object Info
func (*StorageV2ObjectInfo) Descriptor
deprecated
func (*StorageV2ObjectInfo) Descriptor() ([]byte, []int)
Deprecated: Use StorageV2ObjectInfo.ProtoReflect.Descriptor instead.
func (*StorageV2ObjectInfo) GetLastUpdated ¶
func (x *StorageV2ObjectInfo) GetLastUpdated() *timestamppb.Timestamp
func (*StorageV2ObjectInfo) GetSize ¶
func (x *StorageV2ObjectInfo) GetSize() uint64
func (*StorageV2ObjectInfo) ProtoMessage ¶
func (*StorageV2ObjectInfo) ProtoMessage()
func (*StorageV2ObjectInfo) ProtoReflect ¶
func (x *StorageV2ObjectInfo) ProtoReflect() protoreflect.Message
func (*StorageV2ObjectInfo) Reset ¶
func (x *StorageV2ObjectInfo) Reset()
func (*StorageV2ObjectInfo) String ¶
func (x *StorageV2ObjectInfo) String() string
type StorageV2Path ¶
type StorageV2Path struct { // Defines Object Path/Key Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` // contains filtered or unexported fields }
Defines Object Path/Key
func (*StorageV2Path) Descriptor
deprecated
func (*StorageV2Path) Descriptor() ([]byte, []int)
Deprecated: Use StorageV2Path.ProtoReflect.Descriptor instead.
func (*StorageV2Path) GetPath ¶
func (x *StorageV2Path) GetPath() string
func (*StorageV2Path) ProtoMessage ¶
func (*StorageV2Path) ProtoMessage()
func (*StorageV2Path) ProtoReflect ¶
func (x *StorageV2Path) ProtoReflect() protoreflect.Message
func (*StorageV2Path) Reset ¶
func (x *StorageV2Path) Reset()
func (*StorageV2Path) String ¶
func (x *StorageV2Path) String() string
type StorageV2ReadObjectRequest ¶
type StorageV2ReadObjectRequest struct { // Defines Object Path/Key Path *StorageV2Path `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` // contains filtered or unexported fields }
StorageV2 ReadObject Request
func (*StorageV2ReadObjectRequest) Descriptor
deprecated
func (*StorageV2ReadObjectRequest) Descriptor() ([]byte, []int)
Deprecated: Use StorageV2ReadObjectRequest.ProtoReflect.Descriptor instead.
func (*StorageV2ReadObjectRequest) GetPath ¶
func (x *StorageV2ReadObjectRequest) GetPath() *StorageV2Path
func (*StorageV2ReadObjectRequest) ProtoMessage ¶
func (*StorageV2ReadObjectRequest) ProtoMessage()
func (*StorageV2ReadObjectRequest) ProtoReflect ¶
func (x *StorageV2ReadObjectRequest) ProtoReflect() protoreflect.Message
func (*StorageV2ReadObjectRequest) Reset ¶
func (x *StorageV2ReadObjectRequest) Reset()
func (*StorageV2ReadObjectRequest) String ¶
func (x *StorageV2ReadObjectRequest) String() string
type StorageV2ReadObjectResponse ¶
type StorageV2ReadObjectResponse struct { // Bytes of the object Chunk []byte `protobuf:"bytes,1,opt,name=chunk,proto3" json:"chunk,omitempty"` // contains filtered or unexported fields }
StorageV2 ReadObject Response
func (*StorageV2ReadObjectResponse) Descriptor
deprecated
func (*StorageV2ReadObjectResponse) Descriptor() ([]byte, []int)
Deprecated: Use StorageV2ReadObjectResponse.ProtoReflect.Descriptor instead.
func (*StorageV2ReadObjectResponse) GetChunk ¶
func (x *StorageV2ReadObjectResponse) GetChunk() []byte
func (*StorageV2ReadObjectResponse) ProtoMessage ¶
func (*StorageV2ReadObjectResponse) ProtoMessage()
func (*StorageV2ReadObjectResponse) ProtoReflect ¶
func (x *StorageV2ReadObjectResponse) ProtoReflect() protoreflect.Message
func (*StorageV2ReadObjectResponse) Reset ¶
func (x *StorageV2ReadObjectResponse) Reset()
func (*StorageV2ReadObjectResponse) String ¶
func (x *StorageV2ReadObjectResponse) String() string
type StorageV2Server ¶
type StorageV2Server interface { // Allows to init the Storage settings (like bucket creation) Init(context.Context, *StorageV2InitRequest) (*StorageV2InitResponse, error) // Allows to Read Objects using stream ReadObject(*StorageV2ReadObjectRequest, StorageV2_ReadObjectServer) error // Allows to Write Objects using stream WriteObject(StorageV2_WriteObjectServer) error // Gets basic info about object HeadObject(context.Context, *StorageV2HeadObjectRequest) (*StorageV2HeadObjectResponse, error) // Deletes object DeleteObject(context.Context, *StorageV2DeleteObjectRequest) (*StorageV2DeleteObjectResponse, error) // List all objects in batches ListObjects(*StorageV2ListObjectsRequest, StorageV2_ListObjectsServer) error // contains filtered or unexported methods }
StorageV2Server is the server API for StorageV2 service. All implementations must embed UnimplementedStorageV2Server for forward compatibility
type StorageV2WriteObjectRequest ¶
type StorageV2WriteObjectRequest struct { // Defines Object Path/Key Path *StorageV2Path `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` // Bytes of the object Chunk []byte `protobuf:"bytes,2,opt,name=chunk,proto3" json:"chunk,omitempty"` // contains filtered or unexported fields }
StorageV2 WriteObject Request
func (*StorageV2WriteObjectRequest) Descriptor
deprecated
func (*StorageV2WriteObjectRequest) Descriptor() ([]byte, []int)
Deprecated: Use StorageV2WriteObjectRequest.ProtoReflect.Descriptor instead.
func (*StorageV2WriteObjectRequest) GetChunk ¶
func (x *StorageV2WriteObjectRequest) GetChunk() []byte
func (*StorageV2WriteObjectRequest) GetPath ¶
func (x *StorageV2WriteObjectRequest) GetPath() *StorageV2Path
func (*StorageV2WriteObjectRequest) ProtoMessage ¶
func (*StorageV2WriteObjectRequest) ProtoMessage()
func (*StorageV2WriteObjectRequest) ProtoReflect ¶
func (x *StorageV2WriteObjectRequest) ProtoReflect() protoreflect.Message
func (*StorageV2WriteObjectRequest) Reset ¶
func (x *StorageV2WriteObjectRequest) Reset()
func (*StorageV2WriteObjectRequest) String ¶
func (x *StorageV2WriteObjectRequest) String() string
type StorageV2WriteObjectResponse ¶
type StorageV2WriteObjectResponse struct { // Bytes Saved Bytes int64 `protobuf:"varint,1,opt,name=bytes,proto3" json:"bytes,omitempty"` // Checksum (sha256) of the object Checksum string `protobuf:"bytes,2,opt,name=checksum,proto3" json:"checksum,omitempty"` // contains filtered or unexported fields }
StorageV2 WriteObject Response
func Send ¶
func Send(ctx context.Context, client StorageV2Client, key string, in io.Reader) (*StorageV2WriteObjectResponse, error)
func (*StorageV2WriteObjectResponse) Descriptor
deprecated
func (*StorageV2WriteObjectResponse) Descriptor() ([]byte, []int)
Deprecated: Use StorageV2WriteObjectResponse.ProtoReflect.Descriptor instead.
func (*StorageV2WriteObjectResponse) GetBytes ¶
func (x *StorageV2WriteObjectResponse) GetBytes() int64
func (*StorageV2WriteObjectResponse) GetChecksum ¶
func (x *StorageV2WriteObjectResponse) GetChecksum() string
func (*StorageV2WriteObjectResponse) ProtoMessage ¶
func (*StorageV2WriteObjectResponse) ProtoMessage()
func (*StorageV2WriteObjectResponse) ProtoReflect ¶
func (x *StorageV2WriteObjectResponse) ProtoReflect() protoreflect.Message
func (*StorageV2WriteObjectResponse) Reset ¶
func (x *StorageV2WriteObjectResponse) Reset()
func (*StorageV2WriteObjectResponse) String ¶
func (x *StorageV2WriteObjectResponse) String() string
type StorageV2_ListObjectsClient ¶
type StorageV2_ListObjectsClient interface { Recv() (*StorageV2ListObjectsResponse, error) grpc.ClientStream }
type StorageV2_ListObjectsServer ¶
type StorageV2_ListObjectsServer interface { Send(*StorageV2ListObjectsResponse) error grpc.ServerStream }
type StorageV2_ReadObjectClient ¶
type StorageV2_ReadObjectClient interface { Recv() (*StorageV2ReadObjectResponse, error) grpc.ClientStream }
type StorageV2_ReadObjectServer ¶
type StorageV2_ReadObjectServer interface { Send(*StorageV2ReadObjectResponse) error grpc.ServerStream }
type StorageV2_WriteObjectClient ¶
type StorageV2_WriteObjectClient interface { Send(*StorageV2WriteObjectRequest) error CloseAndRecv() (*StorageV2WriteObjectResponse, error) grpc.ClientStream }
type StorageV2_WriteObjectServer ¶
type StorageV2_WriteObjectServer interface { SendAndClose(*StorageV2WriteObjectResponse) error Recv() (*StorageV2WriteObjectRequest, error) grpc.ServerStream }
type UnimplementedStorageV2Server ¶
type UnimplementedStorageV2Server struct { }
UnimplementedStorageV2Server must be embedded to have forward compatible implementations.
func (UnimplementedStorageV2Server) DeleteObject ¶
func (UnimplementedStorageV2Server) DeleteObject(context.Context, *StorageV2DeleteObjectRequest) (*StorageV2DeleteObjectResponse, error)
func (UnimplementedStorageV2Server) HeadObject ¶
func (UnimplementedStorageV2Server) HeadObject(context.Context, *StorageV2HeadObjectRequest) (*StorageV2HeadObjectResponse, error)
func (UnimplementedStorageV2Server) Init ¶
func (UnimplementedStorageV2Server) Init(context.Context, *StorageV2InitRequest) (*StorageV2InitResponse, error)
func (UnimplementedStorageV2Server) ListObjects ¶
func (UnimplementedStorageV2Server) ListObjects(*StorageV2ListObjectsRequest, StorageV2_ListObjectsServer) error
func (UnimplementedStorageV2Server) ReadObject ¶
func (UnimplementedStorageV2Server) ReadObject(*StorageV2ReadObjectRequest, StorageV2_ReadObjectServer) error
func (UnimplementedStorageV2Server) WriteObject ¶
func (UnimplementedStorageV2Server) WriteObject(StorageV2_WriteObjectServer) error
type UnsafeStorageV2Server ¶
type UnsafeStorageV2Server interface {
// contains filtered or unexported methods
}
UnsafeStorageV2Server may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StorageV2Server will result in compilation errors.