s3.micro.go

// Code generated by protoc-gen-micro. DO NOT EDIT.
// source: s3.proto

/*
Package s3 is a generated protocol buffer package.

It is generated from these files:
	s3.proto

It has these top-level messages:
	ListObjectPartsRequest
	ListObjectPartsResponse
	AbortMultipartRequest
	CompletePart
	CompleteMultipartRequest
	CompleteMultipartResponse
	InitMultiPartRequest
	InitMultiPartResponse
	PutDataStream
	UploadPartRequest
	UploadPartResponse
	CopyObjectRequest
	CopyObjectResponse
	MoveObjectRequest
	MoveObjectResponse
	PutObjectRequest
	GetObjectResponse
	GetObjectMetaResult
	PutObjectResponse
	PutBucketACLRequest
	BucketACL
	BucketVersioning
	ObjACL
	PutObjACLRequest
	BaseBucketRequest
	BaseObjRequest
	CopyObjPartRequest
	CopyObjPartResponse
	ServerSideEncryption
	RedirectAllRequestsTo
	Redirect
	Condition
	RoutingRules
	WebsiteConfiguration
	CORSConfiguration
	Destination
	ReplicationRole
	ReplicationConfiguration
	Tag
	LifecycleFilter
	Action
	AbortMultipartUpload
	LifecycleRule
	PutBucketLifecycleRequest
	GetBucketLifecycleResponse
	ReplicationInfo
	Acl
	GetBucketResponse
	Bucket
	Partion
	Version
	Object
	ListBucketsResponse
	BaseResponse
	BaseRequest
	ListObjectsRequest
	ListObjectsResponse
	CountObjectsResponse
	DeleteObjectInput
	DeleteObjectOutput
	GetObjectInput
	MultipartUpload
	ListParts
	TList
	Tier2ClassName
	GetTierMapResponse
	UpdateObjMetaRequest
	StorageClass
	GetStorageClassesResponse
	GetBackendTypeByTierRequest
	GetBackendTypeByTierResponse
	MultipartUploadRecord
	ListBucketUploadRequest
	Owner
	Upload
	ListBucketUploadResult
	ListBucketUploadResponse
*/
package s3

import proto "github.com/golang/protobuf/proto"
import fmt "fmt"
import math "math"

import (
	client "github.com/micro/go-micro/client"
	server "github.com/micro/go-micro/server"
	context "context"
)

// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf

// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package

// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
var _ client.Option
var _ server.Option

// Client API for S3 service

type S3Service interface {
	ListBuckets(ctx context.Context, in *BaseRequest, opts ...client.CallOption) (*ListBucketsResponse, error)
	CreateBucket(ctx context.Context, in *Bucket, opts ...client.CallOption) (*BaseResponse, error)
	DeleteBucket(ctx context.Context, in *Bucket, opts ...client.CallOption) (*BaseResponse, error)
	GetBucket(ctx context.Context, in *Bucket, opts ...client.CallOption) (*GetBucketResponse, error)
	GetObjectMeta(ctx context.Context, in *Object, opts ...client.CallOption) (*GetObjectMetaResult, error)
	UpdateObjectMeta(ctx context.Context, in *Object, opts ...client.CallOption) (*PutObjectResponse, error)
	ListObjects(ctx context.Context, in *ListObjectsRequest, opts ...client.CallOption) (*ListObjectsResponse, error)
	CountObjects(ctx context.Context, in *ListObjectsRequest, opts ...client.CallOption) (*CountObjectsResponse, error)
	PutObject(ctx context.Context, opts ...client.CallOption) (S3_PutObjectService, error)
	UpdateObject(ctx context.Context, in *Object, opts ...client.CallOption) (*BaseResponse, error)
	GetObject(ctx context.Context, in *GetObjectInput, opts ...client.CallOption) (S3_GetObjectService, error)
	DeleteObject(ctx context.Context, in *DeleteObjectInput, opts ...client.CallOption) (*DeleteObjectOutput, error)
	GetTierMap(ctx context.Context, in *BaseRequest, opts ...client.CallOption) (*GetTierMapResponse, error)
	UpdateObjMeta(ctx context.Context, in *UpdateObjMetaRequest, opts ...client.CallOption) (*BaseResponse, error)
	GetStorageClasses(ctx context.Context, in *BaseRequest, opts ...client.CallOption) (*GetStorageClassesResponse, error)
	GetBackendTypeByTier(ctx context.Context, in *GetBackendTypeByTierRequest, opts ...client.CallOption) (*GetBackendTypeByTierResponse, error)
	DeleteBucketLifecycle(ctx context.Context, in *BaseRequest, opts ...client.CallOption) (*BaseResponse, error)
	PutBucketLifecycle(ctx context.Context, in *PutBucketLifecycleRequest, opts ...client.CallOption) (*BaseResponse, error)
	GetBucketLifecycle(ctx context.Context, in *BaseRequest, opts ...client.CallOption) (*GetBucketLifecycleResponse, error)
	ListBucketLifecycle(ctx context.Context, in *BaseRequest, opts ...client.CallOption) (*ListBucketsResponse, error)
	UpdateBucket(ctx context.Context, in *Bucket, opts ...client.CallOption) (*BaseResponse, error)
	ListBucketUploadRecords(ctx context.Context, in *ListBucketUploadRequest, opts ...client.CallOption) (*ListBucketUploadResponse, error)
	InitMultipartUpload(ctx context.Context, in *InitMultiPartRequest, opts ...client.CallOption) (*InitMultiPartResponse, error)
	AbortMultipartUpload(ctx context.Context, in *AbortMultipartRequest, opts ...client.CallOption) (*BaseResponse, error)
	CompleteMultipartUpload(ctx context.Context, in *CompleteMultipartRequest, opts ...client.CallOption) (*CompleteMultipartResponse, error)
	UploadPart(ctx context.Context, opts ...client.CallOption) (S3_UploadPartService, error)
	ListObjectParts(ctx context.Context, in *ListObjectPartsRequest, opts ...client.CallOption) (*ListObjectPartsResponse, error)
	AppendObject(ctx context.Context, in *BaseRequest, opts ...client.CallOption) (*BaseResponse, error)
	PostObject(ctx context.Context, in *BaseRequest, opts ...client.CallOption) (*BaseResponse, error)
	// For lifecycle, may need some change.
	AddUploadRecord(ctx context.Context, in *MultipartUploadRecord, opts ...client.CallOption) (*BaseResponse, error)
	DeleteUploadRecord(ctx context.Context, in *MultipartUploadRecord, opts ...client.CallOption) (*BaseResponse, error)
	HeadObject(ctx context.Context, in *BaseObjRequest, opts ...client.CallOption) (*Object, error)
	MoveObject(ctx context.Context, in *MoveObjectRequest, opts ...client.CallOption) (*MoveObjectResponse, error)
	CopyObject(ctx context.Context, in *CopyObjectRequest, opts ...client.CallOption) (*CopyObjectResponse, error)
	CopyObjPart(ctx context.Context, in *CopyObjPartRequest, opts ...client.CallOption) (*CopyObjPartResponse, error)
	PutObjACL(ctx context.Context, in *PutObjACLRequest, opts ...client.CallOption) (*BaseResponse, error)
	GetObjACL(ctx context.Context, in *BaseObjRequest, opts ...client.CallOption) (*ObjACL, error)
	GetBucketLocation(ctx context.Context, in *BaseRequest, opts ...client.CallOption) (*BaseResponse, error)
	GetBucketVersioning(ctx context.Context, in *BaseBucketRequest, opts ...client.CallOption) (*BucketVersioning, error)
	PutBucketACL(ctx context.Context, in *PutBucketACLRequest, opts ...client.CallOption) (*BaseResponse, error)
	GetBucketACL(ctx context.Context, in *BaseBucketRequest, opts ...client.CallOption) (*BucketACL, error)
	PutBucketCORS(ctx context.Context, in *BaseRequest, opts ...client.CallOption) (*BaseResponse, error)
	GetBucketCORS(ctx context.Context, in *BaseRequest, opts ...client.CallOption) (*BaseResponse, error)
	DeleteBucketCORS(ctx context.Context, in *BaseRequest, opts ...client.CallOption) (*BaseResponse, error)
	PutBucketPolicy(ctx context.Context, in *BaseRequest, opts ...client.CallOption) (*BaseResponse, error)
	GetBucketPolicy(ctx context.Context, in *BaseRequest, opts ...client.CallOption) (*BaseResponse, error)
	DeleteBucketPolicy(ctx context.Context, in *BaseRequest, opts ...client.CallOption) (*BaseResponse, error)
	HeadBucket(ctx context.Context, in *BaseRequest, opts ...client.CallOption) (*Bucket, error)
}

type s3Service struct {
	c    client.Client
	name string
}

func NewS3Service(name string, c client.Client) S3Service {
	if c == nil {
		c = client.NewClient()
	}
	if len(name) == 0 {
		name = "s3"
	}
	return &s3Service{
		c:    c,
		name: name,
	}
}

func (c *s3Service) ListBuckets(ctx context.Context, in *BaseRequest, opts ...client.CallOption) (*ListBucketsResponse, error) {
	req := c.c.NewRequest(c.name, "S3.ListBuckets", in)
	out := new(ListBucketsResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) CreateBucket(ctx context.Context, in *Bucket, opts ...client.CallOption) (*BaseResponse, error) {
	req := c.c.NewRequest(c.name, "S3.CreateBucket", in)
	out := new(BaseResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) DeleteBucket(ctx context.Context, in *Bucket, opts ...client.CallOption) (*BaseResponse, error) {
	req := c.c.NewRequest(c.name, "S3.DeleteBucket", in)
	out := new(BaseResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) GetBucket(ctx context.Context, in *Bucket, opts ...client.CallOption) (*GetBucketResponse, error) {
	req := c.c.NewRequest(c.name, "S3.GetBucket", in)
	out := new(GetBucketResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) GetObjectMeta(ctx context.Context, in *Object, opts ...client.CallOption) (*GetObjectMetaResult, error) {
	req := c.c.NewRequest(c.name, "S3.GetObjectMeta", in)
	out := new(GetObjectMetaResult)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) UpdateObjectMeta(ctx context.Context, in *Object, opts ...client.CallOption) (*PutObjectResponse, error) {
	req := c.c.NewRequest(c.name, "S3.UpdateObjectMeta", in)
	out := new(PutObjectResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) ListObjects(ctx context.Context, in *ListObjectsRequest, opts ...client.CallOption) (*ListObjectsResponse, error) {
	req := c.c.NewRequest(c.name, "S3.ListObjects", in)
	out := new(ListObjectsResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) CountObjects(ctx context.Context, in *ListObjectsRequest, opts ...client.CallOption) (*CountObjectsResponse, error) {
	req := c.c.NewRequest(c.name, "S3.CountObjects", in)
	out := new(CountObjectsResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) PutObject(ctx context.Context, opts ...client.CallOption) (S3_PutObjectService, error) {
	req := c.c.NewRequest(c.name, "S3.PutObject", &PutDataStream{})
	stream, err := c.c.Stream(ctx, req, opts...)
	if err != nil {
		return nil, err
	}
	return &s3ServicePutObject{stream}, nil
}

type S3_PutObjectService interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*PutDataStream) error
}

type s3ServicePutObject struct {
	stream client.Stream
}

func (x *s3ServicePutObject) Close() error {
	return x.stream.Close()
}

func (x *s3ServicePutObject) SendMsg(m interface{}) error {
	return x.stream.Send(m)
}

func (x *s3ServicePutObject) RecvMsg(m interface{}) error {
	return x.stream.Recv(m)
}

func (x *s3ServicePutObject) Send(m *PutDataStream) error {
	return x.stream.Send(m)
}

func (c *s3Service) UpdateObject(ctx context.Context, in *Object, opts ...client.CallOption) (*BaseResponse, error) {
	req := c.c.NewRequest(c.name, "S3.UpdateObject", in)
	out := new(BaseResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) GetObject(ctx context.Context, in *GetObjectInput, opts ...client.CallOption) (S3_GetObjectService, error) {
	req := c.c.NewRequest(c.name, "S3.GetObject", &GetObjectInput{})
	stream, err := c.c.Stream(ctx, req, opts...)
	if err != nil {
		return nil, err
	}
	if err := stream.Send(in); err != nil {
		return nil, err
	}
	return &s3ServiceGetObject{stream}, nil
}

type S3_GetObjectService interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Recv() (*GetObjectResponse, error)
}

type s3ServiceGetObject struct {
	stream client.Stream
}

func (x *s3ServiceGetObject) Close() error {
	return x.stream.Close()
}

func (x *s3ServiceGetObject) SendMsg(m interface{}) error {
	return x.stream.Send(m)
}

func (x *s3ServiceGetObject) RecvMsg(m interface{}) error {
	return x.stream.Recv(m)
}

func (x *s3ServiceGetObject) Recv() (*GetObjectResponse, error) {
	m := new(GetObjectResponse)
	err := x.stream.Recv(m)
	if err != nil {
		return nil, err
	}
	return m, nil
}

func (c *s3Service) DeleteObject(ctx context.Context, in *DeleteObjectInput, opts ...client.CallOption) (*DeleteObjectOutput, error) {
	req := c.c.NewRequest(c.name, "S3.DeleteObject", in)
	out := new(DeleteObjectOutput)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) GetTierMap(ctx context.Context, in *BaseRequest, opts ...client.CallOption) (*GetTierMapResponse, error) {
	req := c.c.NewRequest(c.name, "S3.GetTierMap", in)
	out := new(GetTierMapResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) UpdateObjMeta(ctx context.Context, in *UpdateObjMetaRequest, opts ...client.CallOption) (*BaseResponse, error) {
	req := c.c.NewRequest(c.name, "S3.UpdateObjMeta", in)
	out := new(BaseResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) GetStorageClasses(ctx context.Context, in *BaseRequest, opts ...client.CallOption) (*GetStorageClassesResponse, error) {
	req := c.c.NewRequest(c.name, "S3.GetStorageClasses", in)
	out := new(GetStorageClassesResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) GetBackendTypeByTier(ctx context.Context, in *GetBackendTypeByTierRequest, opts ...client.CallOption) (*GetBackendTypeByTierResponse, error) {
	req := c.c.NewRequest(c.name, "S3.GetBackendTypeByTier", in)
	out := new(GetBackendTypeByTierResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) DeleteBucketLifecycle(ctx context.Context, in *BaseRequest, opts ...client.CallOption) (*BaseResponse, error) {
	req := c.c.NewRequest(c.name, "S3.DeleteBucketLifecycle", in)
	out := new(BaseResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) PutBucketLifecycle(ctx context.Context, in *PutBucketLifecycleRequest, opts ...client.CallOption) (*BaseResponse, error) {
	req := c.c.NewRequest(c.name, "S3.PutBucketLifecycle", in)
	out := new(BaseResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) GetBucketLifecycle(ctx context.Context, in *BaseRequest, opts ...client.CallOption) (*GetBucketLifecycleResponse, error) {
	req := c.c.NewRequest(c.name, "S3.GetBucketLifecycle", in)
	out := new(GetBucketLifecycleResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) ListBucketLifecycle(ctx context.Context, in *BaseRequest, opts ...client.CallOption) (*ListBucketsResponse, error) {
	req := c.c.NewRequest(c.name, "S3.ListBucketLifecycle", in)
	out := new(ListBucketsResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) UpdateBucket(ctx context.Context, in *Bucket, opts ...client.CallOption) (*BaseResponse, error) {
	req := c.c.NewRequest(c.name, "S3.UpdateBucket", in)
	out := new(BaseResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) ListBucketUploadRecords(ctx context.Context, in *ListBucketUploadRequest, opts ...client.CallOption) (*ListBucketUploadResponse, error) {
	req := c.c.NewRequest(c.name, "S3.ListBucketUploadRecords", in)
	out := new(ListBucketUploadResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) InitMultipartUpload(ctx context.Context, in *InitMultiPartRequest, opts ...client.CallOption) (*InitMultiPartResponse, error) {
	req := c.c.NewRequest(c.name, "S3.InitMultipartUpload", in)
	out := new(InitMultiPartResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) AbortMultipartUpload(ctx context.Context, in *AbortMultipartRequest, opts ...client.CallOption) (*BaseResponse, error) {
	req := c.c.NewRequest(c.name, "S3.AbortMultipartUpload", in)
	out := new(BaseResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) CompleteMultipartUpload(ctx context.Context, in *CompleteMultipartRequest, opts ...client.CallOption) (*CompleteMultipartResponse, error) {
	req := c.c.NewRequest(c.name, "S3.CompleteMultipartUpload", in)
	out := new(CompleteMultipartResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) UploadPart(ctx context.Context, opts ...client.CallOption) (S3_UploadPartService, error) {
	req := c.c.NewRequest(c.name, "S3.UploadPart", &PutDataStream{})
	stream, err := c.c.Stream(ctx, req, opts...)
	if err != nil {
		return nil, err
	}
	return &s3ServiceUploadPart{stream}, nil
}

type S3_UploadPartService interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*PutDataStream) error
}

type s3ServiceUploadPart struct {
	stream client.Stream
}

func (x *s3ServiceUploadPart) Close() error {
	return x.stream.Close()
}

func (x *s3ServiceUploadPart) SendMsg(m interface{}) error {
	return x.stream.Send(m)
}

func (x *s3ServiceUploadPart) RecvMsg(m interface{}) error {
	return x.stream.Recv(m)
}

func (x *s3ServiceUploadPart) Send(m *PutDataStream) error {
	return x.stream.Send(m)
}

func (c *s3Service) ListObjectParts(ctx context.Context, in *ListObjectPartsRequest, opts ...client.CallOption) (*ListObjectPartsResponse, error) {
	req := c.c.NewRequest(c.name, "S3.ListObjectParts", in)
	out := new(ListObjectPartsResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) AppendObject(ctx context.Context, in *BaseRequest, opts ...client.CallOption) (*BaseResponse, error) {
	req := c.c.NewRequest(c.name, "S3.AppendObject", in)
	out := new(BaseResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) PostObject(ctx context.Context, in *BaseRequest, opts ...client.CallOption) (*BaseResponse, error) {
	req := c.c.NewRequest(c.name, "S3.PostObject", in)
	out := new(BaseResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) AddUploadRecord(ctx context.Context, in *MultipartUploadRecord, opts ...client.CallOption) (*BaseResponse, error) {
	req := c.c.NewRequest(c.name, "S3.AddUploadRecord", in)
	out := new(BaseResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) DeleteUploadRecord(ctx context.Context, in *MultipartUploadRecord, opts ...client.CallOption) (*BaseResponse, error) {
	req := c.c.NewRequest(c.name, "S3.DeleteUploadRecord", in)
	out := new(BaseResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) HeadObject(ctx context.Context, in *BaseObjRequest, opts ...client.CallOption) (*Object, error) {
	req := c.c.NewRequest(c.name, "S3.HeadObject", in)
	out := new(Object)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) MoveObject(ctx context.Context, in *MoveObjectRequest, opts ...client.CallOption) (*MoveObjectResponse, error) {
	req := c.c.NewRequest(c.name, "S3.MoveObject", in)
	out := new(MoveObjectResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) CopyObject(ctx context.Context, in *CopyObjectRequest, opts ...client.CallOption) (*CopyObjectResponse, error) {
	req := c.c.NewRequest(c.name, "S3.CopyObject", in)
	out := new(CopyObjectResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) CopyObjPart(ctx context.Context, in *CopyObjPartRequest, opts ...client.CallOption) (*CopyObjPartResponse, error) {
	req := c.c.NewRequest(c.name, "S3.CopyObjPart", in)
	out := new(CopyObjPartResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) PutObjACL(ctx context.Context, in *PutObjACLRequest, opts ...client.CallOption) (*BaseResponse, error) {
	req := c.c.NewRequest(c.name, "S3.PutObjACL", in)
	out := new(BaseResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) GetObjACL(ctx context.Context, in *BaseObjRequest, opts ...client.CallOption) (*ObjACL, error) {
	req := c.c.NewRequest(c.name, "S3.GetObjACL", in)
	out := new(ObjACL)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) GetBucketLocation(ctx context.Context, in *BaseRequest, opts ...client.CallOption) (*BaseResponse, error) {
	req := c.c.NewRequest(c.name, "S3.GetBucketLocation", in)
	out := new(BaseResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) GetBucketVersioning(ctx context.Context, in *BaseBucketRequest, opts ...client.CallOption) (*BucketVersioning, error) {
	req := c.c.NewRequest(c.name, "S3.GetBucketVersioning", in)
	out := new(BucketVersioning)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) PutBucketACL(ctx context.Context, in *PutBucketACLRequest, opts ...client.CallOption) (*BaseResponse, error) {
	req := c.c.NewRequest(c.name, "S3.PutBucketACL", in)
	out := new(BaseResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) GetBucketACL(ctx context.Context, in *BaseBucketRequest, opts ...client.CallOption) (*BucketACL, error) {
	req := c.c.NewRequest(c.name, "S3.GetBucketACL", in)
	out := new(BucketACL)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) PutBucketCORS(ctx context.Context, in *BaseRequest, opts ...client.CallOption) (*BaseResponse, error) {
	req := c.c.NewRequest(c.name, "S3.PutBucketCORS", in)
	out := new(BaseResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) GetBucketCORS(ctx context.Context, in *BaseRequest, opts ...client.CallOption) (*BaseResponse, error) {
	req := c.c.NewRequest(c.name, "S3.GetBucketCORS", in)
	out := new(BaseResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) DeleteBucketCORS(ctx context.Context, in *BaseRequest, opts ...client.CallOption) (*BaseResponse, error) {
	req := c.c.NewRequest(c.name, "S3.DeleteBucketCORS", in)
	out := new(BaseResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) PutBucketPolicy(ctx context.Context, in *BaseRequest, opts ...client.CallOption) (*BaseResponse, error) {
	req := c.c.NewRequest(c.name, "S3.PutBucketPolicy", in)
	out := new(BaseResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) GetBucketPolicy(ctx context.Context, in *BaseRequest, opts ...client.CallOption) (*BaseResponse, error) {
	req := c.c.NewRequest(c.name, "S3.GetBucketPolicy", in)
	out := new(BaseResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) DeleteBucketPolicy(ctx context.Context, in *BaseRequest, opts ...client.CallOption) (*BaseResponse, error) {
	req := c.c.NewRequest(c.name, "S3.DeleteBucketPolicy", in)
	out := new(BaseResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *s3Service) HeadBucket(ctx context.Context, in *BaseRequest, opts ...client.CallOption) (*Bucket, error) {
	req := c.c.NewRequest(c.name, "S3.HeadBucket", in)
	out := new(Bucket)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// Server API for S3 service

type S3Handler interface {
	ListBuckets(context.Context, *BaseRequest, *ListBucketsResponse) error
	CreateBucket(context.Context, *Bucket, *BaseResponse) error
	DeleteBucket(context.Context, *Bucket, *BaseResponse) error
	GetBucket(context.Context, *Bucket, *GetBucketResponse) error
	GetObjectMeta(context.Context, *Object, *GetObjectMetaResult) error
	UpdateObjectMeta(context.Context, *Object, *PutObjectResponse) error
	ListObjects(context.Context, *ListObjectsRequest, *ListObjectsResponse) error
	CountObjects(context.Context, *ListObjectsRequest, *CountObjectsResponse) error
	PutObject(context.Context, S3_PutObjectStream) error
	UpdateObject(context.Context, *Object, *BaseResponse) error
	GetObject(context.Context, *GetObjectInput, S3_GetObjectStream) error
	DeleteObject(context.Context, *DeleteObjectInput, *DeleteObjectOutput) error
	GetTierMap(context.Context, *BaseRequest, *GetTierMapResponse) error
	UpdateObjMeta(context.Context, *UpdateObjMetaRequest, *BaseResponse) error
	GetStorageClasses(context.Context, *BaseRequest, *GetStorageClassesResponse) error
	GetBackendTypeByTier(context.Context, *GetBackendTypeByTierRequest, *GetBackendTypeByTierResponse) error
	DeleteBucketLifecycle(context.Context, *BaseRequest, *BaseResponse) error
	PutBucketLifecycle(context.Context, *PutBucketLifecycleRequest, *BaseResponse) error
	GetBucketLifecycle(context.Context, *BaseRequest, *GetBucketLifecycleResponse) error
	ListBucketLifecycle(context.Context, *BaseRequest, *ListBucketsResponse) error
	UpdateBucket(context.Context, *Bucket, *BaseResponse) error
	ListBucketUploadRecords(context.Context, *ListBucketUploadRequest, *ListBucketUploadResponse) error
	InitMultipartUpload(context.Context, *InitMultiPartRequest, *InitMultiPartResponse) error
	AbortMultipartUpload(context.Context, *AbortMultipartRequest, *BaseResponse) error
	CompleteMultipartUpload(context.Context, *CompleteMultipartRequest, *CompleteMultipartResponse) error
	UploadPart(context.Context, S3_UploadPartStream) error
	ListObjectParts(context.Context, *ListObjectPartsRequest, *ListObjectPartsResponse) error
	AppendObject(context.Context, *BaseRequest, *BaseResponse) error
	PostObject(context.Context, *BaseRequest, *BaseResponse) error
	// For lifecycle, may need some change.
	AddUploadRecord(context.Context, *MultipartUploadRecord, *BaseResponse) error
	DeleteUploadRecord(context.Context, *MultipartUploadRecord, *BaseResponse) error
	HeadObject(context.Context, *BaseObjRequest, *Object) error
	MoveObject(context.Context, *MoveObjectRequest, *MoveObjectResponse) error
	CopyObject(context.Context, *CopyObjectRequest, *CopyObjectResponse) error
	CopyObjPart(context.Context, *CopyObjPartRequest, *CopyObjPartResponse) error
	PutObjACL(context.Context, *PutObjACLRequest, *BaseResponse) error
	GetObjACL(context.Context, *BaseObjRequest, *ObjACL) error
	GetBucketLocation(context.Context, *BaseRequest, *BaseResponse) error
	GetBucketVersioning(context.Context, *BaseBucketRequest, *BucketVersioning) error
	PutBucketACL(context.Context, *PutBucketACLRequest, *BaseResponse) error
	GetBucketACL(context.Context, *BaseBucketRequest, *BucketACL) error
	PutBucketCORS(context.Context, *BaseRequest, *BaseResponse) error
	GetBucketCORS(context.Context, *BaseRequest, *BaseResponse) error
	DeleteBucketCORS(context.Context, *BaseRequest, *BaseResponse) error
	PutBucketPolicy(context.Context, *BaseRequest, *BaseResponse) error
	GetBucketPolicy(context.Context, *BaseRequest, *BaseResponse) error
	DeleteBucketPolicy(context.Context, *BaseRequest, *BaseResponse) error
	HeadBucket(context.Context, *BaseRequest, *Bucket) error
}

func RegisterS3Handler(s server.Server, hdlr S3Handler, opts ...server.HandlerOption) error {
	type s3 interface {
		ListBuckets(ctx context.Context, in *BaseRequest, out *ListBucketsResponse) error
		CreateBucket(ctx context.Context, in *Bucket, out *BaseResponse) error
		DeleteBucket(ctx context.Context, in *Bucket, out *BaseResponse) error
		GetBucket(ctx context.Context, in *Bucket, out *GetBucketResponse) error
		GetObjectMeta(ctx context.Context, in *Object, out *GetObjectMetaResult) error
		UpdateObjectMeta(ctx context.Context, in *Object, out *PutObjectResponse) error
		ListObjects(ctx context.Context, in *ListObjectsRequest, out *ListObjectsResponse) error
		CountObjects(ctx context.Context, in *ListObjectsRequest, out *CountObjectsResponse) error
		PutObject(ctx context.Context, stream server.Stream) error
		UpdateObject(ctx context.Context, in *Object, out *BaseResponse) error
		GetObject(ctx context.Context, stream server.Stream) error
		DeleteObject(ctx context.Context, in *DeleteObjectInput, out *DeleteObjectOutput) error
		GetTierMap(ctx context.Context, in *BaseRequest, out *GetTierMapResponse) error
		UpdateObjMeta(ctx context.Context, in *UpdateObjMetaRequest, out *BaseResponse) error
		GetStorageClasses(ctx context.Context, in *BaseRequest, out *GetStorageClassesResponse) error
		GetBackendTypeByTier(ctx context.Context, in *GetBackendTypeByTierRequest, out *GetBackendTypeByTierResponse) error
		DeleteBucketLifecycle(ctx context.Context, in *BaseRequest, out *BaseResponse) error
		PutBucketLifecycle(ctx context.Context, in *PutBucketLifecycleRequest, out *BaseResponse) error
		GetBucketLifecycle(ctx context.Context, in *BaseRequest, out *GetBucketLifecycleResponse) error
		ListBucketLifecycle(ctx context.Context, in *BaseRequest, out *ListBucketsResponse) error
		UpdateBucket(ctx context.Context, in *Bucket, out *BaseResponse) error
		ListBucketUploadRecords(ctx context.Context, in *ListBucketUploadRequest, out *ListBucketUploadResponse) error
		InitMultipartUpload(ctx context.Context, in *InitMultiPartRequest, out *InitMultiPartResponse) error
		AbortMultipartUpload(ctx context.Context, in *AbortMultipartRequest, out *BaseResponse) error
		CompleteMultipartUpload(ctx context.Context, in *CompleteMultipartRequest, out *CompleteMultipartResponse) error
		UploadPart(ctx context.Context, stream server.Stream) error
		ListObjectParts(ctx context.Context, in *ListObjectPartsRequest, out *ListObjectPartsResponse) error
		AppendObject(ctx context.Context, in *BaseRequest, out *BaseResponse) error
		PostObject(ctx context.Context, in *BaseRequest, out *BaseResponse) error
		AddUploadRecord(ctx context.Context, in *MultipartUploadRecord, out *BaseResponse) error
		DeleteUploadRecord(ctx context.Context, in *MultipartUploadRecord, out *BaseResponse) error
		HeadObject(ctx context.Context, in *BaseObjRequest, out *Object) error
		MoveObject(ctx context.Context, in *MoveObjectRequest, out *MoveObjectResponse) error
		CopyObject(ctx context.Context, in *CopyObjectRequest, out *CopyObjectResponse) error
		CopyObjPart(ctx context.Context, in *CopyObjPartRequest, out *CopyObjPartResponse) error
		PutObjACL(ctx context.Context, in *PutObjACLRequest, out *BaseResponse) error
		GetObjACL(ctx context.Context, in *BaseObjRequest, out *ObjACL) error
		GetBucketLocation(ctx context.Context, in *BaseRequest, out *BaseResponse) error
		GetBucketVersioning(ctx context.Context, in *BaseBucketRequest, out *BucketVersioning) error
		PutBucketACL(ctx context.Context, in *PutBucketACLRequest, out *BaseResponse) error
		GetBucketACL(ctx context.Context, in *BaseBucketRequest, out *BucketACL) error
		PutBucketCORS(ctx context.Context, in *BaseRequest, out *BaseResponse) error
		GetBucketCORS(ctx context.Context, in *BaseRequest, out *BaseResponse) error
		DeleteBucketCORS(ctx context.Context, in *BaseRequest, out *BaseResponse) error
		PutBucketPolicy(ctx context.Context, in *BaseRequest, out *BaseResponse) error
		GetBucketPolicy(ctx context.Context, in *BaseRequest, out *BaseResponse) error
		DeleteBucketPolicy(ctx context.Context, in *BaseRequest, out *BaseResponse) error
		HeadBucket(ctx context.Context, in *BaseRequest, out *Bucket) error
	}
	type S3 struct {
		s3
	}
	h := &s3Handler{hdlr}
	return s.Handle(s.NewHandler(&S3{h}, opts...))
}

type s3Handler struct {
	S3Handler
}

func (h *s3Handler) ListBuckets(ctx context.Context, in *BaseRequest, out *ListBucketsResponse) error {
	return h.S3Handler.ListBuckets(ctx, in, out)
}

func (h *s3Handler) CreateBucket(ctx context.Context, in *Bucket, out *BaseResponse) error {
	return h.S3Handler.CreateBucket(ctx, in, out)
}

func (h *s3Handler) DeleteBucket(ctx context.Context, in *Bucket, out *BaseResponse) error {
	return h.S3Handler.DeleteBucket(ctx, in, out)
}

func (h *s3Handler) GetBucket(ctx context.Context, in *Bucket, out *GetBucketResponse) error {
	return h.S3Handler.GetBucket(ctx, in, out)
}

func (h *s3Handler) GetObjectMeta(ctx context.Context, in *Object, out *GetObjectMetaResult) error {
	return h.S3Handler.GetObjectMeta(ctx, in, out)
}

func (h *s3Handler) UpdateObjectMeta(ctx context.Context, in *Object, out *PutObjectResponse) error {
	return h.S3Handler.UpdateObjectMeta(ctx, in, out)
}

func (h *s3Handler) ListObjects(ctx context.Context, in *ListObjectsRequest, out *ListObjectsResponse) error {
	return h.S3Handler.ListObjects(ctx, in, out)
}

func (h *s3Handler) CountObjects(ctx context.Context, in *ListObjectsRequest, out *CountObjectsResponse) error {
	return h.S3Handler.CountObjects(ctx, in, out)
}

func (h *s3Handler) PutObject(ctx context.Context, stream server.Stream) error {
	return h.S3Handler.PutObject(ctx, &s3PutObjectStream{stream})
}

type S3_PutObjectStream interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Recv() (*PutDataStream, error)
}

type s3PutObjectStream struct {
	stream server.Stream
}

func (x *s3PutObjectStream) Close() error {
	return x.stream.Close()
}

func (x *s3PutObjectStream) SendMsg(m interface{}) error {
	return x.stream.Send(m)
}

func (x *s3PutObjectStream) RecvMsg(m interface{}) error {
	return x.stream.Recv(m)
}

func (x *s3PutObjectStream) Recv() (*PutDataStream, error) {
	m := new(PutDataStream)
	if err := x.stream.Recv(m); err != nil {
		return nil, err
	}
	return m, nil
}

func (h *s3Handler) UpdateObject(ctx context.Context, in *Object, out *BaseResponse) error {
	return h.S3Handler.UpdateObject(ctx, in, out)
}

func (h *s3Handler) GetObject(ctx context.Context, stream server.Stream) error {
	m := new(GetObjectInput)
	if err := stream.Recv(m); err != nil {
		return err
	}
	return h.S3Handler.GetObject(ctx, m, &s3GetObjectStream{stream})
}

type S3_GetObjectStream interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*GetObjectResponse) error
}

type s3GetObjectStream struct {
	stream server.Stream
}

func (x *s3GetObjectStream) Close() error {
	return x.stream.Close()
}

func (x *s3GetObjectStream) SendMsg(m interface{}) error {
	return x.stream.Send(m)
}

func (x *s3GetObjectStream) RecvMsg(m interface{}) error {
	return x.stream.Recv(m)
}

func (x *s3GetObjectStream) Send(m *GetObjectResponse) error {
	return x.stream.Send(m)
}

func (h *s3Handler) DeleteObject(ctx context.Context, in *DeleteObjectInput, out *DeleteObjectOutput) error {
	return h.S3Handler.DeleteObject(ctx, in, out)
}

func (h *s3Handler) GetTierMap(ctx context.Context, in *BaseRequest, out *GetTierMapResponse) error {
	return h.S3Handler.GetTierMap(ctx, in, out)
}

func (h *s3Handler) UpdateObjMeta(ctx context.Context, in *UpdateObjMetaRequest, out *BaseResponse) error {
	return h.S3Handler.UpdateObjMeta(ctx, in, out)
}

func (h *s3Handler) GetStorageClasses(ctx context.Context, in *BaseRequest, out *GetStorageClassesResponse) error {
	return h.S3Handler.GetStorageClasses(ctx, in, out)
}

func (h *s3Handler) GetBackendTypeByTier(ctx context.Context, in *GetBackendTypeByTierRequest, out *GetBackendTypeByTierResponse) error {
	return h.S3Handler.GetBackendTypeByTier(ctx, in, out)
}

func (h *s3Handler) DeleteBucketLifecycle(ctx context.Context, in *BaseRequest, out *BaseResponse) error {
	return h.S3Handler.DeleteBucketLifecycle(ctx, in, out)
}

func (h *s3Handler) PutBucketLifecycle(ctx context.Context, in *PutBucketLifecycleRequest, out *BaseResponse) error {
	return h.S3Handler.PutBucketLifecycle(ctx, in, out)
}

func (h *s3Handler) GetBucketLifecycle(ctx context.Context, in *BaseRequest, out *GetBucketLifecycleResponse) error {
	return h.S3Handler.GetBucketLifecycle(ctx, in, out)
}

func (h *s3Handler) ListBucketLifecycle(ctx context.Context, in *BaseRequest, out *ListBucketsResponse) error {
	return h.S3Handler.ListBucketLifecycle(ctx, in, out)
}

func (h *s3Handler) UpdateBucket(ctx context.Context, in *Bucket, out *BaseResponse) error {
	return h.S3Handler.UpdateBucket(ctx, in, out)
}

func (h *s3Handler) ListBucketUploadRecords(ctx context.Context, in *ListBucketUploadRequest, out *ListBucketUploadResponse) error {
	return h.S3Handler.ListBucketUploadRecords(ctx, in, out)
}

func (h *s3Handler) InitMultipartUpload(ctx context.Context, in *InitMultiPartRequest, out *InitMultiPartResponse) error {
	return h.S3Handler.InitMultipartUpload(ctx, in, out)
}

func (h *s3Handler) AbortMultipartUpload(ctx context.Context, in *AbortMultipartRequest, out *BaseResponse) error {
	return h.S3Handler.AbortMultipartUpload(ctx, in, out)
}

func (h *s3Handler) CompleteMultipartUpload(ctx context.Context, in *CompleteMultipartRequest, out *CompleteMultipartResponse) error {
	return h.S3Handler.CompleteMultipartUpload(ctx, in, out)
}

func (h *s3Handler) UploadPart(ctx context.Context, stream server.Stream) error {
	return h.S3Handler.UploadPart(ctx, &s3UploadPartStream{stream})
}

type S3_UploadPartStream interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Recv() (*PutDataStream, error)
}

type s3UploadPartStream struct {
	stream server.Stream
}

func (x *s3UploadPartStream) Close() error {
	return x.stream.Close()
}

func (x *s3UploadPartStream) SendMsg(m interface{}) error {
	return x.stream.Send(m)
}

func (x *s3UploadPartStream) RecvMsg(m interface{}) error {
	return x.stream.Recv(m)
}

func (x *s3UploadPartStream) Recv() (*PutDataStream, error) {
	m := new(PutDataStream)
	if err := x.stream.Recv(m); err != nil {
		return nil, err
	}
	return m, nil
}

func (h *s3Handler) ListObjectParts(ctx context.Context, in *ListObjectPartsRequest, out *ListObjectPartsResponse) error {
	return h.S3Handler.ListObjectParts(ctx, in, out)
}

func (h *s3Handler) AppendObject(ctx context.Context, in *BaseRequest, out *BaseResponse) error {
	return h.S3Handler.AppendObject(ctx, in, out)
}

func (h *s3Handler) PostObject(ctx context.Context, in *BaseRequest, out *BaseResponse) error {
	return h.S3Handler.PostObject(ctx, in, out)
}

func (h *s3Handler) AddUploadRecord(ctx context.Context, in *MultipartUploadRecord, out *BaseResponse) error {
	return h.S3Handler.AddUploadRecord(ctx, in, out)
}

func (h *s3Handler) DeleteUploadRecord(ctx context.Context, in *MultipartUploadRecord, out *BaseResponse) error {
	return h.S3Handler.DeleteUploadRecord(ctx, in, out)
}

func (h *s3Handler) HeadObject(ctx context.Context, in *BaseObjRequest, out *Object) error {
	return h.S3Handler.HeadObject(ctx, in, out)
}

func (h *s3Handler) MoveObject(ctx context.Context, in *MoveObjectRequest, out *MoveObjectResponse) error {
	return h.S3Handler.MoveObject(ctx, in, out)
}

func (h *s3Handler) CopyObject(ctx context.Context, in *CopyObjectRequest, out *CopyObjectResponse) error {
	return h.S3Handler.CopyObject(ctx, in, out)
}

func (h *s3Handler) CopyObjPart(ctx context.Context, in *CopyObjPartRequest, out *CopyObjPartResponse) error {
	return h.S3Handler.CopyObjPart(ctx, in, out)
}

func (h *s3Handler) PutObjACL(ctx context.Context, in *PutObjACLRequest, out *BaseResponse) error {
	return h.S3Handler.PutObjACL(ctx, in, out)
}

func (h *s3Handler) GetObjACL(ctx context.Context, in *BaseObjRequest, out *ObjACL) error {
	return h.S3Handler.GetObjACL(ctx, in, out)
}

func (h *s3Handler) GetBucketLocation(ctx context.Context, in *BaseRequest, out *BaseResponse) error {
	return h.S3Handler.GetBucketLocation(ctx, in, out)
}

func (h *s3Handler) GetBucketVersioning(ctx context.Context, in *BaseBucketRequest, out *BucketVersioning) error {
	return h.S3Handler.GetBucketVersioning(ctx, in, out)
}

func (h *s3Handler) PutBucketACL(ctx context.Context, in *PutBucketACLRequest, out *BaseResponse) error {
	return h.S3Handler.PutBucketACL(ctx, in, out)
}

func (h *s3Handler) GetBucketACL(ctx context.Context, in *BaseBucketRequest, out *BucketACL) error {
	return h.S3Handler.GetBucketACL(ctx, in, out)
}

func (h *s3Handler) PutBucketCORS(ctx context.Context, in *BaseRequest, out *BaseResponse) error {
	return h.S3Handler.PutBucketCORS(ctx, in, out)
}

func (h *s3Handler) GetBucketCORS(ctx context.Context, in *BaseRequest, out *BaseResponse) error {
	return h.S3Handler.GetBucketCORS(ctx, in, out)
}

func (h *s3Handler) DeleteBucketCORS(ctx context.Context, in *BaseRequest, out *BaseResponse) error {
	return h.S3Handler.DeleteBucketCORS(ctx, in, out)
}

func (h *s3Handler) PutBucketPolicy(ctx context.Context, in *BaseRequest, out *BaseResponse) error {
	return h.S3Handler.PutBucketPolicy(ctx, in, out)
}

func (h *s3Handler) GetBucketPolicy(ctx context.Context, in *BaseRequest, out *BaseResponse) error {
	return h.S3Handler.GetBucketPolicy(ctx, in, out)
}

func (h *s3Handler) DeleteBucketPolicy(ctx context.Context, in *BaseRequest, out *BaseResponse) error {
	return h.S3Handler.DeleteBucketPolicy(ctx, in, out)
}

func (h *s3Handler) HeadBucket(ctx context.Context, in *BaseRequest, out *Bucket) error {
	return h.S3Handler.HeadBucket(ctx, in, out)
}