Documentation ¶
Overview ¶
Package bucketservice/v1 contains the integration API of Bucket service.
Index ¶
- Constants
- Variables
- func RegisterBucketServiceServer(s *grpc.Server, srv BucketServiceServer)
- type BucketRequest
- func (*BucketRequest) Descriptor() ([]byte, []int)
- func (m *BucketRequest) GetTags() []*v1.KeyValuePair
- func (m *BucketRequest) Marshal() (dAtA []byte, err error)
- func (m *BucketRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *BucketRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*BucketRequest) ProtoMessage()
- func (m *BucketRequest) Reset()
- func (m *BucketRequest) Size() (n int)
- func (m *BucketRequest) String() string
- func (m *BucketRequest) Unmarshal(dAtA []byte) error
- func (m *BucketRequest) XXX_DiscardUnknown()
- func (m *BucketRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BucketRequest) XXX_Merge(src proto.Message)
- func (m *BucketRequest) XXX_Size() int
- func (m *BucketRequest) XXX_Unmarshal(b []byte) error
- type BucketServiceClient
- type BucketServiceServer
- type BucketService_ReadObjectClient
- type BucketService_ReadObjectServer
- type BucketService_WriteObjectClient
- type BucketService_WriteObjectServer
- type ObjectInfo
- func (*ObjectInfo) Descriptor() ([]byte, []int)
- func (m *ObjectInfo) GetIsLocked() bool
- func (m *ObjectInfo) GetLastUpdatedAt() *types.Timestamp
- func (m *ObjectInfo) GetSizeInBytes() uint64
- func (m *ObjectInfo) Marshal() (dAtA []byte, err error)
- func (m *ObjectInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *ObjectInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ObjectInfo) ProtoMessage()
- func (m *ObjectInfo) Reset()
- func (m *ObjectInfo) Size() (n int)
- func (m *ObjectInfo) String() string
- func (m *ObjectInfo) Unmarshal(dAtA []byte) error
- func (m *ObjectInfo) XXX_DiscardUnknown()
- func (m *ObjectInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ObjectInfo) XXX_Merge(src proto.Message)
- func (m *ObjectInfo) XXX_Size() int
- func (m *ObjectInfo) XXX_Unmarshal(b []byte) error
- type PathRequest
- func (*PathRequest) Descriptor() ([]byte, []int)
- func (m *PathRequest) GetPath() string
- func (m *PathRequest) Marshal() (dAtA []byte, err error)
- func (m *PathRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *PathRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PathRequest) ProtoMessage()
- func (m *PathRequest) Reset()
- func (m *PathRequest) Size() (n int)
- func (m *PathRequest) String() string
- func (m *PathRequest) Unmarshal(dAtA []byte) error
- func (m *PathRequest) XXX_DiscardUnknown()
- func (m *PathRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PathRequest) XXX_Merge(src proto.Message)
- func (m *PathRequest) XXX_Size() int
- func (m *PathRequest) XXX_Unmarshal(b []byte) error
- type PathSize
- func (*PathSize) Descriptor() ([]byte, []int)
- func (m *PathSize) GetNumberOfFiles() uint32
- func (m *PathSize) GetNumberOfFolders() uint32
- func (m *PathSize) GetSizeInBytes() uint64
- func (m *PathSize) Marshal() (dAtA []byte, err error)
- func (m *PathSize) MarshalTo(dAtA []byte) (int, error)
- func (m *PathSize) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PathSize) ProtoMessage()
- func (m *PathSize) Reset()
- func (m *PathSize) Size() (n int)
- func (m *PathSize) String() string
- func (m *PathSize) Unmarshal(dAtA []byte) error
- func (m *PathSize) XXX_DiscardUnknown()
- func (m *PathSize) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PathSize) XXX_Merge(src proto.Message)
- func (m *PathSize) XXX_Size() int
- func (m *PathSize) XXX_Unmarshal(b []byte) error
- type ReadObjectChunk
- func (*ReadObjectChunk) Descriptor() ([]byte, []int)
- func (m *ReadObjectChunk) GetChunk() []byte
- func (m *ReadObjectChunk) Marshal() (dAtA []byte, err error)
- func (m *ReadObjectChunk) MarshalTo(dAtA []byte) (int, error)
- func (m *ReadObjectChunk) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReadObjectChunk) ProtoMessage()
- func (m *ReadObjectChunk) Reset()
- func (m *ReadObjectChunk) Size() (n int)
- func (m *ReadObjectChunk) String() string
- func (m *ReadObjectChunk) Unmarshal(dAtA []byte) error
- func (m *ReadObjectChunk) XXX_DiscardUnknown()
- func (m *ReadObjectChunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReadObjectChunk) XXX_Merge(src proto.Message)
- func (m *ReadObjectChunk) XXX_Size() int
- func (m *ReadObjectChunk) XXX_Unmarshal(b []byte) error
- type RepositoryURL
- func (*RepositoryURL) Descriptor() ([]byte, []int)
- func (m *RepositoryURL) GetBucketPath() string
- func (m *RepositoryURL) GetUrl() string
- func (m *RepositoryURL) Marshal() (dAtA []byte, err error)
- func (m *RepositoryURL) MarshalTo(dAtA []byte) (int, error)
- func (m *RepositoryURL) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RepositoryURL) ProtoMessage()
- func (m *RepositoryURL) Reset()
- func (m *RepositoryURL) Size() (n int)
- func (m *RepositoryURL) String() string
- func (m *RepositoryURL) Unmarshal(dAtA []byte) error
- func (m *RepositoryURL) XXX_DiscardUnknown()
- func (m *RepositoryURL) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RepositoryURL) XXX_Merge(src proto.Message)
- func (m *RepositoryURL) XXX_Size() int
- func (m *RepositoryURL) XXX_Unmarshal(b []byte) error
- type UnimplementedBucketServiceServer
- func (*UnimplementedBucketServiceServer) BucketExists(ctx context.Context, req *BucketRequest) (*v11.YesOrNo, error)
- func (*UnimplementedBucketServiceServer) CreateBucket(ctx context.Context, req *BucketRequest) (*v11.Empty, error)
- func (*UnimplementedBucketServiceServer) DeleteBucket(ctx context.Context, req *BucketRequest) (*v11.Empty, error)
- func (*UnimplementedBucketServiceServer) DeletePath(ctx context.Context, req *PathRequest) (*v11.Empty, error)
- func (*UnimplementedBucketServiceServer) GetAPIVersion(ctx context.Context, req *v11.Empty) (*v11.Version, error)
- func (*UnimplementedBucketServiceServer) GetObjectInfo(ctx context.Context, req *PathRequest) (*ObjectInfo, error)
- func (*UnimplementedBucketServiceServer) GetPathSize(ctx context.Context, req *PathRequest) (*PathSize, error)
- func (*UnimplementedBucketServiceServer) GetRepositoryURL(ctx context.Context, req *PathRequest) (*RepositoryURL, error)
- func (*UnimplementedBucketServiceServer) ReadObject(req *PathRequest, srv BucketService_ReadObjectServer) error
- func (*UnimplementedBucketServiceServer) WriteObject(srv BucketService_WriteObjectServer) error
- type WriteObjectChunk
- func (*WriteObjectChunk) Descriptor() ([]byte, []int)
- func (m *WriteObjectChunk) GetChunk() []byte
- func (m *WriteObjectChunk) GetHasMore() bool
- func (m *WriteObjectChunk) GetPath() *PathRequest
- func (m *WriteObjectChunk) Marshal() (dAtA []byte, err error)
- func (m *WriteObjectChunk) MarshalTo(dAtA []byte) (int, error)
- func (m *WriteObjectChunk) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WriteObjectChunk) ProtoMessage()
- func (m *WriteObjectChunk) Reset()
- func (m *WriteObjectChunk) Size() (n int)
- func (m *WriteObjectChunk) String() string
- func (m *WriteObjectChunk) Unmarshal(dAtA []byte) error
- func (m *WriteObjectChunk) XXX_DiscardUnknown()
- func (m *WriteObjectChunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WriteObjectChunk) XXX_Merge(src proto.Message)
- func (m *WriteObjectChunk) XXX_Size() int
- func (m *WriteObjectChunk) XXX_Unmarshal(b []byte) error
- type WriteObjectControl
- func (*WriteObjectControl) Descriptor() ([]byte, []int)
- func (m *WriteObjectControl) GetAllowMoreOutput() bool
- func (m *WriteObjectControl) GetMaxChunkBytes() int32
- func (m *WriteObjectControl) Marshal() (dAtA []byte, err error)
- func (m *WriteObjectControl) MarshalTo(dAtA []byte) (int, error)
- func (m *WriteObjectControl) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WriteObjectControl) ProtoMessage()
- func (m *WriteObjectControl) Reset()
- func (m *WriteObjectControl) Size() (n int)
- func (m *WriteObjectControl) String() string
- func (m *WriteObjectControl) Unmarshal(dAtA []byte) error
- func (m *WriteObjectControl) XXX_DiscardUnknown()
- func (m *WriteObjectControl) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WriteObjectControl) XXX_Merge(src proto.Message)
- func (m *WriteObjectControl) XXX_Size() int
- func (m *WriteObjectControl) XXX_Unmarshal(b []byte) error
Constants ¶
const ( // PermissionBucketServiceBucketExists is needed to checks if the specified bucket exists PermissionBucketServiceBucketExists = "bucketservice.bucket.exists" // PermissionBucketServiceBucketCreate is needed to create a bucket PermissionBucketServiceBucketCreate = "bucketservice.bucket.create" // PermissionBucketServiceBucketDelete is needed to delete a bucket PermissionBucketServiceBucketDelete = "bucketservice.bucket.delete" )
const ( // PermissionBucketServiceBucketPathGetRepositoryURL is needed to get the URL needed to store/delete objects in a bucket PermissionBucketServiceBucketPathGetRepositoryURL = "bucketservice.bucketpath.get-repository-url" // PermissionBucketServiceBucketPathDelete is needed to delete the specified path (recursively) from the provided bucket PermissionBucketServiceBucketPathDelete = "bucketservice.bucketpath.delete" // PermissionBucketServiceBucketPathGetSize is needed to get the size of a certain path in a bucket PermissionBucketServiceBucketPathGetSize = "bucketservice.bucketpath.get-size" )
const ( // PermissionBucketServiceBucketObjectRead is needed to read an object from a bucket PermissionBucketServiceBucketObjectRead = "bucketservice.bucketobject.read" // PermissionBucketServiceBucketObjectWrite is needed to write an object in a bucket PermissionBucketServiceBucketObjectWrite = "bucketservice.bucketobject.write" // PermissionBucketServiceBucketObjectGetInfo is needed to get the information of an object in a bucket PermissionBucketServiceBucketObjectGetInfo = "bucketservice.bucketobject.get-info" )
const ( // APIIDBucketService contains identifier of this API APIIDBucketService = "bucketservice/v1" // APIMajorVersion contains major version of this API APIMajorVersion = 1 // APIMinorVersion contains minor version of this API APIMinorVersion = 0 // APIPatchVersion contains patch version of this API APIPatchVersion = 0 )
Variables ¶
Functions ¶
func RegisterBucketServiceServer ¶
func RegisterBucketServiceServer(s *grpc.Server, srv BucketServiceServer)
Types ¶
type BucketRequest ¶
type BucketRequest struct { // Key-value pairs stored at the providers (as labels/tags) during CreateBucket Tags []*v1.KeyValuePair `protobuf:"bytes,10,rep,name=tags,proto3" json:"tags,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Request params for Bucket related calls
func (*BucketRequest) Descriptor ¶
func (*BucketRequest) Descriptor() ([]byte, []int)
func (*BucketRequest) GetTags ¶
func (m *BucketRequest) GetTags() []*v1.KeyValuePair
func (*BucketRequest) Marshal ¶
func (m *BucketRequest) Marshal() (dAtA []byte, err error)
func (*BucketRequest) MarshalToSizedBuffer ¶
func (m *BucketRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*BucketRequest) ProtoMessage ¶
func (*BucketRequest) ProtoMessage()
func (*BucketRequest) Reset ¶
func (m *BucketRequest) Reset()
func (*BucketRequest) Size ¶
func (m *BucketRequest) Size() (n int)
func (*BucketRequest) String ¶
func (m *BucketRequest) String() string
func (*BucketRequest) Unmarshal ¶
func (m *BucketRequest) Unmarshal(dAtA []byte) error
func (*BucketRequest) XXX_DiscardUnknown ¶
func (m *BucketRequest) XXX_DiscardUnknown()
func (*BucketRequest) XXX_Marshal ¶
func (m *BucketRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BucketRequest) XXX_Merge ¶
func (m *BucketRequest) XXX_Merge(src proto.Message)
func (*BucketRequest) XXX_Size ¶
func (m *BucketRequest) XXX_Size() int
func (*BucketRequest) XXX_Unmarshal ¶
func (m *BucketRequest) XXX_Unmarshal(b []byte) error
type BucketServiceClient ¶
type BucketServiceClient interface { // Get the current API version of this service. // Required permissions: // - None GetAPIVersion(ctx context.Context, in *v11.Empty, opts ...grpc.CallOption) (*v11.Version, error) // BucketExists checks if the specified bucket exists // Required permissions: // - bucketservice.bucket.exists globally BucketExists(ctx context.Context, in *BucketRequest, opts ...grpc.CallOption) (*v11.YesOrNo, error) // CreateBucket creates a bucket // Required permissions: // - bucketservice.bucket.create globally CreateBucket(ctx context.Context, in *BucketRequest, opts ...grpc.CallOption) (*v11.Empty, error) // DeleteBucket deletes a bucket // Notice that this deletes all data contained in the bucket as well // Required permissions: // - bucketservice.bucket.delete globally DeleteBucket(ctx context.Context, in *BucketRequest, opts ...grpc.CallOption) (*v11.Empty, error) // GetRepositoryURL get the URL needed to store/delete objects in a bucket // Required permissions: // - bucketservice.bucketpath.get-repository-url globally GetRepositoryURL(ctx context.Context, in *PathRequest, opts ...grpc.CallOption) (*RepositoryURL, error) // DeletePath deletes the specified path (recursively) from the provided bucket // Required permissions: // - bucketservice.bucketpath.delete globally DeletePath(ctx context.Context, in *PathRequest, opts ...grpc.CallOption) (*v11.Empty, error) // GetPathSize provides the size in bytes for the specified path from the provided bucket // Required permissions: // - bucketservice.bucketpath.get-size globally GetPathSize(ctx context.Context, in *PathRequest, opts ...grpc.CallOption) (*PathSize, error) // ReadObject opens an object in the bucket and streams the existing data from the object into the client // Required permissions: // - bucketservice.bucketobject.read globally ReadObject(ctx context.Context, in *PathRequest, opts ...grpc.CallOption) (BucketService_ReadObjectClient, error) // CreateObject creates or opens an object in the bucket and allows the client to stream (additional) data into the object // Required permissions: // - bucketservice.bucketobject.write globally WriteObject(ctx context.Context, opts ...grpc.CallOption) (BucketService_WriteObjectClient, error) // GetObjectInfo provides information for the specified object from the provided bucket // A Not-Found error is returned if the object cannot be found // Required permissions: // - bucketservice.bucketobject.get-info globally GetObjectInfo(ctx context.Context, in *PathRequest, opts ...grpc.CallOption) (*ObjectInfo, error) }
BucketServiceClient is the client API for BucketService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewBucketServiceClient ¶
func NewBucketServiceClient(cc *grpc.ClientConn) BucketServiceClient
type BucketServiceServer ¶
type BucketServiceServer interface { // Get the current API version of this service. // Required permissions: // - None GetAPIVersion(context.Context, *v11.Empty) (*v11.Version, error) // BucketExists checks if the specified bucket exists // Required permissions: // - bucketservice.bucket.exists globally BucketExists(context.Context, *BucketRequest) (*v11.YesOrNo, error) // CreateBucket creates a bucket // Required permissions: // - bucketservice.bucket.create globally CreateBucket(context.Context, *BucketRequest) (*v11.Empty, error) // DeleteBucket deletes a bucket // Notice that this deletes all data contained in the bucket as well // Required permissions: // - bucketservice.bucket.delete globally DeleteBucket(context.Context, *BucketRequest) (*v11.Empty, error) // GetRepositoryURL get the URL needed to store/delete objects in a bucket // Required permissions: // - bucketservice.bucketpath.get-repository-url globally GetRepositoryURL(context.Context, *PathRequest) (*RepositoryURL, error) // DeletePath deletes the specified path (recursively) from the provided bucket // Required permissions: // - bucketservice.bucketpath.delete globally DeletePath(context.Context, *PathRequest) (*v11.Empty, error) // GetPathSize provides the size in bytes for the specified path from the provided bucket // Required permissions: // - bucketservice.bucketpath.get-size globally GetPathSize(context.Context, *PathRequest) (*PathSize, error) // ReadObject opens an object in the bucket and streams the existing data from the object into the client // Required permissions: // - bucketservice.bucketobject.read globally ReadObject(*PathRequest, BucketService_ReadObjectServer) error // CreateObject creates or opens an object in the bucket and allows the client to stream (additional) data into the object // Required permissions: // - bucketservice.bucketobject.write globally WriteObject(BucketService_WriteObjectServer) error // GetObjectInfo provides information for the specified object from the provided bucket // A Not-Found error is returned if the object cannot be found // Required permissions: // - bucketservice.bucketobject.get-info globally GetObjectInfo(context.Context, *PathRequest) (*ObjectInfo, error) }
BucketServiceServer is the server API for BucketService service.
type BucketService_ReadObjectClient ¶
type BucketService_ReadObjectClient interface { Recv() (*ReadObjectChunk, error) grpc.ClientStream }
type BucketService_ReadObjectServer ¶
type BucketService_ReadObjectServer interface { Send(*ReadObjectChunk) error grpc.ServerStream }
type BucketService_WriteObjectClient ¶
type BucketService_WriteObjectClient interface { Send(*WriteObjectChunk) error Recv() (*WriteObjectControl, error) grpc.ClientStream }
type BucketService_WriteObjectServer ¶
type BucketService_WriteObjectServer interface { Send(*WriteObjectControl) error Recv() (*WriteObjectChunk, error) grpc.ServerStream }
type ObjectInfo ¶
type ObjectInfo struct { // Indicates if the object is locked IsLocked bool `protobuf:"varint,1,opt,name=is_locked,json=isLocked,proto3" json:"is_locked,omitempty"` // Indicates the size of the object in bytes SizeInBytes uint64 `protobuf:"varint,2,opt,name=size_in_bytes,json=sizeInBytes,proto3" json:"size_in_bytes,omitempty"` // The timestamp this object has last been modified LastUpdatedAt *types.Timestamp `protobuf:"bytes,3,opt,name=last_updated_at,json=lastUpdatedAt,proto3" json:"last_updated_at,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Response from GetObjectInfo request
func (*ObjectInfo) Descriptor ¶
func (*ObjectInfo) Descriptor() ([]byte, []int)
func (*ObjectInfo) GetIsLocked ¶
func (m *ObjectInfo) GetIsLocked() bool
func (*ObjectInfo) GetLastUpdatedAt ¶
func (m *ObjectInfo) GetLastUpdatedAt() *types.Timestamp
func (*ObjectInfo) GetSizeInBytes ¶
func (m *ObjectInfo) GetSizeInBytes() uint64
func (*ObjectInfo) Marshal ¶
func (m *ObjectInfo) Marshal() (dAtA []byte, err error)
func (*ObjectInfo) MarshalToSizedBuffer ¶
func (m *ObjectInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ObjectInfo) ProtoMessage ¶
func (*ObjectInfo) ProtoMessage()
func (*ObjectInfo) Reset ¶
func (m *ObjectInfo) Reset()
func (*ObjectInfo) Size ¶
func (m *ObjectInfo) Size() (n int)
func (*ObjectInfo) String ¶
func (m *ObjectInfo) String() string
func (*ObjectInfo) Unmarshal ¶
func (m *ObjectInfo) Unmarshal(dAtA []byte) error
func (*ObjectInfo) XXX_DiscardUnknown ¶
func (m *ObjectInfo) XXX_DiscardUnknown()
func (*ObjectInfo) XXX_Marshal ¶
func (m *ObjectInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ObjectInfo) XXX_Merge ¶
func (m *ObjectInfo) XXX_Merge(src proto.Message)
func (*ObjectInfo) XXX_Size ¶
func (m *ObjectInfo) XXX_Size() int
func (*ObjectInfo) XXX_Unmarshal ¶
func (m *ObjectInfo) XXX_Unmarshal(b []byte) error
type PathRequest ¶
type PathRequest struct { // The path (Specify as "." to indicate the root folder) Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Request params for Path related requests
func (*PathRequest) Descriptor ¶
func (*PathRequest) Descriptor() ([]byte, []int)
func (*PathRequest) GetPath ¶
func (m *PathRequest) GetPath() string
func (*PathRequest) Marshal ¶
func (m *PathRequest) Marshal() (dAtA []byte, err error)
func (*PathRequest) MarshalToSizedBuffer ¶
func (m *PathRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PathRequest) ProtoMessage ¶
func (*PathRequest) ProtoMessage()
func (*PathRequest) Reset ¶
func (m *PathRequest) Reset()
func (*PathRequest) Size ¶
func (m *PathRequest) Size() (n int)
func (*PathRequest) String ¶
func (m *PathRequest) String() string
func (*PathRequest) Unmarshal ¶
func (m *PathRequest) Unmarshal(dAtA []byte) error
func (*PathRequest) XXX_DiscardUnknown ¶
func (m *PathRequest) XXX_DiscardUnknown()
func (*PathRequest) XXX_Marshal ¶
func (m *PathRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PathRequest) XXX_Merge ¶
func (m *PathRequest) XXX_Merge(src proto.Message)
func (*PathRequest) XXX_Size ¶
func (m *PathRequest) XXX_Size() int
func (*PathRequest) XXX_Unmarshal ¶
func (m *PathRequest) XXX_Unmarshal(b []byte) error
type PathSize ¶
type PathSize struct { // The size in bytes SizeInBytes uint64 `protobuf:"varint,1,opt,name=size_in_bytes,json=sizeInBytes,proto3" json:"size_in_bytes,omitempty"` // Number of files NumberOfFiles uint32 `protobuf:"varint,2,opt,name=number_of_files,json=numberOfFiles,proto3" json:"number_of_files,omitempty"` // Number of folders NumberOfFolders uint32 `protobuf:"varint,3,opt,name=number_of_folders,json=numberOfFolders,proto3" json:"number_of_folders,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Response from GetPathSize request
func (*PathSize) Descriptor ¶
func (*PathSize) GetNumberOfFiles ¶
func (*PathSize) GetNumberOfFolders ¶
func (*PathSize) GetSizeInBytes ¶
func (*PathSize) MarshalToSizedBuffer ¶
func (*PathSize) ProtoMessage ¶
func (*PathSize) ProtoMessage()
func (*PathSize) XXX_DiscardUnknown ¶
func (m *PathSize) XXX_DiscardUnknown()
func (*PathSize) XXX_Marshal ¶
func (*PathSize) XXX_Unmarshal ¶
type ReadObjectChunk ¶
type ReadObjectChunk struct { // Raw output Chunk []byte `protobuf:"bytes,1,opt,name=chunk,proto3" json:"chunk,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Output message for ReadObject.
func (*ReadObjectChunk) Descriptor ¶
func (*ReadObjectChunk) Descriptor() ([]byte, []int)
func (*ReadObjectChunk) GetChunk ¶
func (m *ReadObjectChunk) GetChunk() []byte
func (*ReadObjectChunk) Marshal ¶
func (m *ReadObjectChunk) Marshal() (dAtA []byte, err error)
func (*ReadObjectChunk) MarshalToSizedBuffer ¶
func (m *ReadObjectChunk) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReadObjectChunk) ProtoMessage ¶
func (*ReadObjectChunk) ProtoMessage()
func (*ReadObjectChunk) Reset ¶
func (m *ReadObjectChunk) Reset()
func (*ReadObjectChunk) Size ¶
func (m *ReadObjectChunk) Size() (n int)
func (*ReadObjectChunk) String ¶
func (m *ReadObjectChunk) String() string
func (*ReadObjectChunk) Unmarshal ¶
func (m *ReadObjectChunk) Unmarshal(dAtA []byte) error
func (*ReadObjectChunk) XXX_DiscardUnknown ¶
func (m *ReadObjectChunk) XXX_DiscardUnknown()
func (*ReadObjectChunk) XXX_Marshal ¶
func (m *ReadObjectChunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReadObjectChunk) XXX_Merge ¶
func (m *ReadObjectChunk) XXX_Merge(src proto.Message)
func (*ReadObjectChunk) XXX_Size ¶
func (m *ReadObjectChunk) XXX_Size() int
func (*ReadObjectChunk) XXX_Unmarshal ¶
func (m *ReadObjectChunk) XXX_Unmarshal(b []byte) error
type RepositoryURL ¶
type RepositoryURL struct { // The URL Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"` // The URL without provider information BucketPath string `protobuf:"bytes,2,opt,name=bucket_path,json=bucketPath,proto3" json:"bucket_path,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Response from GetRepositoryURL request
func (*RepositoryURL) Descriptor ¶
func (*RepositoryURL) Descriptor() ([]byte, []int)
func (*RepositoryURL) GetBucketPath ¶
func (m *RepositoryURL) GetBucketPath() string
func (*RepositoryURL) GetUrl ¶
func (m *RepositoryURL) GetUrl() string
func (*RepositoryURL) Marshal ¶
func (m *RepositoryURL) Marshal() (dAtA []byte, err error)
func (*RepositoryURL) MarshalToSizedBuffer ¶
func (m *RepositoryURL) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RepositoryURL) ProtoMessage ¶
func (*RepositoryURL) ProtoMessage()
func (*RepositoryURL) Reset ¶
func (m *RepositoryURL) Reset()
func (*RepositoryURL) Size ¶
func (m *RepositoryURL) Size() (n int)
func (*RepositoryURL) String ¶
func (m *RepositoryURL) String() string
func (*RepositoryURL) Unmarshal ¶
func (m *RepositoryURL) Unmarshal(dAtA []byte) error
func (*RepositoryURL) XXX_DiscardUnknown ¶
func (m *RepositoryURL) XXX_DiscardUnknown()
func (*RepositoryURL) XXX_Marshal ¶
func (m *RepositoryURL) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RepositoryURL) XXX_Merge ¶
func (m *RepositoryURL) XXX_Merge(src proto.Message)
func (*RepositoryURL) XXX_Size ¶
func (m *RepositoryURL) XXX_Size() int
func (*RepositoryURL) XXX_Unmarshal ¶
func (m *RepositoryURL) XXX_Unmarshal(b []byte) error
type UnimplementedBucketServiceServer ¶
type UnimplementedBucketServiceServer struct { }
UnimplementedBucketServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedBucketServiceServer) BucketExists ¶
func (*UnimplementedBucketServiceServer) BucketExists(ctx context.Context, req *BucketRequest) (*v11.YesOrNo, error)
func (*UnimplementedBucketServiceServer) CreateBucket ¶
func (*UnimplementedBucketServiceServer) CreateBucket(ctx context.Context, req *BucketRequest) (*v11.Empty, error)
func (*UnimplementedBucketServiceServer) DeleteBucket ¶
func (*UnimplementedBucketServiceServer) DeleteBucket(ctx context.Context, req *BucketRequest) (*v11.Empty, error)
func (*UnimplementedBucketServiceServer) DeletePath ¶
func (*UnimplementedBucketServiceServer) DeletePath(ctx context.Context, req *PathRequest) (*v11.Empty, error)
func (*UnimplementedBucketServiceServer) GetAPIVersion ¶
func (*UnimplementedBucketServiceServer) GetObjectInfo ¶
func (*UnimplementedBucketServiceServer) GetObjectInfo(ctx context.Context, req *PathRequest) (*ObjectInfo, error)
func (*UnimplementedBucketServiceServer) GetPathSize ¶
func (*UnimplementedBucketServiceServer) GetPathSize(ctx context.Context, req *PathRequest) (*PathSize, error)
func (*UnimplementedBucketServiceServer) GetRepositoryURL ¶
func (*UnimplementedBucketServiceServer) GetRepositoryURL(ctx context.Context, req *PathRequest) (*RepositoryURL, error)
func (*UnimplementedBucketServiceServer) ReadObject ¶
func (*UnimplementedBucketServiceServer) ReadObject(req *PathRequest, srv BucketService_ReadObjectServer) error
func (*UnimplementedBucketServiceServer) WriteObject ¶
func (*UnimplementedBucketServiceServer) WriteObject(srv BucketService_WriteObjectServer) error
type WriteObjectChunk ¶
type WriteObjectChunk struct { // Base request params for Path related requests. // This field cannot change during the stream. Path *PathRequest `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` // Raw input Chunk []byte `protobuf:"bytes,2,opt,name=chunk,proto3" json:"chunk,omitempty"` // If set, the caller wants to send a next message with more input data. // If not set, no more control message will be sent. HasMore bool `protobuf:"varint,3,opt,name=has_more,json=hasMore,proto3" json:"has_more,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Input message for WriteObject
func (*WriteObjectChunk) Descriptor ¶
func (*WriteObjectChunk) Descriptor() ([]byte, []int)
func (*WriteObjectChunk) GetChunk ¶
func (m *WriteObjectChunk) GetChunk() []byte
func (*WriteObjectChunk) GetHasMore ¶
func (m *WriteObjectChunk) GetHasMore() bool
func (*WriteObjectChunk) GetPath ¶
func (m *WriteObjectChunk) GetPath() *PathRequest
func (*WriteObjectChunk) Marshal ¶
func (m *WriteObjectChunk) Marshal() (dAtA []byte, err error)
func (*WriteObjectChunk) MarshalToSizedBuffer ¶
func (m *WriteObjectChunk) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*WriteObjectChunk) ProtoMessage ¶
func (*WriteObjectChunk) ProtoMessage()
func (*WriteObjectChunk) Reset ¶
func (m *WriteObjectChunk) Reset()
func (*WriteObjectChunk) Size ¶
func (m *WriteObjectChunk) Size() (n int)
func (*WriteObjectChunk) String ¶
func (m *WriteObjectChunk) String() string
func (*WriteObjectChunk) Unmarshal ¶
func (m *WriteObjectChunk) Unmarshal(dAtA []byte) error
func (*WriteObjectChunk) XXX_DiscardUnknown ¶
func (m *WriteObjectChunk) XXX_DiscardUnknown()
func (*WriteObjectChunk) XXX_Marshal ¶
func (m *WriteObjectChunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WriteObjectChunk) XXX_Merge ¶
func (m *WriteObjectChunk) XXX_Merge(src proto.Message)
func (*WriteObjectChunk) XXX_Size ¶
func (m *WriteObjectChunk) XXX_Size() int
func (*WriteObjectChunk) XXX_Unmarshal ¶
func (m *WriteObjectChunk) XXX_Unmarshal(b []byte) error
type WriteObjectControl ¶
type WriteObjectControl struct { // If set, the next chunk of input is allowed. // If unset, the caller is expected to terminate the call. AllowMoreOutput bool `protobuf:"varint,1,opt,name=allow_more_output,json=allowMoreOutput,proto3" json:"allow_more_output,omitempty"` // Maximum number of bytes the caller is allowed to send in the next input chunk. MaxChunkBytes int32 `protobuf:"varint,2,opt,name=max_chunk_bytes,json=maxChunkBytes,proto3" json:"max_chunk_bytes,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Output message for WriteObject
func (*WriteObjectControl) Descriptor ¶
func (*WriteObjectControl) Descriptor() ([]byte, []int)
func (*WriteObjectControl) GetAllowMoreOutput ¶
func (m *WriteObjectControl) GetAllowMoreOutput() bool
func (*WriteObjectControl) GetMaxChunkBytes ¶
func (m *WriteObjectControl) GetMaxChunkBytes() int32
func (*WriteObjectControl) Marshal ¶
func (m *WriteObjectControl) Marshal() (dAtA []byte, err error)
func (*WriteObjectControl) MarshalTo ¶
func (m *WriteObjectControl) MarshalTo(dAtA []byte) (int, error)
func (*WriteObjectControl) MarshalToSizedBuffer ¶
func (m *WriteObjectControl) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*WriteObjectControl) ProtoMessage ¶
func (*WriteObjectControl) ProtoMessage()
func (*WriteObjectControl) Reset ¶
func (m *WriteObjectControl) Reset()
func (*WriteObjectControl) Size ¶
func (m *WriteObjectControl) Size() (n int)
func (*WriteObjectControl) String ¶
func (m *WriteObjectControl) String() string
func (*WriteObjectControl) Unmarshal ¶
func (m *WriteObjectControl) Unmarshal(dAtA []byte) error
func (*WriteObjectControl) XXX_DiscardUnknown ¶
func (m *WriteObjectControl) XXX_DiscardUnknown()
func (*WriteObjectControl) XXX_Marshal ¶
func (m *WriteObjectControl) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WriteObjectControl) XXX_Merge ¶
func (m *WriteObjectControl) XXX_Merge(src proto.Message)
func (*WriteObjectControl) XXX_Size ¶
func (m *WriteObjectControl) XXX_Size() int
func (*WriteObjectControl) XXX_Unmarshal ¶
func (m *WriteObjectControl) XXX_Unmarshal(b []byte) error