Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterAdminServiceServer(s grpc.ServiceRegistrar, srv AdminServiceServer)
- func RegisterMigrationServiceServer(s grpc.ServiceRegistrar, srv MigrationServiceServer)
- func RegisterPublicServiceServer(s grpc.ServiceRegistrar, srv PublicServiceServer)
- type AdminServiceClient
- type AdminServiceServer
- type MigrationServiceClient
- type MigrationServiceServer
- type PublicServiceClient
- type PublicServiceServer
- type PublicService_UploadClient
- type PublicService_UploadServer
- type UnimplementedAdminServiceServer
- func (UnimplementedAdminServiceServer) BucketExists(context.Context, *v1alpha1.AdminServiceBucketExistsRequest) (*v1alpha1.AdminServiceBucketExistsResponse, error)
- func (UnimplementedAdminServiceServer) CreateBucket(context.Context, *v1alpha1.AdminServiceCreateBucketRequest) (*v1alpha1.AdminServiceCreateBucketResponse, error)
- func (UnimplementedAdminServiceServer) CreateNamespace(context.Context, *v1alpha1.AdminServiceCreateNamespaceRequest) (*v1alpha1.AdminServiceCreateNamespaceResponse, error)
- func (UnimplementedAdminServiceServer) DeleteBucket(context.Context, *v1alpha1.AdminServiceDeleteBucketRequest) (*v1alpha1.AdminServiceDeleteBucketResponse, error)
- func (UnimplementedAdminServiceServer) GetBucket(context.Context, *v1alpha1.AdminServiceGetBucketRequest) (*v1alpha1.AdminServiceGetBucketResponse, error)
- func (UnimplementedAdminServiceServer) GetNamespace(context.Context, *v1alpha1.AdminServiceGetNamespaceRequest) (*v1alpha1.AdminServiceGetNamespaceResponse, error)
- func (UnimplementedAdminServiceServer) ListBuckets(context.Context, *v1alpha1.AdminServiceListBucketsRequest) (*v1alpha1.AdminServiceListBucketsResponse, error)
- func (UnimplementedAdminServiceServer) ListFiles(context.Context, *v1alpha1.AdminServiceListFilesRequest) (*v1alpha1.AdminServiceListFilesResponse, error)
- func (UnimplementedAdminServiceServer) Ping(context.Context, *v1alpha1.AdminServicePingRequest) (*v1alpha1.AdminServicePingResponse, error)
- type UnimplementedMigrationServiceServer
- func (UnimplementedMigrationServiceServer) FirebaseCredentials(context.Context, *v1alpha1.MigrationServiceFirebaseCredentialsRequest) (*v1alpha1.MigrationServiceFirebaseCredentialsResponse, error)
- func (UnimplementedMigrationServiceServer) Ping(context.Context, *v1alpha1.MigrationServicePingRequest) (*v1alpha1.MigrationServicePingResponse, error)
- type UnimplementedPublicServiceServer
- func (UnimplementedPublicServiceServer) Delete(context.Context, *v1alpha1.PublicServiceDeleteRequest) (*v1alpha1.PublicServiceDeleteResponse, error)
- func (UnimplementedPublicServiceServer) Download(context.Context, *v1alpha1.PublicServiceDownloadFileRequest) (*v1alpha1.PublicServiceDownloadFileResponse, error)
- func (UnimplementedPublicServiceServer) GenerateLink(context.Context, *v1alpha1.PublicServiceGenerateLinkRequest) (*v1alpha1.PublicServiceGenerateLinkResponse, error)
- func (UnimplementedPublicServiceServer) Ping(context.Context, *v1alpha1.PublicServicePingRequest) (*v1alpha1.PublicServicePingResponse, error)
- func (UnimplementedPublicServiceServer) Upload(PublicService_UploadServer) error
- type UnsafeAdminServiceServer
- type UnsafeMigrationServiceServer
- type UnsafePublicServiceServer
Constants ¶
const ( AdminService_Ping_FullMethodName = "/nuntio.storage.v1alpha1.AdminService/Ping" AdminService_CreateNamespace_FullMethodName = "/nuntio.storage.v1alpha1.AdminService/CreateNamespace" AdminService_GetNamespace_FullMethodName = "/nuntio.storage.v1alpha1.AdminService/GetNamespace" AdminService_CreateBucket_FullMethodName = "/nuntio.storage.v1alpha1.AdminService/CreateBucket" AdminService_DeleteBucket_FullMethodName = "/nuntio.storage.v1alpha1.AdminService/DeleteBucket" AdminService_BucketExists_FullMethodName = "/nuntio.storage.v1alpha1.AdminService/BucketExists" AdminService_GetBucket_FullMethodName = "/nuntio.storage.v1alpha1.AdminService/GetBucket" AdminService_ListBuckets_FullMethodName = "/nuntio.storage.v1alpha1.AdminService/ListBuckets" AdminService_ListFiles_FullMethodName = "/nuntio.storage.v1alpha1.AdminService/ListFiles" )
const ( MigrationService_Ping_FullMethodName = "/nuntio.storage.v1alpha1.MigrationService/Ping" MigrationService_FirebaseCredentials_FullMethodName = "/nuntio.storage.v1alpha1.MigrationService/FirebaseCredentials" )
const ( PublicService_Ping_FullMethodName = "/nuntio.storage.v1alpha1.PublicService/Ping" PublicService_Delete_FullMethodName = "/nuntio.storage.v1alpha1.PublicService/Delete" PublicService_GenerateLink_FullMethodName = "/nuntio.storage.v1alpha1.PublicService/GenerateLink" PublicService_Upload_FullMethodName = "/nuntio.storage.v1alpha1.PublicService/Upload" PublicService_Download_FullMethodName = "/nuntio.storage.v1alpha1.PublicService/Download" )
Variables ¶
var AdminService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "nuntio.storage.v1alpha1.AdminService", HandlerType: (*AdminServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Ping", Handler: _AdminService_Ping_Handler, }, { MethodName: "CreateNamespace", Handler: _AdminService_CreateNamespace_Handler, }, { MethodName: "GetNamespace", Handler: _AdminService_GetNamespace_Handler, }, { MethodName: "CreateBucket", Handler: _AdminService_CreateBucket_Handler, }, { MethodName: "DeleteBucket", Handler: _AdminService_DeleteBucket_Handler, }, { MethodName: "BucketExists", Handler: _AdminService_BucketExists_Handler, }, { MethodName: "GetBucket", Handler: _AdminService_GetBucket_Handler, }, { MethodName: "ListBuckets", Handler: _AdminService_ListBuckets_Handler, }, { MethodName: "ListFiles", Handler: _AdminService_ListFiles_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "nuntio/storage/v1alpha1/storage_admin.proto", }
AdminService_ServiceDesc is the grpc.ServiceDesc for AdminService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var MigrationService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "nuntio.storage.v1alpha1.MigrationService", HandlerType: (*MigrationServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Ping", Handler: _MigrationService_Ping_Handler, }, { MethodName: "FirebaseCredentials", Handler: _MigrationService_FirebaseCredentials_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "nuntio/storage/v1alpha1/storage_migration.proto", }
MigrationService_ServiceDesc is the grpc.ServiceDesc for MigrationService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var PublicService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "nuntio.storage.v1alpha1.PublicService", HandlerType: (*PublicServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Ping", Handler: _PublicService_Ping_Handler, }, { MethodName: "Delete", Handler: _PublicService_Delete_Handler, }, { MethodName: "GenerateLink", Handler: _PublicService_GenerateLink_Handler, }, { MethodName: "Download", Handler: _PublicService_Download_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Upload", Handler: _PublicService_Upload_Handler, ClientStreams: true, }, }, Metadata: "nuntio/storage/v1alpha1/storage_public.proto", }
PublicService_ServiceDesc is the grpc.ServiceDesc for PublicService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterAdminServiceServer ¶
func RegisterAdminServiceServer(s grpc.ServiceRegistrar, srv AdminServiceServer)
func RegisterMigrationServiceServer ¶
func RegisterMigrationServiceServer(s grpc.ServiceRegistrar, srv MigrationServiceServer)
func RegisterPublicServiceServer ¶
func RegisterPublicServiceServer(s grpc.ServiceRegistrar, srv PublicServiceServer)
Types ¶
type AdminServiceClient ¶
type AdminServiceClient interface { // Ping returns an empty response used to check if the server is live Ping(ctx context.Context, in *v1alpha1.AdminServicePingRequest, opts ...grpc.CallOption) (*v1alpha1.AdminServicePingResponse, error) // Creates a namespace in the repository CreateNamespace(ctx context.Context, in *v1alpha1.AdminServiceCreateNamespaceRequest, opts ...grpc.CallOption) (*v1alpha1.AdminServiceCreateNamespaceResponse, error) // Fetches a namespace from the repository GetNamespace(ctx context.Context, in *v1alpha1.AdminServiceGetNamespaceRequest, opts ...grpc.CallOption) (*v1alpha1.AdminServiceGetNamespaceResponse, error) // Create initializes the storage interface for a given namespace CreateBucket(ctx context.Context, in *v1alpha1.AdminServiceCreateBucketRequest, opts ...grpc.CallOption) (*v1alpha1.AdminServiceCreateBucketResponse, error) // Delete removes the storage ressources for a given namespace DeleteBucket(ctx context.Context, in *v1alpha1.AdminServiceDeleteBucketRequest, opts ...grpc.CallOption) (*v1alpha1.AdminServiceDeleteBucketResponse, error) // BucketExists checks if the bucket exists in the storage provider BucketExists(ctx context.Context, in *v1alpha1.AdminServiceBucketExistsRequest, opts ...grpc.CallOption) (*v1alpha1.AdminServiceBucketExistsResponse, error) // GetBucket GetBucket(ctx context.Context, in *v1alpha1.AdminServiceGetBucketRequest, opts ...grpc.CallOption) (*v1alpha1.AdminServiceGetBucketResponse, error) // ListBuckets list buckets in a namespace ListBuckets(ctx context.Context, in *v1alpha1.AdminServiceListBucketsRequest, opts ...grpc.CallOption) (*v1alpha1.AdminServiceListBucketsResponse, error) // ListFiles returns a list of all folders and files in a path ListFiles(ctx context.Context, in *v1alpha1.AdminServiceListFilesRequest, opts ...grpc.CallOption) (*v1alpha1.AdminServiceListFilesResponse, error) }
AdminServiceClient is the client API for AdminService 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 NewAdminServiceClient ¶
func NewAdminServiceClient(cc grpc.ClientConnInterface) AdminServiceClient
type AdminServiceServer ¶
type AdminServiceServer interface { // Ping returns an empty response used to check if the server is live Ping(context.Context, *v1alpha1.AdminServicePingRequest) (*v1alpha1.AdminServicePingResponse, error) // Creates a namespace in the repository CreateNamespace(context.Context, *v1alpha1.AdminServiceCreateNamespaceRequest) (*v1alpha1.AdminServiceCreateNamespaceResponse, error) // Fetches a namespace from the repository GetNamespace(context.Context, *v1alpha1.AdminServiceGetNamespaceRequest) (*v1alpha1.AdminServiceGetNamespaceResponse, error) // Create initializes the storage interface for a given namespace CreateBucket(context.Context, *v1alpha1.AdminServiceCreateBucketRequest) (*v1alpha1.AdminServiceCreateBucketResponse, error) // Delete removes the storage ressources for a given namespace DeleteBucket(context.Context, *v1alpha1.AdminServiceDeleteBucketRequest) (*v1alpha1.AdminServiceDeleteBucketResponse, error) // BucketExists checks if the bucket exists in the storage provider BucketExists(context.Context, *v1alpha1.AdminServiceBucketExistsRequest) (*v1alpha1.AdminServiceBucketExistsResponse, error) // GetBucket GetBucket(context.Context, *v1alpha1.AdminServiceGetBucketRequest) (*v1alpha1.AdminServiceGetBucketResponse, error) // ListBuckets list buckets in a namespace ListBuckets(context.Context, *v1alpha1.AdminServiceListBucketsRequest) (*v1alpha1.AdminServiceListBucketsResponse, error) // ListFiles returns a list of all folders and files in a path ListFiles(context.Context, *v1alpha1.AdminServiceListFilesRequest) (*v1alpha1.AdminServiceListFilesResponse, error) }
AdminServiceServer is the server API for AdminService service. All implementations should embed UnimplementedAdminServiceServer for forward compatibility
type MigrationServiceClient ¶
type MigrationServiceClient interface { // Ping -> Pong Ping(ctx context.Context, in *v1alpha1.MigrationServicePingRequest, opts ...grpc.CallOption) (*v1alpha1.MigrationServicePingResponse, error) // Migrate your users from Firebase FirebaseCredentials(ctx context.Context, in *v1alpha1.MigrationServiceFirebaseCredentialsRequest, opts ...grpc.CallOption) (*v1alpha1.MigrationServiceFirebaseCredentialsResponse, error) }
MigrationServiceClient is the client API for MigrationService 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 NewMigrationServiceClient ¶
func NewMigrationServiceClient(cc grpc.ClientConnInterface) MigrationServiceClient
type MigrationServiceServer ¶
type MigrationServiceServer interface { // Ping -> Pong Ping(context.Context, *v1alpha1.MigrationServicePingRequest) (*v1alpha1.MigrationServicePingResponse, error) // Migrate your users from Firebase FirebaseCredentials(context.Context, *v1alpha1.MigrationServiceFirebaseCredentialsRequest) (*v1alpha1.MigrationServiceFirebaseCredentialsResponse, error) }
MigrationServiceServer is the server API for MigrationService service. All implementations should embed UnimplementedMigrationServiceServer for forward compatibility
type PublicServiceClient ¶
type PublicServiceClient interface { // Ping returns an empty response used to check if the server is live Ping(ctx context.Context, in *v1alpha1.PublicServicePingRequest, opts ...grpc.CallOption) (*v1alpha1.PublicServicePingResponse, error) // Delete deletes requested file Delete(ctx context.Context, in *v1alpha1.PublicServiceDeleteRequest, opts ...grpc.CallOption) (*v1alpha1.PublicServiceDeleteResponse, error) // GenerateLink geneates a link to a specific file GenerateLink(ctx context.Context, in *v1alpha1.PublicServiceGenerateLinkRequest, opts ...grpc.CallOption) (*v1alpha1.PublicServiceGenerateLinkResponse, error) // Upload uploads a file to the server Upload(ctx context.Context, opts ...grpc.CallOption) (PublicService_UploadClient, error) // DownloadFile returns the butes of a file Download(ctx context.Context, in *v1alpha1.PublicServiceDownloadFileRequest, opts ...grpc.CallOption) (*v1alpha1.PublicServiceDownloadFileResponse, error) }
PublicServiceClient is the client API for PublicService 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 NewPublicServiceClient ¶
func NewPublicServiceClient(cc grpc.ClientConnInterface) PublicServiceClient
type PublicServiceServer ¶
type PublicServiceServer interface { // Ping returns an empty response used to check if the server is live Ping(context.Context, *v1alpha1.PublicServicePingRequest) (*v1alpha1.PublicServicePingResponse, error) // Delete deletes requested file Delete(context.Context, *v1alpha1.PublicServiceDeleteRequest) (*v1alpha1.PublicServiceDeleteResponse, error) // GenerateLink geneates a link to a specific file GenerateLink(context.Context, *v1alpha1.PublicServiceGenerateLinkRequest) (*v1alpha1.PublicServiceGenerateLinkResponse, error) // Upload uploads a file to the server Upload(PublicService_UploadServer) error // DownloadFile returns the butes of a file Download(context.Context, *v1alpha1.PublicServiceDownloadFileRequest) (*v1alpha1.PublicServiceDownloadFileResponse, error) }
PublicServiceServer is the server API for PublicService service. All implementations should embed UnimplementedPublicServiceServer for forward compatibility
type PublicService_UploadClient ¶
type PublicService_UploadClient interface { Send(*v1alpha1.PublicServiceUploadRequest) error CloseAndRecv() (*v1alpha1.PublicServiceUploadResponse, error) grpc.ClientStream }
type PublicService_UploadServer ¶
type PublicService_UploadServer interface { SendAndClose(*v1alpha1.PublicServiceUploadResponse) error Recv() (*v1alpha1.PublicServiceUploadRequest, error) grpc.ServerStream }
type UnimplementedAdminServiceServer ¶
type UnimplementedAdminServiceServer struct { }
UnimplementedAdminServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedAdminServiceServer) BucketExists ¶
func (UnimplementedAdminServiceServer) BucketExists(context.Context, *v1alpha1.AdminServiceBucketExistsRequest) (*v1alpha1.AdminServiceBucketExistsResponse, error)
func (UnimplementedAdminServiceServer) CreateBucket ¶
func (UnimplementedAdminServiceServer) CreateBucket(context.Context, *v1alpha1.AdminServiceCreateBucketRequest) (*v1alpha1.AdminServiceCreateBucketResponse, error)
func (UnimplementedAdminServiceServer) CreateNamespace ¶
func (UnimplementedAdminServiceServer) CreateNamespace(context.Context, *v1alpha1.AdminServiceCreateNamespaceRequest) (*v1alpha1.AdminServiceCreateNamespaceResponse, error)
func (UnimplementedAdminServiceServer) DeleteBucket ¶
func (UnimplementedAdminServiceServer) DeleteBucket(context.Context, *v1alpha1.AdminServiceDeleteBucketRequest) (*v1alpha1.AdminServiceDeleteBucketResponse, error)
func (UnimplementedAdminServiceServer) GetBucket ¶
func (UnimplementedAdminServiceServer) GetBucket(context.Context, *v1alpha1.AdminServiceGetBucketRequest) (*v1alpha1.AdminServiceGetBucketResponse, error)
func (UnimplementedAdminServiceServer) GetNamespace ¶
func (UnimplementedAdminServiceServer) GetNamespace(context.Context, *v1alpha1.AdminServiceGetNamespaceRequest) (*v1alpha1.AdminServiceGetNamespaceResponse, error)
func (UnimplementedAdminServiceServer) ListBuckets ¶
func (UnimplementedAdminServiceServer) ListBuckets(context.Context, *v1alpha1.AdminServiceListBucketsRequest) (*v1alpha1.AdminServiceListBucketsResponse, error)
func (UnimplementedAdminServiceServer) ListFiles ¶
func (UnimplementedAdminServiceServer) ListFiles(context.Context, *v1alpha1.AdminServiceListFilesRequest) (*v1alpha1.AdminServiceListFilesResponse, error)
func (UnimplementedAdminServiceServer) Ping ¶
type UnimplementedMigrationServiceServer ¶
type UnimplementedMigrationServiceServer struct { }
UnimplementedMigrationServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedMigrationServiceServer) FirebaseCredentials ¶
func (UnimplementedMigrationServiceServer) FirebaseCredentials(context.Context, *v1alpha1.MigrationServiceFirebaseCredentialsRequest) (*v1alpha1.MigrationServiceFirebaseCredentialsResponse, error)
func (UnimplementedMigrationServiceServer) Ping ¶
type UnimplementedPublicServiceServer ¶
type UnimplementedPublicServiceServer struct { }
UnimplementedPublicServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedPublicServiceServer) Delete ¶
func (UnimplementedPublicServiceServer) Download ¶
func (UnimplementedPublicServiceServer) GenerateLink ¶
func (UnimplementedPublicServiceServer) GenerateLink(context.Context, *v1alpha1.PublicServiceGenerateLinkRequest) (*v1alpha1.PublicServiceGenerateLinkResponse, error)
func (UnimplementedPublicServiceServer) Ping ¶
func (UnimplementedPublicServiceServer) Upload ¶
func (UnimplementedPublicServiceServer) Upload(PublicService_UploadServer) error
type UnsafeAdminServiceServer ¶
type UnsafeAdminServiceServer interface {
// contains filtered or unexported methods
}
UnsafeAdminServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AdminServiceServer will result in compilation errors.
type UnsafeMigrationServiceServer ¶
type UnsafeMigrationServiceServer interface {
// contains filtered or unexported methods
}
UnsafeMigrationServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MigrationServiceServer will result in compilation errors.
type UnsafePublicServiceServer ¶
type UnsafePublicServiceServer interface {
// contains filtered or unexported methods
}
UnsafePublicServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PublicServiceServer will result in compilation errors.