v1

package
v0.7.0 Latest Latest
Warning

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

 Go to latest Published: Aug 8, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var CloudProxyService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "github.com.metaprov.modelaapi.services.cloudproxyd.v1.CloudProxyService",
	HandlerType: (*CloudProxyServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Download",
			Handler:    _CloudProxyService_Download_Handler,
		},
		{
			MethodName: "List",
			Handler:    _CloudProxyService_List_Handler,
		},
		{
			MethodName: "Upload",
			Handler:    _CloudProxyService_Upload_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _CloudProxyService_Delete_Handler,
		},
		{
			MethodName: "ExistsInBucket",
			Handler:    _CloudProxyService_ExistsInBucket_Handler,
		},
		{
			MethodName: "BucketExist",
			Handler:    _CloudProxyService_BucketExist_Handler,
		},
		{
			MethodName: "CreateBucket",
			Handler:    _CloudProxyService_CreateBucket_Handler,
		},
		{
			MethodName: "Shutdown",
			Handler:    _CloudProxyService_Shutdown_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/metaprov/modelaapi/services/cloudproxyd/v1/cloudproxyd.proto",
}

CloudProxyService_ServiceDesc is the grpc.ServiceDesc for CloudProxyService 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 File_github_com_metaprov_modelaapi_services_cloudproxyd_v1_cloudproxyd_proto protoreflect.FileDescriptor

Functions

func RegisterCloudProxyServiceServer 

func RegisterCloudProxyServiceServer(s grpc.ServiceRegistrar, srv CloudProxyServiceServer)

Types

type BucketExistRequest added in v0.6.252 

type BucketExistRequest struct {
	Bucket *v1alpha1.VirtualBucket `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	// contains filtered or unexported fields
}

func (*BucketExistRequest) Descriptor deprecated added in v0.6.252 

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

Deprecated: Use BucketExistRequest.ProtoReflect.Descriptor instead.

func (*BucketExistRequest) GetBucket added in v0.6.252 

func (x *BucketExistRequest) GetBucket() *v1alpha1.VirtualBucket

func (*BucketExistRequest) ProtoMessage added in v0.6.252 

func (*BucketExistRequest) ProtoMessage()

func (*BucketExistRequest) ProtoReflect added in v0.6.252 

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

func (*BucketExistRequest) Reset added in v0.6.252 

func (x *BucketExistRequest) Reset()

func (*BucketExistRequest) String added in v0.6.252 

func (x *BucketExistRequest) String() string

type BucketExistResponse added in v0.6.252 

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

func (*BucketExistResponse) Descriptor deprecated added in v0.6.252 

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

Deprecated: Use BucketExistResponse.ProtoReflect.Descriptor instead.

func (*BucketExistResponse) GetExist added in v0.6.252 

func (x *BucketExistResponse) GetExist() bool

func (*BucketExistResponse) ProtoMessage added in v0.6.252 

func (*BucketExistResponse) ProtoMessage()

func (*BucketExistResponse) ProtoReflect added in v0.6.252 

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

func (*BucketExistResponse) Reset added in v0.6.252 

func (x *BucketExistResponse) Reset()

func (*BucketExistResponse) String added in v0.6.252 

func (x *BucketExistResponse) String() string

type CloudProxyServiceClient 

type CloudProxyServiceClient interface {
	Download(ctx context.Context, in *FileDownloadRequest, opts ...grpc.CallOption) (*FileDownloadResponse, error)
	List(ctx context.Context, in *ListObjectsRequest, opts ...grpc.CallOption) (*ListObjectsResponse, error)
	Upload(ctx context.Context, in *FileUploadRequest, opts ...grpc.CallOption) (*FileUploadResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	ExistsInBucket(ctx context.Context, in *ExistsInBucketRequest, opts ...grpc.CallOption) (*ExistsInBucketResponse, error)
	BucketExist(ctx context.Context, in *BucketExistRequest, opts ...grpc.CallOption) (*BucketExistResponse, error)
	CreateBucket(ctx context.Context, in *CreateBucketRequest, opts ...grpc.CallOption) (*CreateBucketResponse, error)
	Shutdown(ctx context.Context, in *ShutdownRequest, opts ...grpc.CallOption) (*ShutdownResponse, error)
}

CloudProxyServiceClient is the client API for CloudProxyService 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 NewCloudProxyServiceClient 

func NewCloudProxyServiceClient(cc grpc.ClientConnInterface) CloudProxyServiceClient

type CloudProxyServiceServer 

type CloudProxyServiceServer interface {
	Download(context.Context, *FileDownloadRequest) (*FileDownloadResponse, error)
	List(context.Context, *ListObjectsRequest) (*ListObjectsResponse, error)
	Upload(context.Context, *FileUploadRequest) (*FileUploadResponse, error)
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	ExistsInBucket(context.Context, *ExistsInBucketRequest) (*ExistsInBucketResponse, error)
	BucketExist(context.Context, *BucketExistRequest) (*BucketExistResponse, error)
	CreateBucket(context.Context, *CreateBucketRequest) (*CreateBucketResponse, error)
	Shutdown(context.Context, *ShutdownRequest) (*ShutdownResponse, error)
	// contains filtered or unexported methods
}

CloudProxyServiceServer is the server API for CloudProxyService service. All implementations must embed UnimplementedCloudProxyServiceServer for forward compatibility

type CreateBucketRequest added in v0.6.252 

type CreateBucketRequest struct {
	Bucket *v1alpha1.VirtualBucket `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateBucketRequest) Descriptor deprecated added in v0.6.252 

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

Deprecated: Use CreateBucketRequest.ProtoReflect.Descriptor instead.

func (*CreateBucketRequest) GetBucket added in v0.6.252 

func (x *CreateBucketRequest) GetBucket() *v1alpha1.VirtualBucket

func (*CreateBucketRequest) ProtoMessage added in v0.6.252 

func (*CreateBucketRequest) ProtoMessage()

func (*CreateBucketRequest) ProtoReflect added in v0.6.252 

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

func (*CreateBucketRequest) Reset added in v0.6.252 

func (x *CreateBucketRequest) Reset()

func (*CreateBucketRequest) String added in v0.6.252 

func (x *CreateBucketRequest) String() string

type CreateBucketResponse added in v0.6.252 

type CreateBucketResponse struct {
	// contains filtered or unexported fields
}

func (*CreateBucketResponse) Descriptor deprecated added in v0.6.252 

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

Deprecated: Use CreateBucketResponse.ProtoReflect.Descriptor instead.

func (*CreateBucketResponse) ProtoMessage added in v0.6.252 

func (*CreateBucketResponse) ProtoMessage()

func (*CreateBucketResponse) ProtoReflect added in v0.6.252 

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

func (*CreateBucketResponse) Reset added in v0.6.252 

func (x *CreateBucketResponse) Reset()

func (*CreateBucketResponse) String added in v0.6.252 

func (x *CreateBucketResponse) String() string

type DeleteRequest added in v0.6.252 

type DeleteRequest struct {
	Bucket *v1alpha1.VirtualBucket `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Key    string                  `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRequest) Descriptor deprecated added in v0.6.252 

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

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) GetBucket added in v0.6.252 

func (x *DeleteRequest) GetBucket() *v1alpha1.VirtualBucket

func (*DeleteRequest) GetKey added in v0.6.252 

func (x *DeleteRequest) GetKey() string

func (*DeleteRequest) ProtoMessage added in v0.6.252 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect added in v0.6.252 

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

func (*DeleteRequest) Reset added in v0.6.252 

func (x *DeleteRequest) Reset()

func (*DeleteRequest) String added in v0.6.252 

func (x *DeleteRequest) String() string

type DeleteResponse added in v0.6.252 

type DeleteResponse struct {
	// contains filtered or unexported fields
}

func (*DeleteResponse) Descriptor deprecated added in v0.6.252 

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

Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.

func (*DeleteResponse) ProtoMessage added in v0.6.252 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) ProtoReflect added in v0.6.252 

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

func (*DeleteResponse) Reset added in v0.6.252 

func (x *DeleteResponse) Reset()

func (*DeleteResponse) String added in v0.6.252 

func (x *DeleteResponse) String() string

type ExistsInBucketRequest added in v0.6.252 

type ExistsInBucketRequest struct {
	Bucket *v1alpha1.VirtualBucket `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Key    string                  `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*ExistsInBucketRequest) Descriptor deprecated added in v0.6.252 

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

Deprecated: Use ExistsInBucketRequest.ProtoReflect.Descriptor instead.

func (*ExistsInBucketRequest) GetBucket added in v0.6.252 

func (x *ExistsInBucketRequest) GetBucket() *v1alpha1.VirtualBucket

func (*ExistsInBucketRequest) GetKey added in v0.6.252 

func (x *ExistsInBucketRequest) GetKey() string

func (*ExistsInBucketRequest) ProtoMessage added in v0.6.252 

func (*ExistsInBucketRequest) ProtoMessage()

func (*ExistsInBucketRequest) ProtoReflect added in v0.6.252 

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

func (*ExistsInBucketRequest) Reset added in v0.6.252 

func (x *ExistsInBucketRequest) Reset()

func (*ExistsInBucketRequest) String added in v0.6.252 

func (x *ExistsInBucketRequest) String() string

type ExistsInBucketResponse added in v0.6.252 

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

func (*ExistsInBucketResponse) Descriptor deprecated added in v0.6.252 

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

Deprecated: Use ExistsInBucketResponse.ProtoReflect.Descriptor instead.

func (*ExistsInBucketResponse) GetExist added in v0.6.252 

func (x *ExistsInBucketResponse) GetExist() bool

func (*ExistsInBucketResponse) ProtoMessage added in v0.6.252 

func (*ExistsInBucketResponse) ProtoMessage()

func (*ExistsInBucketResponse) ProtoReflect added in v0.6.252 

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

func (*ExistsInBucketResponse) Reset added in v0.6.252 

func (x *ExistsInBucketResponse) Reset()

func (*ExistsInBucketResponse) String added in v0.6.252 

func (x *ExistsInBucketResponse) String() string

type FileDownloadRequest 

type FileDownloadRequest struct {
	Key    string                  `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`   // key on the cloud storage
	Path   string                  `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` // local path
	Bucket *v1alpha1.VirtualBucket `protobuf:"bytes,3,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Tenant string                  `protobuf:"bytes,4,opt,name=tenant,proto3" json:"tenant,omitempty"`
	// contains filtered or unexported fields
}

Ask the bucket to download a file

func (*FileDownloadRequest) Descriptor deprecated 

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

Deprecated: Use FileDownloadRequest.ProtoReflect.Descriptor instead.

func (*FileDownloadRequest) GetBucket 

func (x *FileDownloadRequest) GetBucket() *v1alpha1.VirtualBucket

func (*FileDownloadRequest) GetKey 

func (x *FileDownloadRequest) GetKey() string

func (*FileDownloadRequest) GetPath 

func (x *FileDownloadRequest) GetPath() string

func (*FileDownloadRequest) GetTenant 

func (x *FileDownloadRequest) GetTenant() string

func (*FileDownloadRequest) ProtoMessage 

func (*FileDownloadRequest) ProtoMessage()

func (*FileDownloadRequest) ProtoReflect 

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

func (*FileDownloadRequest) Reset 

func (x *FileDownloadRequest) Reset()

func (*FileDownloadRequest) String 

func (x *FileDownloadRequest) String() string

type FileDownloadResponse 

type FileDownloadResponse struct {
	// contains filtered or unexported fields
}

func (*FileDownloadResponse) Descriptor deprecated 

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

Deprecated: Use FileDownloadResponse.ProtoReflect.Descriptor instead.

func (*FileDownloadResponse) ProtoMessage 

func (*FileDownloadResponse) ProtoMessage()

func (*FileDownloadResponse) ProtoReflect 

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

func (*FileDownloadResponse) Reset 

func (x *FileDownloadResponse) Reset()

func (*FileDownloadResponse) String 

func (x *FileDownloadResponse) String() string

type FileUploadRequest 

type FileUploadRequest struct {
	Key    string                  `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`   // key on the cloud storage
	Path   string                  `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` // local path
	Bucket *v1alpha1.VirtualBucket `protobuf:"bytes,3,opt,name=bucket,proto3" json:"bucket,omitempty"`
	// contains filtered or unexported fields
}

func (*FileUploadRequest) Descriptor deprecated 

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

Deprecated: Use FileUploadRequest.ProtoReflect.Descriptor instead.

func (*FileUploadRequest) GetBucket 

func (x *FileUploadRequest) GetBucket() *v1alpha1.VirtualBucket

func (*FileUploadRequest) GetKey 

func (x *FileUploadRequest) GetKey() string

func (*FileUploadRequest) GetPath 

func (x *FileUploadRequest) GetPath() string

func (*FileUploadRequest) ProtoMessage 

func (*FileUploadRequest) ProtoMessage()

func (*FileUploadRequest) ProtoReflect 

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

func (*FileUploadRequest) Reset 

func (x *FileUploadRequest) Reset()

func (*FileUploadRequest) String 

func (x *FileUploadRequest) String() string

type FileUploadResponse 

type FileUploadResponse struct {
	// contains filtered or unexported fields
}

func (*FileUploadResponse) Descriptor deprecated 

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

Deprecated: Use FileUploadResponse.ProtoReflect.Descriptor instead.

func (*FileUploadResponse) ProtoMessage 

func (*FileUploadResponse) ProtoMessage()

func (*FileUploadResponse) ProtoReflect 

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

func (*FileUploadResponse) Reset 

func (x *FileUploadResponse) Reset()

func (*FileUploadResponse) String 

func (x *FileUploadResponse) String() string

type ListObjectsRequest added in v0.5.464 

type ListObjectsRequest struct {
	Prefix string                  `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"` // local path
	Bucket *v1alpha1.VirtualBucket `protobuf:"bytes,2,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Tenant string                  `protobuf:"bytes,3,opt,name=tenant,proto3" json:"tenant,omitempty"`
	// contains filtered or unexported fields
}

func (*ListObjectsRequest) Descriptor deprecated added in v0.5.464 

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

Deprecated: Use ListObjectsRequest.ProtoReflect.Descriptor instead.

func (*ListObjectsRequest) GetBucket added in v0.5.464 

func (x *ListObjectsRequest) GetBucket() *v1alpha1.VirtualBucket

func (*ListObjectsRequest) GetPrefix added in v0.5.464 

func (x *ListObjectsRequest) GetPrefix() string

func (*ListObjectsRequest) GetTenant added in v0.5.464 

func (x *ListObjectsRequest) GetTenant() string

func (*ListObjectsRequest) ProtoMessage added in v0.5.464 

func (*ListObjectsRequest) ProtoMessage()

func (*ListObjectsRequest) ProtoReflect added in v0.5.464 

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

func (*ListObjectsRequest) Reset added in v0.5.464 

func (x *ListObjectsRequest) Reset()

func (*ListObjectsRequest) String added in v0.5.464 

func (x *ListObjectsRequest) String() string

type ListObjectsResponse added in v0.5.464 

type ListObjectsResponse struct {
	Keys []string `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*ListObjectsResponse) Descriptor deprecated added in v0.5.464 

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

Deprecated: Use ListObjectsResponse.ProtoReflect.Descriptor instead.

func (*ListObjectsResponse) GetKeys added in v0.5.464 

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

func (*ListObjectsResponse) ProtoMessage added in v0.5.464 

func (*ListObjectsResponse) ProtoMessage()

func (*ListObjectsResponse) ProtoReflect added in v0.5.464 

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

func (*ListObjectsResponse) Reset added in v0.5.464 

func (x *ListObjectsResponse) Reset()

func (*ListObjectsResponse) String added in v0.5.464 

func (x *ListObjectsResponse) String() string

type ShutdownRequest 

type ShutdownRequest struct {
	// contains filtered or unexported fields
}

func (*ShutdownRequest) Descriptor deprecated 

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

Deprecated: Use ShutdownRequest.ProtoReflect.Descriptor instead.

func (*ShutdownRequest) ProtoMessage 

func (*ShutdownRequest) ProtoMessage()

func (*ShutdownRequest) ProtoReflect 

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

func (*ShutdownRequest) Reset 

func (x *ShutdownRequest) Reset()

func (*ShutdownRequest) String 

func (x *ShutdownRequest) String() string

type ShutdownResponse 

type ShutdownResponse struct {
	// contains filtered or unexported fields
}

func (*ShutdownResponse) Descriptor deprecated 

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

Deprecated: Use ShutdownResponse.ProtoReflect.Descriptor instead.

func (*ShutdownResponse) ProtoMessage 

func (*ShutdownResponse) ProtoMessage()

func (*ShutdownResponse) ProtoReflect 

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

func (*ShutdownResponse) Reset 

func (x *ShutdownResponse) Reset()

func (*ShutdownResponse) String 

func (x *ShutdownResponse) String() string

type UnimplementedCloudProxyServiceServer 

type UnimplementedCloudProxyServiceServer struct {
}

UnimplementedCloudProxyServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedCloudProxyServiceServer) BucketExist added in v0.6.252 

func (UnimplementedCloudProxyServiceServer) BucketExist(context.Context, *BucketExistRequest) (*BucketExistResponse, error)

func (UnimplementedCloudProxyServiceServer) CreateBucket added in v0.6.252 

func (UnimplementedCloudProxyServiceServer) CreateBucket(context.Context, *CreateBucketRequest) (*CreateBucketResponse, error)

func (UnimplementedCloudProxyServiceServer) Delete added in v0.6.252 

func (UnimplementedCloudProxyServiceServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)

func (UnimplementedCloudProxyServiceServer) Download 

func (UnimplementedCloudProxyServiceServer) Download(context.Context, *FileDownloadRequest) (*FileDownloadResponse, error)

func (UnimplementedCloudProxyServiceServer) ExistsInBucket added in v0.6.252 

func (UnimplementedCloudProxyServiceServer) ExistsInBucket(context.Context, *ExistsInBucketRequest) (*ExistsInBucketResponse, error)

func (UnimplementedCloudProxyServiceServer) List added in v0.5.464 

func (UnimplementedCloudProxyServiceServer) List(context.Context, *ListObjectsRequest) (*ListObjectsResponse, error)

func (UnimplementedCloudProxyServiceServer) Shutdown 

func (UnimplementedCloudProxyServiceServer) Shutdown(context.Context, *ShutdownRequest) (*ShutdownResponse, error)

func (UnimplementedCloudProxyServiceServer) Upload 

func (UnimplementedCloudProxyServiceServer) Upload(context.Context, *FileUploadRequest) (*FileUploadResponse, error)

type UnsafeCloudProxyServiceServer added in v0.4.687 

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

UnsafeCloudProxyServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CloudProxyServiceServer 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.