v1

package
v0.1.1 Latest Latest
Warning

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

Go to latest
Published: Nov 7, 2023 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Overview

Package bucketservice/v1 contains the integration API of Bucket service.

Index

Constants

View Source
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"
)
View Source
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"
)
View Source
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"
)
View Source
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

View Source
var (
	ErrInvalidLengthBucketservice        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBucketservice          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupBucketservice = fmt.Errorf("proto: unexpected end of group")
)

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) MarshalTo

func (m *BucketRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo

func (m *ObjectInfo) MarshalTo(dAtA []byte) (int, 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) MarshalTo

func (m *PathRequest) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*PathSize) GetNumberOfFiles

func (m *PathSize) GetNumberOfFiles() uint32

func (*PathSize) GetNumberOfFolders

func (m *PathSize) GetNumberOfFolders() uint32

func (*PathSize) GetSizeInBytes

func (m *PathSize) GetSizeInBytes() uint64

func (*PathSize) Marshal

func (m *PathSize) Marshal() (dAtA []byte, err error)

func (*PathSize) MarshalTo

func (m *PathSize) MarshalTo(dAtA []byte) (int, error)

func (*PathSize) MarshalToSizedBuffer

func (m *PathSize) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PathSize) ProtoMessage

func (*PathSize) ProtoMessage()

func (*PathSize) Reset

func (m *PathSize) Reset()

func (*PathSize) Size

func (m *PathSize) Size() (n int)

func (*PathSize) String

func (m *PathSize) String() string

func (*PathSize) Unmarshal

func (m *PathSize) Unmarshal(dAtA []byte) error

func (*PathSize) XXX_DiscardUnknown

func (m *PathSize) XXX_DiscardUnknown()

func (*PathSize) XXX_Marshal

func (m *PathSize) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PathSize) XXX_Merge

func (m *PathSize) XXX_Merge(src proto.Message)

func (*PathSize) XXX_Size

func (m *PathSize) XXX_Size() int

func (*PathSize) XXX_Unmarshal

func (m *PathSize) XXX_Unmarshal(b []byte) error

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) MarshalTo

func (m *ReadObjectChunk) MarshalTo(dAtA []byte) (int, 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) MarshalTo

func (m *RepositoryURL) MarshalTo(dAtA []byte) (int, 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) CreateBucket

func (*UnimplementedBucketServiceServer) DeleteBucket

func (*UnimplementedBucketServiceServer) DeletePath

func (*UnimplementedBucketServiceServer) GetAPIVersion

func (*UnimplementedBucketServiceServer) GetAPIVersion(ctx context.Context, req *v11.Empty) (*v11.Version, error)

func (*UnimplementedBucketServiceServer) GetObjectInfo

func (*UnimplementedBucketServiceServer) GetPathSize

func (*UnimplementedBucketServiceServer) GetRepositoryURL

func (*UnimplementedBucketServiceServer) ReadObject

func (*UnimplementedBucketServiceServer) WriteObject

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) MarshalTo

func (m *WriteObjectChunk) MarshalTo(dAtA []byte) (int, 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

Jump to

Keyboard shortcuts

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