storagev1alpha1grpc

package
v1.3.0-20230531113704-... Latest Latest
Warning

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

 Go to latest Published: unknown License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

View Source 
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"
)
View Source 
const (
	MigrationService_Ping_FullMethodName                = "/nuntio.storage.v1alpha1.MigrationService/Ping"
	MigrationService_FirebaseCredentials_FullMethodName = "/nuntio.storage.v1alpha1.MigrationService/FirebaseCredentials"
)
View Source 
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

View Source 
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)

View Source 
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)

View Source 
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 

func (UnimplementedAdminServiceServer) Ping(context.Context, *v1alpha1.AdminServicePingRequest) (*v1alpha1.AdminServicePingResponse, error)

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 

func (UnimplementedMigrationServiceServer) Ping(context.Context, *v1alpha1.MigrationServicePingRequest) (*v1alpha1.MigrationServicePingResponse, error)

type UnimplementedPublicServiceServer 

type UnimplementedPublicServiceServer struct {
}

UnimplementedPublicServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedPublicServiceServer) Delete 

func (UnimplementedPublicServiceServer) Delete(context.Context, *v1alpha1.PublicServiceDeleteRequest) (*v1alpha1.PublicServiceDeleteResponse, error)

func (UnimplementedPublicServiceServer) Download 

func (UnimplementedPublicServiceServer) Download(context.Context, *v1alpha1.PublicServiceDownloadFileRequest) (*v1alpha1.PublicServiceDownloadFileResponse, error)
func (UnimplementedPublicServiceServer) GenerateLink(context.Context, *v1alpha1.PublicServiceGenerateLinkRequest) (*v1alpha1.PublicServiceGenerateLinkResponse, error)

func (UnimplementedPublicServiceServer) Ping 

func (UnimplementedPublicServiceServer) Ping(context.Context, *v1alpha1.PublicServicePingRequest) (*v1alpha1.PublicServicePingResponse, error)

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.

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.