v1

package
v0.5.545 Latest Latest
Warning

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

Go to latest
Published: Dec 29, 2022 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: "KeyExistInVirtualBucket",
			Handler:    _CloudProxyService_KeyExistInVirtualBucket_Handler,
		},
		{
			MethodName: "VirtualBucketExist",
			Handler:    _CloudProxyService_VirtualBucketExist_Handler,
		},
		{
			MethodName: "CreateVirtualBucketIfNotExist",
			Handler:    _CloudProxyService_CreateVirtualBucketIfNotExist_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 CloudProxyServiceClient

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.

type CloudProxyServiceServer

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

type CloudVirtualBucketResponse

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

func (*CloudVirtualBucketResponse) Descriptor deprecated

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

Deprecated: Use CloudVirtualBucketResponse.ProtoReflect.Descriptor instead.

func (*CloudVirtualBucketResponse) ProtoMessage

func (*CloudVirtualBucketResponse) ProtoMessage()

func (*CloudVirtualBucketResponse) ProtoReflect

func (*CloudVirtualBucketResponse) Reset

func (x *CloudVirtualBucketResponse) Reset()

func (*CloudVirtualBucketResponse) String

func (x *CloudVirtualBucketResponse) String() string

type CreateVirtualBucketRequest

type CreateVirtualBucketRequest struct {
	Bucket     *v1alpha1.VirtualBucket `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Connection *v1alpha1.Connection    `protobuf:"bytes,2,opt,name=connection,proto3" json:"connection,omitempty"`
	Secret     map[string][]byte       `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateVirtualBucketRequest) Descriptor deprecated

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

Deprecated: Use CreateVirtualBucketRequest.ProtoReflect.Descriptor instead.

func (*CreateVirtualBucketRequest) GetBucket

func (*CreateVirtualBucketRequest) GetConnection

func (x *CreateVirtualBucketRequest) GetConnection() *v1alpha1.Connection

func (*CreateVirtualBucketRequest) GetSecret

func (x *CreateVirtualBucketRequest) GetSecret() map[string][]byte

func (*CreateVirtualBucketRequest) ProtoMessage

func (*CreateVirtualBucketRequest) ProtoMessage()

func (*CreateVirtualBucketRequest) ProtoReflect

func (*CreateVirtualBucketRequest) Reset

func (x *CreateVirtualBucketRequest) Reset()

func (*CreateVirtualBucketRequest) String

func (x *CreateVirtualBucketRequest) String() string

type CreateVirtualBucketResponse

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

func (*CreateVirtualBucketResponse) Descriptor deprecated

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

Deprecated: Use CreateVirtualBucketResponse.ProtoReflect.Descriptor instead.

func (*CreateVirtualBucketResponse) ProtoMessage

func (*CreateVirtualBucketResponse) ProtoMessage()

func (*CreateVirtualBucketResponse) ProtoReflect

func (*CreateVirtualBucketResponse) Reset

func (x *CreateVirtualBucketResponse) Reset()

func (*CreateVirtualBucketResponse) String

func (x *CreateVirtualBucketResponse) 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"`
	Connection *v1alpha1.Connection    `protobuf:"bytes,4,opt,name=connection,proto3" json:"connection,omitempty"`
	Secret     map[string][]byte       ``                                                                  /* 153-byte string literal not displayed */
	Tenant     string                  `protobuf:"bytes,6,opt,name=tenant,proto3" json:"tenant,omitempty"` // local path
	// 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) GetConnection

func (x *FileDownloadRequest) GetConnection() *v1alpha1.Connection

func (*FileDownloadRequest) GetKey

func (x *FileDownloadRequest) GetKey() string

func (*FileDownloadRequest) GetPath

func (x *FileDownloadRequest) GetPath() string

func (*FileDownloadRequest) GetSecret

func (x *FileDownloadRequest) GetSecret() map[string][]byte

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"`
	Connection *v1alpha1.Connection    `protobuf:"bytes,4,opt,name=connection,proto3" json:"connection,omitempty"`
	Secret     map[string][]byte       `` /* 153-byte string literal not displayed */
	// 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) GetConnection

func (x *FileUploadRequest) GetConnection() *v1alpha1.Connection

func (*FileUploadRequest) GetKey

func (x *FileUploadRequest) GetKey() string

func (*FileUploadRequest) GetPath

func (x *FileUploadRequest) GetPath() string

func (*FileUploadRequest) GetSecret

func (x *FileUploadRequest) GetSecret() map[string][]byte

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 KeyExistInVirtualBucketRequest

type KeyExistInVirtualBucketRequest struct {
	Region     string                  `protobuf:"bytes,1,opt,name=region,proto3" json:"region,omitempty"`
	Bucket     *v1alpha1.VirtualBucket `protobuf:"bytes,2,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Key        string                  `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Connection *v1alpha1.Connection    `protobuf:"bytes,4,opt,name=connection,proto3" json:"connection,omitempty"`
	Secret     map[string][]byte       `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*KeyExistInVirtualBucketRequest) Descriptor deprecated

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

Deprecated: Use KeyExistInVirtualBucketRequest.ProtoReflect.Descriptor instead.

func (*KeyExistInVirtualBucketRequest) GetBucket

func (*KeyExistInVirtualBucketRequest) GetConnection

func (*KeyExistInVirtualBucketRequest) GetKey

func (*KeyExistInVirtualBucketRequest) GetRegion

func (x *KeyExistInVirtualBucketRequest) GetRegion() string

func (*KeyExistInVirtualBucketRequest) GetSecret

func (x *KeyExistInVirtualBucketRequest) GetSecret() map[string][]byte

func (*KeyExistInVirtualBucketRequest) ProtoMessage

func (*KeyExistInVirtualBucketRequest) ProtoMessage()

func (*KeyExistInVirtualBucketRequest) ProtoReflect

func (*KeyExistInVirtualBucketRequest) Reset

func (x *KeyExistInVirtualBucketRequest) Reset()

func (*KeyExistInVirtualBucketRequest) String

type KeyExistInVirtualBucketResponse

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

func (*KeyExistInVirtualBucketResponse) Descriptor deprecated

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

Deprecated: Use KeyExistInVirtualBucketResponse.ProtoReflect.Descriptor instead.

func (*KeyExistInVirtualBucketResponse) GetExist

func (x *KeyExistInVirtualBucketResponse) GetExist() bool

func (*KeyExistInVirtualBucketResponse) ProtoMessage

func (*KeyExistInVirtualBucketResponse) ProtoMessage()

func (*KeyExistInVirtualBucketResponse) ProtoReflect

func (*KeyExistInVirtualBucketResponse) Reset

func (*KeyExistInVirtualBucketResponse) 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"`
	Connection *v1alpha1.Connection    `protobuf:"bytes,3,opt,name=connection,proto3" json:"connection,omitempty"`
	Secret     map[string][]byte       ``                                                                  /* 153-byte string literal not displayed */
	Tenant     string                  `protobuf:"bytes,5,opt,name=tenant,proto3" json:"tenant,omitempty"` // local path
	// 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) GetConnection added in v0.5.464

func (x *ListObjectsRequest) GetConnection() *v1alpha1.Connection

func (*ListObjectsRequest) GetPrefix added in v0.5.464

func (x *ListObjectsRequest) GetPrefix() string

func (*ListObjectsRequest) GetSecret added in v0.5.464

func (x *ListObjectsRequest) GetSecret() map[string][]byte

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"` // local path
	// 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) CreateVirtualBucketIfNotExist

func (UnimplementedCloudProxyServiceServer) Download

func (UnimplementedCloudProxyServiceServer) List added in v0.5.464

func (UnimplementedCloudProxyServiceServer) Shutdown

func (UnimplementedCloudProxyServiceServer) Upload

func (UnimplementedCloudProxyServiceServer) VirtualBucketExist

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.

type VirtualBucketExistRequest

type VirtualBucketExistRequest struct {
	Bucket     *v1alpha1.VirtualBucket `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Connection *v1alpha1.Connection    `protobuf:"bytes,2,opt,name=connection,proto3" json:"connection,omitempty"`
	Secret     map[string][]byte       `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*VirtualBucketExistRequest) Descriptor deprecated

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

Deprecated: Use VirtualBucketExistRequest.ProtoReflect.Descriptor instead.

func (*VirtualBucketExistRequest) GetBucket

func (*VirtualBucketExistRequest) GetConnection

func (x *VirtualBucketExistRequest) GetConnection() *v1alpha1.Connection

func (*VirtualBucketExistRequest) GetSecret

func (x *VirtualBucketExistRequest) GetSecret() map[string][]byte

func (*VirtualBucketExistRequest) ProtoMessage

func (*VirtualBucketExistRequest) ProtoMessage()

func (*VirtualBucketExistRequest) ProtoReflect

func (*VirtualBucketExistRequest) Reset

func (x *VirtualBucketExistRequest) Reset()

func (*VirtualBucketExistRequest) String

func (x *VirtualBucketExistRequest) String() string

type VirtualBucketExistResponse

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

func (*VirtualBucketExistResponse) Descriptor deprecated

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

Deprecated: Use VirtualBucketExistResponse.ProtoReflect.Descriptor instead.

func (*VirtualBucketExistResponse) GetExist

func (x *VirtualBucketExistResponse) GetExist() bool

func (*VirtualBucketExistResponse) ProtoMessage

func (*VirtualBucketExistResponse) ProtoMessage()

func (*VirtualBucketExistResponse) ProtoReflect

func (*VirtualBucketExistResponse) Reset

func (x *VirtualBucketExistResponse) Reset()

func (*VirtualBucketExistResponse) String

func (x *VirtualBucketExistResponse) String() string

Jump to

Keyboard shortcuts

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