Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterServiceServer(s grpc.ServiceRegistrar, srv ServiceServer)
- type ServiceClient
- type ServiceServer
- type Service_DownloadObjectClient
- type Service_DownloadObjectServer
- type Service_UploadObjectClient
- type Service_UploadObjectServer
- type UnimplementedServiceServer
- func (UnimplementedServiceServer) CopyObject(context.Context, *storage.CopyObjectRequest) (*storage.CopyObjectResponse, error)
- func (UnimplementedServiceServer) CreateBucket(context.Context, *storage.CreateBucketRequest) (*storage.CreateBucketResponse, error)
- func (UnimplementedServiceServer) DeleteBucket(context.Context, *storage.DeleteBucketRequest) (*storage.DeleteBucketResponse, error)
- func (UnimplementedServiceServer) DeleteObject(context.Context, *storage.DeleteObjectRequest) (*storage.DeleteObjectResponse, error)
- func (UnimplementedServiceServer) DownloadObject(*storage.DownloadObjectRequest, Service_DownloadObjectServer) error
- func (UnimplementedServiceServer) GetBucket(context.Context, *storage.GetBucketRequest) (*storage.GetBucketResponse, error)
- func (UnimplementedServiceServer) GetObject(context.Context, *storage.GetObjectRequest) (*storage.GetObjectResponse, error)
- func (UnimplementedServiceServer) ListBuckets(context.Context, *storage.ListBucketsRequest) (*storage.ListBucketsResponse, error)
- func (UnimplementedServiceServer) ListObjects(context.Context, *storage.ListObjectsRequest) (*storage.ListObjectsResponse, error)
- func (UnimplementedServiceServer) Ping(context.Context, *storage.PingRequest) (*storage.PingResponse, error)
- func (UnimplementedServiceServer) UploadObject(Service_UploadObjectServer) error
- type UnsafeServiceServer
Constants ¶
const ( Service_Ping_FullMethodName = "/nuntio.sdk.api.storage.Service/Ping" Service_CreateBucket_FullMethodName = "/nuntio.sdk.api.storage.Service/CreateBucket" Service_GetBucket_FullMethodName = "/nuntio.sdk.api.storage.Service/GetBucket" Service_ListBuckets_FullMethodName = "/nuntio.sdk.api.storage.Service/ListBuckets" Service_DeleteBucket_FullMethodName = "/nuntio.sdk.api.storage.Service/DeleteBucket" Service_GetObject_FullMethodName = "/nuntio.sdk.api.storage.Service/GetObject" Service_ListObjects_FullMethodName = "/nuntio.sdk.api.storage.Service/ListObjects" Service_DeleteObject_FullMethodName = "/nuntio.sdk.api.storage.Service/DeleteObject" Service_CopyObject_FullMethodName = "/nuntio.sdk.api.storage.Service/CopyObject" Service_UploadObject_FullMethodName = "/nuntio.sdk.api.storage.Service/UploadObject" Service_DownloadObject_FullMethodName = "/nuntio.sdk.api.storage.Service/DownloadObject" )
Variables ¶
var Service_ServiceDesc = grpc.ServiceDesc{ ServiceName: "nuntio.sdk.api.storage.Service", HandlerType: (*ServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Ping", Handler: _Service_Ping_Handler, }, { MethodName: "CreateBucket", Handler: _Service_CreateBucket_Handler, }, { MethodName: "GetBucket", Handler: _Service_GetBucket_Handler, }, { MethodName: "ListBuckets", Handler: _Service_ListBuckets_Handler, }, { MethodName: "DeleteBucket", Handler: _Service_DeleteBucket_Handler, }, { MethodName: "GetObject", Handler: _Service_GetObject_Handler, }, { MethodName: "ListObjects", Handler: _Service_ListObjects_Handler, }, { MethodName: "DeleteObject", Handler: _Service_DeleteObject_Handler, }, { MethodName: "CopyObject", Handler: _Service_CopyObject_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "UploadObject", Handler: _Service_UploadObject_Handler, ClientStreams: true, }, { StreamName: "DownloadObject", Handler: _Service_DownloadObject_Handler, ServerStreams: true, }, }, Metadata: "nuntio/sdk/api/storage/service.proto", }
Service_ServiceDesc is the grpc.ServiceDesc for Service service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterServiceServer ¶
func RegisterServiceServer(s grpc.ServiceRegistrar, srv ServiceServer)
Types ¶
type ServiceClient ¶
type ServiceClient interface { Ping(ctx context.Context, in *storage.PingRequest, opts ...grpc.CallOption) (*storage.PingResponse, error) CreateBucket(ctx context.Context, in *storage.CreateBucketRequest, opts ...grpc.CallOption) (*storage.CreateBucketResponse, error) GetBucket(ctx context.Context, in *storage.GetBucketRequest, opts ...grpc.CallOption) (*storage.GetBucketResponse, error) ListBuckets(ctx context.Context, in *storage.ListBucketsRequest, opts ...grpc.CallOption) (*storage.ListBucketsResponse, error) DeleteBucket(ctx context.Context, in *storage.DeleteBucketRequest, opts ...grpc.CallOption) (*storage.DeleteBucketResponse, error) GetObject(ctx context.Context, in *storage.GetObjectRequest, opts ...grpc.CallOption) (*storage.GetObjectResponse, error) ListObjects(ctx context.Context, in *storage.ListObjectsRequest, opts ...grpc.CallOption) (*storage.ListObjectsResponse, error) DeleteObject(ctx context.Context, in *storage.DeleteObjectRequest, opts ...grpc.CallOption) (*storage.DeleteObjectResponse, error) CopyObject(ctx context.Context, in *storage.CopyObjectRequest, opts ...grpc.CallOption) (*storage.CopyObjectResponse, error) UploadObject(ctx context.Context, opts ...grpc.CallOption) (Service_UploadObjectClient, error) DownloadObject(ctx context.Context, in *storage.DownloadObjectRequest, opts ...grpc.CallOption) (Service_DownloadObjectClient, error) }
ServiceClient is the client API for Service service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.golang.ir/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewServiceClient ¶
func NewServiceClient(cc grpc.ClientConnInterface) ServiceClient
type ServiceServer ¶
type ServiceServer interface { Ping(context.Context, *storage.PingRequest) (*storage.PingResponse, error) CreateBucket(context.Context, *storage.CreateBucketRequest) (*storage.CreateBucketResponse, error) GetBucket(context.Context, *storage.GetBucketRequest) (*storage.GetBucketResponse, error) ListBuckets(context.Context, *storage.ListBucketsRequest) (*storage.ListBucketsResponse, error) DeleteBucket(context.Context, *storage.DeleteBucketRequest) (*storage.DeleteBucketResponse, error) GetObject(context.Context, *storage.GetObjectRequest) (*storage.GetObjectResponse, error) ListObjects(context.Context, *storage.ListObjectsRequest) (*storage.ListObjectsResponse, error) DeleteObject(context.Context, *storage.DeleteObjectRequest) (*storage.DeleteObjectResponse, error) CopyObject(context.Context, *storage.CopyObjectRequest) (*storage.CopyObjectResponse, error) UploadObject(Service_UploadObjectServer) error DownloadObject(*storage.DownloadObjectRequest, Service_DownloadObjectServer) error }
ServiceServer is the server API for Service service. All implementations should embed UnimplementedServiceServer for forward compatibility
type Service_DownloadObjectClient ¶
type Service_DownloadObjectClient interface { Recv() (*storage.DownloadObjectResponse, error) grpc.ClientStream }
type Service_DownloadObjectServer ¶
type Service_DownloadObjectServer interface { Send(*storage.DownloadObjectResponse) error grpc.ServerStream }
type Service_UploadObjectClient ¶
type Service_UploadObjectClient interface { Send(*storage.UploadObjectRequest) error CloseAndRecv() (*storage.UploadObjectResponse, error) grpc.ClientStream }
type Service_UploadObjectServer ¶
type Service_UploadObjectServer interface { SendAndClose(*storage.UploadObjectResponse) error Recv() (*storage.UploadObjectRequest, error) grpc.ServerStream }
type UnimplementedServiceServer ¶
type UnimplementedServiceServer struct { }
UnimplementedServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedServiceServer) CopyObject ¶
func (UnimplementedServiceServer) CopyObject(context.Context, *storage.CopyObjectRequest) (*storage.CopyObjectResponse, error)
func (UnimplementedServiceServer) CreateBucket ¶
func (UnimplementedServiceServer) CreateBucket(context.Context, *storage.CreateBucketRequest) (*storage.CreateBucketResponse, error)
func (UnimplementedServiceServer) DeleteBucket ¶
func (UnimplementedServiceServer) DeleteBucket(context.Context, *storage.DeleteBucketRequest) (*storage.DeleteBucketResponse, error)
func (UnimplementedServiceServer) DeleteObject ¶
func (UnimplementedServiceServer) DeleteObject(context.Context, *storage.DeleteObjectRequest) (*storage.DeleteObjectResponse, error)
func (UnimplementedServiceServer) DownloadObject ¶
func (UnimplementedServiceServer) DownloadObject(*storage.DownloadObjectRequest, Service_DownloadObjectServer) error
func (UnimplementedServiceServer) GetBucket ¶
func (UnimplementedServiceServer) GetBucket(context.Context, *storage.GetBucketRequest) (*storage.GetBucketResponse, error)
func (UnimplementedServiceServer) GetObject ¶
func (UnimplementedServiceServer) GetObject(context.Context, *storage.GetObjectRequest) (*storage.GetObjectResponse, error)
func (UnimplementedServiceServer) ListBuckets ¶
func (UnimplementedServiceServer) ListBuckets(context.Context, *storage.ListBucketsRequest) (*storage.ListBucketsResponse, error)
func (UnimplementedServiceServer) ListObjects ¶
func (UnimplementedServiceServer) ListObjects(context.Context, *storage.ListObjectsRequest) (*storage.ListObjectsResponse, error)
func (UnimplementedServiceServer) Ping ¶
func (UnimplementedServiceServer) Ping(context.Context, *storage.PingRequest) (*storage.PingResponse, error)
func (UnimplementedServiceServer) UploadObject ¶
func (UnimplementedServiceServer) UploadObject(Service_UploadObjectServer) error
type UnsafeServiceServer ¶
type UnsafeServiceServer interface {
// contains filtered or unexported methods
}
UnsafeServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ServiceServer will result in compilation errors.