v1

package

Go to main page

Versions in this module

v0

v0.2.1

Dec 13, 2024

v0.2.0

Dec 13, 2024

Changes in this version

+ var File_bucketservice_proto protoreflect.FileDescriptor

type BucketRequest

+ func (x *BucketRequest) ProtoReflect() protoreflect.Message

type ObjectInfo

+ func (x *ObjectInfo) ProtoReflect() protoreflect.Message

type PathRequest

+ func (x *PathRequest) ProtoReflect() protoreflect.Message

type PathSize

+ func (x *PathSize) ProtoReflect() protoreflect.Message

type ReadObjectChunk

+ func (x *ReadObjectChunk) ProtoReflect() protoreflect.Message

type RepositoryURL

+ func (x *RepositoryURL) ProtoReflect() protoreflect.Message

type WriteObjectChunk

+ func (x *WriteObjectChunk) ProtoReflect() protoreflect.Message

type WriteObjectControl

+ func (x *WriteObjectControl) ProtoReflect() protoreflect.Message

v0.1.1

Nov 7, 2023

v0.1.0

Sep 7, 2023

v0.0.2

Mar 23, 2023

Changes in this version

+ const PermissionBucketServiceBucketPathGetRepositoryURL

v0.0.1

Mar 21, 2023

Changes in this version

+ const APIIDBucketService

+ const APIMajorVersion

+ const APIMinorVersion

+ const APIPatchVersion

+ const PermissionBucketServiceBackupPathGetRepositoryURL

+ const PermissionBucketServiceBucketCreate

+ const PermissionBucketServiceBucketDelete

+ const PermissionBucketServiceBucketExists

+ const PermissionBucketServiceBucketObjectGetInfo

+ const PermissionBucketServiceBucketObjectRead

+ const PermissionBucketServiceBucketObjectWrite

+ const PermissionBucketServiceBucketPathDelete

+ const PermissionBucketServiceBucketPathGetSize

+ var ErrIntOverflowBucketservice = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthBucketservice = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupBucketservice = fmt.Errorf("proto: unexpected end of group")

+ var ServiceProfileBucketService = icommon.ServiceProfile

+ func RegisterBucketServiceServer(s *grpc.Server, srv BucketServiceServer)

+ type BucketRequest struct

+ Tags []*v1.KeyValuePair

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BucketRequest) Descriptor() ([]byte, []int)

+ func (*BucketRequest) ProtoMessage()

+ 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 (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 interface

+ BucketExists func(ctx context.Context, in *BucketRequest, opts ...grpc.CallOption) (*v11.YesOrNo, error)

+ CreateBucket func(ctx context.Context, in *BucketRequest, opts ...grpc.CallOption) (*v11.Empty, error)

+ DeleteBucket func(ctx context.Context, in *BucketRequest, opts ...grpc.CallOption) (*v11.Empty, error)

+ DeletePath func(ctx context.Context, in *PathRequest, opts ...grpc.CallOption) (*v11.Empty, error)

+ GetAPIVersion func(ctx context.Context, in *v11.Empty, opts ...grpc.CallOption) (*v11.Version, error)

+ GetObjectInfo func(ctx context.Context, in *PathRequest, opts ...grpc.CallOption) (*ObjectInfo, error)

+ GetPathSize func(ctx context.Context, in *PathRequest, opts ...grpc.CallOption) (*PathSize, error)

+ GetRepositoryURL func(ctx context.Context, in *PathRequest, opts ...grpc.CallOption) (*RepositoryURL, error)

+ ReadObject func(ctx context.Context, in *PathRequest, opts ...grpc.CallOption) (BucketService_ReadObjectClient, error)

+ WriteObject func(ctx context.Context, opts ...grpc.CallOption) (BucketService_WriteObjectClient, error)

+ func NewBucketServiceClient(cc *grpc.ClientConn) BucketServiceClient

+ type BucketServiceServer interface

+ BucketExists func(context.Context, *BucketRequest) (*v11.YesOrNo, error)

+ CreateBucket func(context.Context, *BucketRequest) (*v11.Empty, error)

+ DeleteBucket func(context.Context, *BucketRequest) (*v11.Empty, error)

+ DeletePath func(context.Context, *PathRequest) (*v11.Empty, error)

+ GetAPIVersion func(context.Context, *v11.Empty) (*v11.Version, error)

+ GetObjectInfo func(context.Context, *PathRequest) (*ObjectInfo, error)

+ GetPathSize func(context.Context, *PathRequest) (*PathSize, error)

+ GetRepositoryURL func(context.Context, *PathRequest) (*RepositoryURL, error)

+ ReadObject func(*PathRequest, BucketService_ReadObjectServer) error

+ WriteObject func(BucketService_WriteObjectServer) error

+ type BucketService_ReadObjectClient interface

+ Recv func() (*ReadObjectChunk, error)

+ type BucketService_ReadObjectServer interface

+ Send func(*ReadObjectChunk) error

+ type BucketService_WriteObjectClient interface

+ Recv func() (*WriteObjectControl, error)

+ Send func(*WriteObjectChunk) error

+ type BucketService_WriteObjectServer interface

+ Recv func() (*WriteObjectChunk, error)

+ Send func(*WriteObjectControl) error

+ type ObjectInfo struct

+ IsLocked bool

+ LastUpdatedAt *types.Timestamp

+ SizeInBytes uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ObjectInfo) Descriptor() ([]byte, []int)

+ func (*ObjectInfo) ProtoMessage()

+ 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 (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 struct

+ Path string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PathRequest) Descriptor() ([]byte, []int)

+ func (*PathRequest) ProtoMessage()

+ 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 (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 struct

+ NumberOfFiles uint32

+ NumberOfFolders uint32

+ SizeInBytes uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PathSize) Descriptor() ([]byte, []int)

+ func (*PathSize) ProtoMessage()

+ 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 (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 struct

+ Chunk []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReadObjectChunk) Descriptor() ([]byte, []int)

+ func (*ReadObjectChunk) ProtoMessage()

+ 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 (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 struct

+ BucketPath string

+ Url string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RepositoryURL) Descriptor() ([]byte, []int)

+ func (*RepositoryURL) ProtoMessage()

+ 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 (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 struct

+ 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 struct

+ Chunk []byte

+ HasMore bool

+ Path *PathRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WriteObjectChunk) Descriptor() ([]byte, []int)

+ func (*WriteObjectChunk) ProtoMessage()

+ 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 (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 struct

+ AllowMoreOutput bool

+ MaxChunkBytes int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WriteObjectControl) Descriptor() ([]byte, []int)

+ func (*WriteObjectControl) ProtoMessage()

+ 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 (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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL