objectstorev1grpc

package
v1.3.0-20230622223511-... Latest Latest
Warning

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

Go to latest
Published: unknown License: Apache-2.0 Imports: 5 Imported by: 1

Documentation

Index

Constants

View Source
const (
	ObjectStoreService_Metadata_FullMethodName                         = "/cloudidl.objectstore.v1.ObjectStoreService/Metadata"
	ObjectStoreService_Head_FullMethodName                             = "/cloudidl.objectstore.v1.ObjectStoreService/Head"
	ObjectStoreService_Put_FullMethodName                              = "/cloudidl.objectstore.v1.ObjectStoreService/Put"
	ObjectStoreService_Get_FullMethodName                              = "/cloudidl.objectstore.v1.ObjectStoreService/Get"
	ObjectStoreService_Delete_FullMethodName                           = "/cloudidl.objectstore.v1.ObjectStoreService/Delete"
	ObjectStoreService_CreateLargeObjectUploadLocation_FullMethodName  = "/cloudidl.objectstore.v1.ObjectStoreService/CreateLargeObjectUploadLocation"
	ObjectStoreService_TerminateLargeObjectUpload_FullMethodName       = "/cloudidl.objectstore.v1.ObjectStoreService/TerminateLargeObjectUpload"
	ObjectStoreService_CreateLargeObjectDownloadLink_FullMethodName    = "/cloudidl.objectstore.v1.ObjectStoreService/CreateLargeObjectDownloadLink"
	ObjectStoreService_StartLargeObjectUpload_FullMethodName           = "/cloudidl.objectstore.v1.ObjectStoreService/StartLargeObjectUpload"
	ObjectStoreService_UploadPart_FullMethodName                       = "/cloudidl.objectstore.v1.ObjectStoreService/UploadPart"
	ObjectStoreService_ListInProgressLargeObjectUploads_FullMethodName = "/cloudidl.objectstore.v1.ObjectStoreService/ListInProgressLargeObjectUploads"
	ObjectStoreService_DownloadPart_FullMethodName                     = "/cloudidl.objectstore.v1.ObjectStoreService/DownloadPart"
)

Variables

View Source
var ObjectStoreService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cloudidl.objectstore.v1.ObjectStoreService",
	HandlerType: (*ObjectStoreServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Metadata",
			Handler:    _ObjectStoreService_Metadata_Handler,
		},
		{
			MethodName: "Head",
			Handler:    _ObjectStoreService_Head_Handler,
		},
		{
			MethodName: "Put",
			Handler:    _ObjectStoreService_Put_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _ObjectStoreService_Get_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _ObjectStoreService_Delete_Handler,
		},
		{
			MethodName: "TerminateLargeObjectUpload",
			Handler:    _ObjectStoreService_TerminateLargeObjectUpload_Handler,
		},
		{
			MethodName: "StartLargeObjectUpload",
			Handler:    _ObjectStoreService_StartLargeObjectUpload_Handler,
		},
		{
			MethodName: "ListInProgressLargeObjectUploads",
			Handler:    _ObjectStoreService_ListInProgressLargeObjectUploads_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "CreateLargeObjectUploadLocation",
			Handler:       _ObjectStoreService_CreateLargeObjectUploadLocation_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "CreateLargeObjectDownloadLink",
			Handler:       _ObjectStoreService_CreateLargeObjectDownloadLink_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "UploadPart",
			Handler:       _ObjectStoreService_UploadPart_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "DownloadPart",
			Handler:       _ObjectStoreService_DownloadPart_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "objectstore/service.proto",
}

ObjectStoreService_ServiceDesc is the grpc.ServiceDesc for ObjectStoreService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterObjectStoreServiceServer

func RegisterObjectStoreServiceServer(s grpc.ServiceRegistrar, srv ObjectStoreServiceServer)

Types

type ObjectStoreServiceClient

type ObjectStoreServiceClient interface {
	// Metadata returns the metadata for the object store
	Metadata(ctx context.Context, in *objectstore.MetadataRequest, opts ...grpc.CallOption) (*objectstore.MetadataResponse, error)
	// Head returns the metadata for an object
	Head(ctx context.Context, in *objectstore.HeadRequest, opts ...grpc.CallOption) (*objectstore.HeadResponse, error)
	// Put creates or updates an object. The maximum size of an object is 1GB.
	Put(ctx context.Context, in *objectstore.PutRequest, opts ...grpc.CallOption) (*objectstore.PutResponse, error)
	// Get returns the contents of an object
	Get(ctx context.Context, in *objectstore.GetRequest, opts ...grpc.CallOption) (*objectstore.GetResponse, error)
	// Delete deletes an object
	Delete(ctx context.Context, in *objectstore.DeleteRequest, opts ...grpc.CallOption) (*objectstore.DeleteResponse, error)
	// Using Signed URLs
	CreateLargeObjectUploadLocation(ctx context.Context, in *objectstore.CreateLargeObjectUploadLocationRequest, opts ...grpc.CallOption) (ObjectStoreService_CreateLargeObjectUploadLocationClient, error)
	TerminateLargeObjectUpload(ctx context.Context, in *objectstore.TerminateLargeObjectUploadRequest, opts ...grpc.CallOption) (*objectstore.TerminateLargeObjectUploadResponse, error)
	CreateLargeObjectDownloadLink(ctx context.Context, in *objectstore.CreateLargeObjectDownloadLinkRequest, opts ...grpc.CallOption) (ObjectStoreService_CreateLargeObjectDownloadLinkClient, error)
	// Using straight proxying
	StartLargeObjectUpload(ctx context.Context, in *objectstore.StartLargeObjectUploadRequest, opts ...grpc.CallOption) (*objectstore.StartLargeObjectUploadResponse, error)
	UploadPart(ctx context.Context, opts ...grpc.CallOption) (ObjectStoreService_UploadPartClient, error)
	ListInProgressLargeObjectUploads(ctx context.Context, in *objectstore.ListInProgressLargeObjectUploadsRequest, opts ...grpc.CallOption) (*objectstore.ListInProgressLargeObjectUploadsResponse, error)
	DownloadPart(ctx context.Context, in *objectstore.DownloadPartRequest, opts ...grpc.CallOption) (ObjectStoreService_DownloadPartClient, error)
}

ObjectStoreServiceClient is the client API for ObjectStoreService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewObjectStoreServiceClient

func NewObjectStoreServiceClient(cc grpc.ClientConnInterface) ObjectStoreServiceClient

type ObjectStoreServiceServer

type ObjectStoreServiceServer interface {
	// Metadata returns the metadata for the object store
	Metadata(context.Context, *objectstore.MetadataRequest) (*objectstore.MetadataResponse, error)
	// Head returns the metadata for an object
	Head(context.Context, *objectstore.HeadRequest) (*objectstore.HeadResponse, error)
	// Put creates or updates an object. The maximum size of an object is 1GB.
	Put(context.Context, *objectstore.PutRequest) (*objectstore.PutResponse, error)
	// Get returns the contents of an object
	Get(context.Context, *objectstore.GetRequest) (*objectstore.GetResponse, error)
	// Delete deletes an object
	Delete(context.Context, *objectstore.DeleteRequest) (*objectstore.DeleteResponse, error)
	// Using Signed URLs
	CreateLargeObjectUploadLocation(*objectstore.CreateLargeObjectUploadLocationRequest, ObjectStoreService_CreateLargeObjectUploadLocationServer) error
	TerminateLargeObjectUpload(context.Context, *objectstore.TerminateLargeObjectUploadRequest) (*objectstore.TerminateLargeObjectUploadResponse, error)
	CreateLargeObjectDownloadLink(*objectstore.CreateLargeObjectDownloadLinkRequest, ObjectStoreService_CreateLargeObjectDownloadLinkServer) error
	// Using straight proxying
	StartLargeObjectUpload(context.Context, *objectstore.StartLargeObjectUploadRequest) (*objectstore.StartLargeObjectUploadResponse, error)
	UploadPart(ObjectStoreService_UploadPartServer) error
	ListInProgressLargeObjectUploads(context.Context, *objectstore.ListInProgressLargeObjectUploadsRequest) (*objectstore.ListInProgressLargeObjectUploadsResponse, error)
	DownloadPart(*objectstore.DownloadPartRequest, ObjectStoreService_DownloadPartServer) error
}

ObjectStoreServiceServer is the server API for ObjectStoreService service. All implementations should embed UnimplementedObjectStoreServiceServer for forward compatibility

type ObjectStoreService_CreateLargeObjectDownloadLinkClient

type ObjectStoreService_CreateLargeObjectDownloadLinkClient interface {
	Recv() (*objectstore.CreateLargeObjectDownloadLinkResponse, error)
	grpc.ClientStream
}

type ObjectStoreService_CreateLargeObjectDownloadLinkServer

type ObjectStoreService_CreateLargeObjectDownloadLinkServer interface {
	Send(*objectstore.CreateLargeObjectDownloadLinkResponse) error
	grpc.ServerStream
}

type ObjectStoreService_CreateLargeObjectUploadLocationClient

type ObjectStoreService_CreateLargeObjectUploadLocationClient interface {
	Recv() (*objectstore.CreateLargeObjectUploadLocationResponse, error)
	grpc.ClientStream
}

type ObjectStoreService_CreateLargeObjectUploadLocationServer

type ObjectStoreService_CreateLargeObjectUploadLocationServer interface {
	Send(*objectstore.CreateLargeObjectUploadLocationResponse) error
	grpc.ServerStream
}

type ObjectStoreService_DownloadPartClient

type ObjectStoreService_DownloadPartClient interface {
	Recv() (*objectstore.DownloadPartResponse, error)
	grpc.ClientStream
}

type ObjectStoreService_DownloadPartServer

type ObjectStoreService_DownloadPartServer interface {
	Send(*objectstore.DownloadPartResponse) error
	grpc.ServerStream
}

type ObjectStoreService_UploadPartClient

type ObjectStoreService_UploadPartClient interface {
	Send(*objectstore.UploadPartRequest) error
	CloseAndRecv() (*objectstore.UploadPartResponse, error)
	grpc.ClientStream
}

type ObjectStoreService_UploadPartServer

type ObjectStoreService_UploadPartServer interface {
	SendAndClose(*objectstore.UploadPartResponse) error
	Recv() (*objectstore.UploadPartRequest, error)
	grpc.ServerStream
}

type UnimplementedObjectStoreServiceServer

type UnimplementedObjectStoreServiceServer struct {
}

UnimplementedObjectStoreServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedObjectStoreServiceServer) CreateLargeObjectUploadLocation

func (UnimplementedObjectStoreServiceServer) Delete

func (UnimplementedObjectStoreServiceServer) DownloadPart

func (UnimplementedObjectStoreServiceServer) Get

func (UnimplementedObjectStoreServiceServer) Head

func (UnimplementedObjectStoreServiceServer) ListInProgressLargeObjectUploads

func (UnimplementedObjectStoreServiceServer) Metadata

func (UnimplementedObjectStoreServiceServer) Put

func (UnimplementedObjectStoreServiceServer) StartLargeObjectUpload

func (UnimplementedObjectStoreServiceServer) TerminateLargeObjectUpload

func (UnimplementedObjectStoreServiceServer) UploadPart

type UnsafeObjectStoreServiceServer

type UnsafeObjectStoreServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeObjectStoreServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ObjectStoreServiceServer will result in compilation errors.

Jump to

Keyboard shortcuts

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