s3.pb.micro.go

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

package s3

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

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

// 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.ProtoPackageIsVersion3 // 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)
}