Documentation ¶
Index ¶
- type GcpAdapter
- func (ad *GcpAdapter) AbortMultipartUpload(multipartUpload *pb.MultipartUpload, context context.Context) S3Error
- func (ad *GcpAdapter) CompleteMultipartUpload(multipartUpload *pb.MultipartUpload, ...) (*model.CompleteMultipartUploadResult, S3Error)
- func (ad *GcpAdapter) DELETE(object *pb.DeleteObjectInput, ctx context.Context) S3Error
- func (ad *GcpAdapter) GET(object *pb.Object, context context.Context, start int64, end int64) (io.ReadCloser, S3Error)
- func (ad *GcpAdapter) GetObjectInfo(bucketName string, key string, context context.Context) (*pb.Object, S3Error)
- func (ad *GcpAdapter) InitMultipartUpload(object *pb.Object, context context.Context) (*pb.MultipartUpload, S3Error)
- func (ad *GcpAdapter) ListParts(listParts *pb.ListParts, context context.Context) (*model.ListPartsOutput, S3Error)
- func (ad *GcpAdapter) PUT(stream io.Reader, object *pb.Object, ctx context.Context) S3Error
- func (ad *GcpAdapter) UploadPart(stream io.Reader, multipartUpload *pb.MultipartUpload, partNumber int64, ...) (*model.UploadPartResult, S3Error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GcpAdapter ¶
type GcpAdapter struct {
// contains filtered or unexported fields
}
func Init ¶
func Init(backend *backendpb.BackendDetail) *GcpAdapter
func (*GcpAdapter) AbortMultipartUpload ¶
func (ad *GcpAdapter) AbortMultipartUpload(multipartUpload *pb.MultipartUpload, context context.Context) S3Error
func (*GcpAdapter) CompleteMultipartUpload ¶
func (ad *GcpAdapter) CompleteMultipartUpload(multipartUpload *pb.MultipartUpload, completeUpload *model.CompleteMultipartUpload, context context.Context) (*model.CompleteMultipartUploadResult, S3Error)
func (*GcpAdapter) DELETE ¶
func (ad *GcpAdapter) DELETE(object *pb.DeleteObjectInput, ctx context.Context) S3Error
func (*GcpAdapter) GET ¶
func (ad *GcpAdapter) GET(object *pb.Object, context context.Context, start int64, end int64) (io.ReadCloser, S3Error)
func (*GcpAdapter) GetObjectInfo ¶
func (*GcpAdapter) InitMultipartUpload ¶
func (ad *GcpAdapter) InitMultipartUpload(object *pb.Object, context context.Context) (*pb.MultipartUpload, S3Error)
func (*GcpAdapter) ListParts ¶
func (ad *GcpAdapter) ListParts(listParts *pb.ListParts, context context.Context) (*model.ListPartsOutput, S3Error)
func (*GcpAdapter) UploadPart ¶
func (ad *GcpAdapter) UploadPart(stream io.Reader, multipartUpload *pb.MultipartUpload, partNumber int64, upBytes int64, context context.Context) (*model.UploadPartResult, S3Error)
Click to show internal directories.
Click to hide internal directories.