upload

package
v0.0.0-...-5a5b885 Latest Latest
Warning

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

 Go to latest Published: Feb 13, 2021 License: Apache-2.0 Imports: 9 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_upload_service_proto protoreflect.FileDescriptor

Functions

func RegisterUploadServer 

func RegisterUploadServer(s *grpc.Server, srv UploadServer)

Types

type CopyObjectRequest 

type CopyObjectRequest struct {

	// The source bucket of the object.
	BucketSrc string `protobuf:"bytes,1,opt,name=bucketSrc,proto3" json:"bucketSrc,omitempty"`
	// The source bucket of the object.
	BucketDest string `protobuf:"bytes,2,opt,name=bucketDest,proto3" json:"bucketDest,omitempty"`
	// The object key to be copied.
	KeySrc string `protobuf:"bytes,3,opt,name=keySrc,proto3" json:"keySrc,omitempty"`
	// New object key.
	KeyDest string `protobuf:"bytes,4,opt,name=keyDest,proto3" json:"keyDest,omitempty"`
	// contains filtered or unexported fields
}

CopyObjectRequest is the request for copy object between buckets.

func (*CopyObjectRequest) Descriptor deprecated 

func (*CopyObjectRequest) Descriptor() ([]byte, []int)

Deprecated: Use CopyObjectRequest.ProtoReflect.Descriptor instead.

func (*CopyObjectRequest) GetBucketDest 

func (x *CopyObjectRequest) GetBucketDest() string

func (*CopyObjectRequest) GetBucketSrc 

func (x *CopyObjectRequest) GetBucketSrc() string

func (*CopyObjectRequest) GetKeyDest 

func (x *CopyObjectRequest) GetKeyDest() string

func (*CopyObjectRequest) GetKeySrc 

func (x *CopyObjectRequest) GetKeySrc() string

func (*CopyObjectRequest) ProtoMessage 

func (*CopyObjectRequest) ProtoMessage()

func (*CopyObjectRequest) ProtoReflect 

func (x *CopyObjectRequest) ProtoReflect() protoreflect.Message

func (*CopyObjectRequest) Reset 

func (x *CopyObjectRequest) Reset()

func (*CopyObjectRequest) String 

func (x *CopyObjectRequest) String() string

type CopyObjectResponse 

type CopyObjectResponse struct {

	// The object key that copied successfully.
	Copied string `protobuf:"bytes,1,opt,name=copied,proto3" json:"copied,omitempty"`
	// contains filtered or unexported fields
}

CopyObjectResponse is the response for copy an object.

func (*CopyObjectResponse) Descriptor deprecated 

func (*CopyObjectResponse) Descriptor() ([]byte, []int)

Deprecated: Use CopyObjectResponse.ProtoReflect.Descriptor instead.

func (*CopyObjectResponse) GetCopied 

func (x *CopyObjectResponse) GetCopied() string

func (*CopyObjectResponse) ProtoMessage 

func (*CopyObjectResponse) ProtoMessage()

func (*CopyObjectResponse) ProtoReflect 

func (x *CopyObjectResponse) ProtoReflect() protoreflect.Message

func (*CopyObjectResponse) Reset 

func (x *CopyObjectResponse) Reset()

func (*CopyObjectResponse) String 

func (x *CopyObjectResponse) String() string

type DeleteObjectsRequest 

type DeleteObjectsRequest struct {

	// The bucket to delete the objects from.
	Bucket string `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	// The object keys to be deleted from s3.
	Keys []string `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

DeleteObjectsRequest is the request for deleting objects.

func (*DeleteObjectsRequest) Descriptor deprecated 

func (*DeleteObjectsRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteObjectsRequest.ProtoReflect.Descriptor instead.

func (*DeleteObjectsRequest) GetBucket 

func (x *DeleteObjectsRequest) GetBucket() string

func (*DeleteObjectsRequest) GetKeys 

func (x *DeleteObjectsRequest) GetKeys() []string

func (*DeleteObjectsRequest) ProtoMessage 

func (*DeleteObjectsRequest) ProtoMessage()

func (*DeleteObjectsRequest) ProtoReflect 

func (x *DeleteObjectsRequest) ProtoReflect() protoreflect.Message

func (*DeleteObjectsRequest) Reset 

func (x *DeleteObjectsRequest) Reset()

func (*DeleteObjectsRequest) String 

func (x *DeleteObjectsRequest) String() string

type DeleteObjectsResponse 

type DeleteObjectsResponse struct {

	// The object keys that deleted successfully.
	Deleted []string `protobuf:"bytes,1,rep,name=deleted,proto3" json:"deleted,omitempty"`
	// The object keys that failed to delete.
	Failed []string `protobuf:"bytes,2,rep,name=failed,proto3" json:"failed,omitempty"`
	// contains filtered or unexported fields
}

DeleteObjectsResponse is the response for deleting objects.

func (*DeleteObjectsResponse) Descriptor deprecated 

func (*DeleteObjectsResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteObjectsResponse.ProtoReflect.Descriptor instead.

func (*DeleteObjectsResponse) GetDeleted 

func (x *DeleteObjectsResponse) GetDeleted() []string

func (*DeleteObjectsResponse) GetFailed 

func (x *DeleteObjectsResponse) GetFailed() []string

func (*DeleteObjectsResponse) ProtoMessage 

func (*DeleteObjectsResponse) ProtoMessage()

func (*DeleteObjectsResponse) ProtoReflect 

func (x *DeleteObjectsResponse) ProtoReflect() protoreflect.Message

func (*DeleteObjectsResponse) Reset 

func (x *DeleteObjectsResponse) Reset()

func (*DeleteObjectsResponse) String 

func (x *DeleteObjectsResponse) String() string

type MoveObjectRequest 

type MoveObjectRequest struct {

	// The source bucket of the object.
	BucketSrc string `protobuf:"bytes,1,opt,name=bucketSrc,proto3" json:"bucketSrc,omitempty"`
	// The source bucket of the object.
	BucketDest string `protobuf:"bytes,2,opt,name=bucketDest,proto3" json:"bucketDest,omitempty"`
	// The object key to be moved.
	KeySrc string `protobuf:"bytes,3,opt,name=keySrc,proto3" json:"keySrc,omitempty"`
	// New object key.
	KeyDest string `protobuf:"bytes,4,opt,name=keyDest,proto3" json:"keyDest,omitempty"`
	// contains filtered or unexported fields
}

MoveObjectRequest is the request for move object between buckets.

func (*MoveObjectRequest) Descriptor deprecated 

func (*MoveObjectRequest) Descriptor() ([]byte, []int)

Deprecated: Use MoveObjectRequest.ProtoReflect.Descriptor instead.

func (*MoveObjectRequest) GetBucketDest 

func (x *MoveObjectRequest) GetBucketDest() string

func (*MoveObjectRequest) GetBucketSrc 

func (x *MoveObjectRequest) GetBucketSrc() string

func (*MoveObjectRequest) GetKeyDest 

func (x *MoveObjectRequest) GetKeyDest() string

func (*MoveObjectRequest) GetKeySrc 

func (x *MoveObjectRequest) GetKeySrc() string

func (*MoveObjectRequest) ProtoMessage 

func (*MoveObjectRequest) ProtoMessage()

func (*MoveObjectRequest) ProtoReflect 

func (x *MoveObjectRequest) ProtoReflect() protoreflect.Message

func (*MoveObjectRequest) Reset 

func (x *MoveObjectRequest) Reset()

func (*MoveObjectRequest) String 

func (x *MoveObjectRequest) String() string

type MoveObjectResponse 

type MoveObjectResponse struct {

	// The object keys that moved successfully.
	Moved string `protobuf:"bytes,1,opt,name=moved,proto3" json:"moved,omitempty"`
	// contains filtered or unexported fields
}

MoveObjectResponse is the response for moving an object.

func (*MoveObjectResponse) Descriptor deprecated 

func (*MoveObjectResponse) Descriptor() ([]byte, []int)

Deprecated: Use MoveObjectResponse.ProtoReflect.Descriptor instead.

func (*MoveObjectResponse) GetMoved 

func (x *MoveObjectResponse) GetMoved() string

func (*MoveObjectResponse) ProtoMessage 

func (*MoveObjectResponse) ProtoMessage()

func (*MoveObjectResponse) ProtoReflect 

func (x *MoveObjectResponse) ProtoReflect() protoreflect.Message

func (*MoveObjectResponse) Reset 

func (x *MoveObjectResponse) Reset()

func (*MoveObjectResponse) String 

func (x *MoveObjectResponse) String() string

type UnimplementedUploadServer 

type UnimplementedUploadServer struct {
}

UnimplementedUploadServer can be embedded to have forward compatible implementations.

func (*UnimplementedUploadServer) CopyObject 

func (*UnimplementedUploadServer) CopyObject(context.Context, *CopyObjectRequest) (*CopyObjectResponse, error)

func (*UnimplementedUploadServer) DeleteObjects 

func (*UnimplementedUploadServer) DeleteObjects(context.Context, *DeleteObjectsRequest) (*DeleteObjectsResponse, error)

func (*UnimplementedUploadServer) MoveObject 

func (*UnimplementedUploadServer) MoveObject(context.Context, *MoveObjectRequest) (*MoveObjectResponse, error)

func (*UnimplementedUploadServer) UploadAbort 

func (*UnimplementedUploadServer) UploadAbort(context.Context, *UploadAbortRequest) (*UploadAbortResponse, error)

func (*UnimplementedUploadServer) UploadComplete 

func (*UnimplementedUploadServer) UploadComplete(context.Context, *UploadCompleteRequest) (*UploadCompleteResponse, error)

func (*UnimplementedUploadServer) UploadInit 

func (*UnimplementedUploadServer) UploadInit(context.Context, *UploadInitRequest) (*UploadInitResponse, error)

func (*UnimplementedUploadServer) UploadMedia 

func (*UnimplementedUploadServer) UploadMedia(context.Context, *UploadMediaRequest) (*UploadMediaResponse, error)

func (*UnimplementedUploadServer) UploadMultipart 

func (*UnimplementedUploadServer) UploadMultipart(context.Context, *UploadMultipartRequest) (*UploadMultipartResponse, error)

func (*UnimplementedUploadServer) UploadPart 

func (*UnimplementedUploadServer) UploadPart(Upload_UploadPartServer) error

type UploadAbortRequest 

type UploadAbortRequest struct {

	// Upload ID generated for resumable upload of a file
	UploadId string `protobuf:"bytes,1,opt,name=uploadId,proto3" json:"uploadId,omitempty"`
	// File key to store in S3
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// The bucket to upload the file to
	Bucket string `protobuf:"bytes,3,opt,name=bucket,proto3" json:"bucket,omitempty"`
	// contains filtered or unexported fields
}

UploadAbortRequest is the request for aborting resumable upload

func (*UploadAbortRequest) Descriptor deprecated 

func (*UploadAbortRequest) Descriptor() ([]byte, []int)

Deprecated: Use UploadAbortRequest.ProtoReflect.Descriptor instead.

func (*UploadAbortRequest) GetBucket 

func (x *UploadAbortRequest) GetBucket() string

func (*UploadAbortRequest) GetKey 

func (x *UploadAbortRequest) GetKey() string

func (*UploadAbortRequest) GetUploadId 

func (x *UploadAbortRequest) GetUploadId() string

func (*UploadAbortRequest) ProtoMessage 

func (*UploadAbortRequest) ProtoMessage()

func (*UploadAbortRequest) ProtoReflect 

func (x *UploadAbortRequest) ProtoReflect() protoreflect.Message

func (*UploadAbortRequest) Reset 

func (x *UploadAbortRequest) Reset()

func (*UploadAbortRequest) String 

func (x *UploadAbortRequest) String() string

type UploadAbortResponse 

type UploadAbortResponse struct {
	Status bool `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

UploadAbortResponse is the response for aborting resumable upload

func (*UploadAbortResponse) Descriptor deprecated 

func (*UploadAbortResponse) Descriptor() ([]byte, []int)

Deprecated: Use UploadAbortResponse.ProtoReflect.Descriptor instead.

func (*UploadAbortResponse) GetStatus 

func (x *UploadAbortResponse) GetStatus() bool

func (*UploadAbortResponse) ProtoMessage 

func (*UploadAbortResponse) ProtoMessage()

func (*UploadAbortResponse) ProtoReflect 

func (x *UploadAbortResponse) ProtoReflect() protoreflect.Message

func (*UploadAbortResponse) Reset 

func (x *UploadAbortResponse) Reset()

func (*UploadAbortResponse) String 

func (x *UploadAbortResponse) String() string

type UploadClient 

type UploadClient interface {
	// The function Uploads the given file
	//
	// Returns the Location of the file as output
	//
	// In case of an error the error is returned
	UploadMedia(ctx context.Context, in *UploadMediaRequest, opts ...grpc.CallOption) (*UploadMediaResponse, error)
	UploadMultipart(ctx context.Context, in *UploadMultipartRequest, opts ...grpc.CallOption) (*UploadMultipartResponse, error)
	UploadInit(ctx context.Context, in *UploadInitRequest, opts ...grpc.CallOption) (*UploadInitResponse, error)
	UploadPart(ctx context.Context, opts ...grpc.CallOption) (Upload_UploadPartClient, error)
	UploadComplete(ctx context.Context, in *UploadCompleteRequest, opts ...grpc.CallOption) (*UploadCompleteResponse, error)
	UploadAbort(ctx context.Context, in *UploadAbortRequest, opts ...grpc.CallOption) (*UploadAbortResponse, error)
	DeleteObjects(ctx context.Context, in *DeleteObjectsRequest, opts ...grpc.CallOption) (*DeleteObjectsResponse, error)
	CopyObject(ctx context.Context, in *CopyObjectRequest, opts ...grpc.CallOption) (*CopyObjectResponse, error)
	MoveObject(ctx context.Context, in *MoveObjectRequest, opts ...grpc.CallOption) (*MoveObjectResponse, error)
}

UploadClient is the client API for Upload service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewUploadClient 

func NewUploadClient(cc grpc.ClientConnInterface) UploadClient

type UploadCompleteRequest 

type UploadCompleteRequest struct {

	/// Upload ID generated for resumable upload of a file
	UploadId string `protobuf:"bytes,1,opt,name=uploadId,proto3" json:"uploadId,omitempty"`
	// File key to store in S3
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// The bucket to upload the file to
	Bucket string `protobuf:"bytes,3,opt,name=bucket,proto3" json:"bucket,omitempty"`
	// contains filtered or unexported fields
}

UploadCompleteRequest is the request for completing resumable upload

func (*UploadCompleteRequest) Descriptor deprecated 

func (*UploadCompleteRequest) Descriptor() ([]byte, []int)

Deprecated: Use UploadCompleteRequest.ProtoReflect.Descriptor instead.

func (*UploadCompleteRequest) GetBucket 

func (x *UploadCompleteRequest) GetBucket() string

func (*UploadCompleteRequest) GetKey 

func (x *UploadCompleteRequest) GetKey() string

func (*UploadCompleteRequest) GetUploadId 

func (x *UploadCompleteRequest) GetUploadId() string

func (*UploadCompleteRequest) ProtoMessage 

func (*UploadCompleteRequest) ProtoMessage()

func (*UploadCompleteRequest) ProtoReflect 

func (x *UploadCompleteRequest) ProtoReflect() protoreflect.Message

func (*UploadCompleteRequest) Reset 

func (x *UploadCompleteRequest) Reset()

func (*UploadCompleteRequest) String 

func (x *UploadCompleteRequest) String() string

type UploadCompleteResponse 

type UploadCompleteResponse struct {

	// The size that the uploaded file
	ContentLength int64 `protobuf:"varint,1,opt,name=ContentLength,proto3" json:"ContentLength,omitempty"`
	// The type of the uploaded file
	ContentType string `protobuf:"bytes,2,opt,name=ContentType,proto3" json:"ContentType,omitempty"`
	// contains filtered or unexported fields
}

UploadCompleteResponse is the response for completing resumable upload

func (*UploadCompleteResponse) Descriptor deprecated 

func (*UploadCompleteResponse) Descriptor() ([]byte, []int)

Deprecated: Use UploadCompleteResponse.ProtoReflect.Descriptor instead.

func (*UploadCompleteResponse) GetContentLength 

func (x *UploadCompleteResponse) GetContentLength() int64

func (*UploadCompleteResponse) GetContentType 

func (x *UploadCompleteResponse) GetContentType() string

func (*UploadCompleteResponse) ProtoMessage 

func (*UploadCompleteResponse) ProtoMessage()

func (*UploadCompleteResponse) ProtoReflect 

func (x *UploadCompleteResponse) ProtoReflect() protoreflect.Message

func (*UploadCompleteResponse) Reset 

func (x *UploadCompleteResponse) Reset()

func (*UploadCompleteResponse) String 

func (x *UploadCompleteResponse) String() string

type UploadInitRequest 

type UploadInitRequest struct {

	// File key to store in S3
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The bucket to upload the file to
	Bucket string `protobuf:"bytes,2,opt,name=bucket,proto3" json:"bucket,omitempty"`
	// File metadata
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// The mime-type of the file.
	ContentType string `protobuf:"bytes,4,opt,name=contentType,proto3" json:"contentType,omitempty"`
	// contains filtered or unexported fields
}

UploadInitRequest is the data for initiating resumable upload

func (*UploadInitRequest) Descriptor deprecated 

func (*UploadInitRequest) Descriptor() ([]byte, []int)

Deprecated: Use UploadInitRequest.ProtoReflect.Descriptor instead.

func (*UploadInitRequest) GetBucket 

func (x *UploadInitRequest) GetBucket() string

func (*UploadInitRequest) GetContentType 

func (x *UploadInitRequest) GetContentType() string

func (*UploadInitRequest) GetKey 

func (x *UploadInitRequest) GetKey() string

func (*UploadInitRequest) GetMetadata 

func (x *UploadInitRequest) GetMetadata() map[string]string

func (*UploadInitRequest) ProtoMessage 

func (*UploadInitRequest) ProtoMessage()

func (*UploadInitRequest) ProtoReflect 

func (x *UploadInitRequest) ProtoReflect() protoreflect.Message

func (*UploadInitRequest) Reset 

func (x *UploadInitRequest) Reset()

func (*UploadInitRequest) String 

func (x *UploadInitRequest) String() string

type UploadInitResponse 

type UploadInitResponse struct {

	// Upload ID generated for resumable upload of a file
	UploadId string `protobuf:"bytes,1,opt,name=uploadId,proto3" json:"uploadId,omitempty"`
	// File key to store in S3
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// The bucket to upload the file to
	Bucket string `protobuf:"bytes,3,opt,name=bucket,proto3" json:"bucket,omitempty"`
	// contains filtered or unexported fields
}

UploadInitResponse is the response for initiating resumable upload

func (*UploadInitResponse) Descriptor deprecated 

func (*UploadInitResponse) Descriptor() ([]byte, []int)

Deprecated: Use UploadInitResponse.ProtoReflect.Descriptor instead.

func (*UploadInitResponse) GetBucket 

func (x *UploadInitResponse) GetBucket() string

func (*UploadInitResponse) GetKey 

func (x *UploadInitResponse) GetKey() string

func (*UploadInitResponse) GetUploadId 

func (x *UploadInitResponse) GetUploadId() string

func (*UploadInitResponse) ProtoMessage 

func (*UploadInitResponse) ProtoMessage()

func (*UploadInitResponse) ProtoReflect 

func (x *UploadInitResponse) ProtoReflect() protoreflect.Message

func (*UploadInitResponse) Reset 

func (x *UploadInitResponse) Reset()

func (*UploadInitResponse) String 

func (x *UploadInitResponse) String() string

type UploadMediaRequest 

type UploadMediaRequest struct {

	// File is the file to upload
	File []byte `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"`
	// File key to store in S3
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// The bucket to upload the file to
	Bucket string `protobuf:"bytes,3,opt,name=bucket,proto3" json:"bucket,omitempty"`
	// The mime-type of the file.
	ContentType string `protobuf:"bytes,4,opt,name=contentType,proto3" json:"contentType,omitempty"`
	// contains filtered or unexported fields
}

UploadMediaRequest is the request for media upload

func (*UploadMediaRequest) Descriptor deprecated 

func (*UploadMediaRequest) Descriptor() ([]byte, []int)

Deprecated: Use UploadMediaRequest.ProtoReflect.Descriptor instead.

func (*UploadMediaRequest) GetBucket 

func (x *UploadMediaRequest) GetBucket() string

func (*UploadMediaRequest) GetContentType 

func (x *UploadMediaRequest) GetContentType() string

func (*UploadMediaRequest) GetFile 

func (x *UploadMediaRequest) GetFile() []byte

func (*UploadMediaRequest) GetKey 

func (x *UploadMediaRequest) GetKey() string

func (*UploadMediaRequest) ProtoMessage 

func (*UploadMediaRequest) ProtoMessage()

func (*UploadMediaRequest) ProtoReflect 

func (x *UploadMediaRequest) ProtoReflect() protoreflect.Message

func (*UploadMediaRequest) Reset 

func (x *UploadMediaRequest) Reset()

func (*UploadMediaRequest) String 

func (x *UploadMediaRequest) String() string

type UploadMediaResponse 

type UploadMediaResponse struct {

	// The location that the file was uploaded to
	Location string `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
	// contains filtered or unexported fields
}

UploadMediaResponse is the response for media upload

func (*UploadMediaResponse) Descriptor deprecated 

func (*UploadMediaResponse) Descriptor() ([]byte, []int)

Deprecated: Use UploadMediaResponse.ProtoReflect.Descriptor instead.

func (*UploadMediaResponse) GetLocation 

func (x *UploadMediaResponse) GetLocation() string

func (*UploadMediaResponse) ProtoMessage 

func (*UploadMediaResponse) ProtoMessage()

func (*UploadMediaResponse) ProtoReflect 

func (x *UploadMediaResponse) ProtoReflect() protoreflect.Message

func (*UploadMediaResponse) Reset 

func (x *UploadMediaResponse) Reset()

func (*UploadMediaResponse) String 

func (x *UploadMediaResponse) String() string

type UploadMultipartRequest 

type UploadMultipartRequest struct {

	// File to upload
	File []byte `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"`
	// File metadata
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// File key to store in S3
	Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// The bucket to upload the file to
	Bucket string `protobuf:"bytes,4,opt,name=bucket,proto3" json:"bucket,omitempty"`
	// The mime-type of the file.
	ContentType string `protobuf:"bytes,5,opt,name=contentType,proto3" json:"contentType,omitempty"`
	// contains filtered or unexported fields
}

UploadMultipartRequest is the request for multipart upload

func (*UploadMultipartRequest) Descriptor deprecated 

func (*UploadMultipartRequest) Descriptor() ([]byte, []int)

Deprecated: Use UploadMultipartRequest.ProtoReflect.Descriptor instead.

func (*UploadMultipartRequest) GetBucket 

func (x *UploadMultipartRequest) GetBucket() string

func (*UploadMultipartRequest) GetContentType 

func (x *UploadMultipartRequest) GetContentType() string

func (*UploadMultipartRequest) GetFile 

func (x *UploadMultipartRequest) GetFile() []byte

func (*UploadMultipartRequest) GetKey 

func (x *UploadMultipartRequest) GetKey() string

func (*UploadMultipartRequest) GetMetadata 

func (x *UploadMultipartRequest) GetMetadata() map[string]string

func (*UploadMultipartRequest) ProtoMessage 

func (*UploadMultipartRequest) ProtoMessage()

func (*UploadMultipartRequest) ProtoReflect 

func (x *UploadMultipartRequest) ProtoReflect() protoreflect.Message

func (*UploadMultipartRequest) Reset 

func (x *UploadMultipartRequest) Reset()

func (*UploadMultipartRequest) String 

func (x *UploadMultipartRequest) String() string

type UploadMultipartResponse 

type UploadMultipartResponse struct {

	// The location that the file was uploaded to
	Location string `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
	// contains filtered or unexported fields
}

UploadMultipartResponse is the response for multipart upload

func (*UploadMultipartResponse) Descriptor deprecated 

func (*UploadMultipartResponse) Descriptor() ([]byte, []int)

Deprecated: Use UploadMultipartResponse.ProtoReflect.Descriptor instead.

func (*UploadMultipartResponse) GetLocation 

func (x *UploadMultipartResponse) GetLocation() string

func (*UploadMultipartResponse) ProtoMessage 

func (*UploadMultipartResponse) ProtoMessage()

func (*UploadMultipartResponse) ProtoReflect 

func (x *UploadMultipartResponse) ProtoReflect() protoreflect.Message

func (*UploadMultipartResponse) Reset 

func (x *UploadMultipartResponse) Reset()

func (*UploadMultipartResponse) String 

func (x *UploadMultipartResponse) String() string

type UploadPartRequest 

type UploadPartRequest struct {

	// File part chunk
	Part []byte `protobuf:"bytes,1,opt,name=part,proto3" json:"part,omitempty"`
	// Part number
	PartNumber int64 `protobuf:"varint,2,opt,name=partNumber,proto3" json:"partNumber,omitempty"`
	// Upload ID generated for resumable upload of a file
	UploadId string `protobuf:"bytes,3,opt,name=uploadId,proto3" json:"uploadId,omitempty"`
	// File key to store in S3
	Key string `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	// The bucket to upload the file to
	Bucket string `protobuf:"bytes,5,opt,name=bucket,proto3" json:"bucket,omitempty"`
	// contains filtered or unexported fields
}

UploadPartRequest is the request for resumable part uload

func (*UploadPartRequest) Descriptor deprecated 

func (*UploadPartRequest) Descriptor() ([]byte, []int)

Deprecated: Use UploadPartRequest.ProtoReflect.Descriptor instead.

func (*UploadPartRequest) GetBucket 

func (x *UploadPartRequest) GetBucket() string

func (*UploadPartRequest) GetKey 

func (x *UploadPartRequest) GetKey() string

func (*UploadPartRequest) GetPart 

func (x *UploadPartRequest) GetPart() []byte

func (*UploadPartRequest) GetPartNumber 

func (x *UploadPartRequest) GetPartNumber() int64

func (*UploadPartRequest) GetUploadId 

func (x *UploadPartRequest) GetUploadId() string

func (*UploadPartRequest) ProtoMessage 

func (*UploadPartRequest) ProtoMessage()

func (*UploadPartRequest) ProtoReflect 

func (x *UploadPartRequest) ProtoReflect() protoreflect.Message

func (*UploadPartRequest) Reset 

func (x *UploadPartRequest) Reset()

func (*UploadPartRequest) String 

func (x *UploadPartRequest) String() string

type UploadPartResponse 

type UploadPartResponse struct {

	// Upload status code
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	// Upload status message
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

UploadPartResponse is the response for resumable part upload

func (*UploadPartResponse) Descriptor deprecated 

func (*UploadPartResponse) Descriptor() ([]byte, []int)

Deprecated: Use UploadPartResponse.ProtoReflect.Descriptor instead.

func (*UploadPartResponse) GetCode 

func (x *UploadPartResponse) GetCode() int32

func (*UploadPartResponse) GetMessage 

func (x *UploadPartResponse) GetMessage() string

func (*UploadPartResponse) ProtoMessage 

func (*UploadPartResponse) ProtoMessage()

func (*UploadPartResponse) ProtoReflect 

func (x *UploadPartResponse) ProtoReflect() protoreflect.Message

func (*UploadPartResponse) Reset 

func (x *UploadPartResponse) Reset()

func (*UploadPartResponse) String 

func (x *UploadPartResponse) String() string

type UploadServer 

type UploadServer interface {
	// The function Uploads the given file
	//
	// Returns the Location of the file as output
	//
	// In case of an error the error is returned
	UploadMedia(context.Context, *UploadMediaRequest) (*UploadMediaResponse, error)
	UploadMultipart(context.Context, *UploadMultipartRequest) (*UploadMultipartResponse, error)
	UploadInit(context.Context, *UploadInitRequest) (*UploadInitResponse, error)
	UploadPart(Upload_UploadPartServer) error
	UploadComplete(context.Context, *UploadCompleteRequest) (*UploadCompleteResponse, error)
	UploadAbort(context.Context, *UploadAbortRequest) (*UploadAbortResponse, error)
	DeleteObjects(context.Context, *DeleteObjectsRequest) (*DeleteObjectsResponse, error)
	CopyObject(context.Context, *CopyObjectRequest) (*CopyObjectResponse, error)
	MoveObject(context.Context, *MoveObjectRequest) (*MoveObjectResponse, error)
}

UploadServer is the server API for Upload service.

type Upload_UploadPartClient 

type Upload_UploadPartClient interface {
	Send(*UploadPartRequest) error
	Recv() (*UploadPartResponse, error)
	grpc.ClientStream
}

type Upload_UploadPartServer 

type Upload_UploadPartServer interface {
	Send(*UploadPartResponse) error
	Recv() (*UploadPartRequest, error)
	grpc.ServerStream
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.