v1

package
v0.4.581 Latest Latest
Warning

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

 Go to latest Published: Mar 12, 2022 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_github_com_metaprov_modelaapi_services_cloudproxyd_v1_cloudproxyd_proto protoreflect.FileDescriptor

Functions

func RegisterCloudProxyServiceServer 

func RegisterCloudProxyServiceServer(s *grpc.Server, srv CloudProxyServiceServer)

Types

type CloudProxyServiceClient 

type CloudProxyServiceClient interface {
	Download(ctx context.Context, in *FileDownloadRequest, opts ...grpc.CallOption) (*FileDownloadResponse, error)
	Upload(ctx context.Context, in *FileUploadRequest, opts ...grpc.CallOption) (*FileUploadResponse, error)
	KeyExistInVirtualBucket(ctx context.Context, in *KeyExistInVirtualBucketRequest, opts ...grpc.CallOption) (*KeyExistInVirtualBucketResponse, error)
	VirtualBucketExist(ctx context.Context, in *VirtualBucketExistRequest, opts ...grpc.CallOption) (*VirtualBucketExistResponse, error)
	CreateVirtualBucketIfNotExist(ctx context.Context, in *CreateVirtualBucketRequest, opts ...grpc.CallOption) (*CreateVirtualBucketResponse, 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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewCloudProxyServiceClient 

func NewCloudProxyServiceClient(cc grpc.ClientConnInterface) CloudProxyServiceClient

type CloudProxyServiceServer 

type CloudProxyServiceServer interface {
	Download(context.Context, *FileDownloadRequest) (*FileDownloadResponse, error)
	Upload(context.Context, *FileUploadRequest) (*FileUploadResponse, error)
	KeyExistInVirtualBucket(context.Context, *KeyExistInVirtualBucketRequest) (*KeyExistInVirtualBucketResponse, error)
	VirtualBucketExist(context.Context, *VirtualBucketExistRequest) (*VirtualBucketExistResponse, error)
	CreateVirtualBucketIfNotExist(context.Context, *CreateVirtualBucketRequest) (*CreateVirtualBucketResponse, error)
	Shutdown(context.Context, *ShutdownRequest) (*ShutdownResponse, error)
}

CloudProxyServiceServer is the server API for CloudProxyService service.

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 (x *CloudVirtualBucketResponse) ProtoReflect() protoreflect.Message

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 (x *CreateVirtualBucketRequest) GetBucket() *v1alpha1.VirtualBucket

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 (x *CreateVirtualBucketRequest) ProtoReflect() protoreflect.Message

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 (x *CreateVirtualBucketResponse) ProtoReflect() protoreflect.Message

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 (x *KeyExistInVirtualBucketRequest) GetBucket() *v1alpha1.VirtualBucket

func (*KeyExistInVirtualBucketRequest) GetConnection 

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

func (*KeyExistInVirtualBucketRequest) GetKey 

func (x *KeyExistInVirtualBucketRequest) GetKey() string

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 (x *KeyExistInVirtualBucketRequest) ProtoReflect() protoreflect.Message

func (*KeyExistInVirtualBucketRequest) Reset 

func (x *KeyExistInVirtualBucketRequest) Reset()

func (*KeyExistInVirtualBucketRequest) String 

func (x *KeyExistInVirtualBucketRequest) String() 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 (x *KeyExistInVirtualBucketResponse) ProtoReflect() protoreflect.Message

func (*KeyExistInVirtualBucketResponse) Reset 

func (x *KeyExistInVirtualBucketResponse) Reset()

func (*KeyExistInVirtualBucketResponse) String 

func (x *KeyExistInVirtualBucketResponse) 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 can be embedded to have forward compatible implementations.

func (*UnimplementedCloudProxyServiceServer) CreateVirtualBucketIfNotExist 

func (*UnimplementedCloudProxyServiceServer) CreateVirtualBucketIfNotExist(context.Context, *CreateVirtualBucketRequest) (*CreateVirtualBucketResponse, error)

func (*UnimplementedCloudProxyServiceServer) Download 

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

func (*UnimplementedCloudProxyServiceServer) KeyExistInVirtualBucket 

func (*UnimplementedCloudProxyServiceServer) KeyExistInVirtualBucket(context.Context, *KeyExistInVirtualBucketRequest) (*KeyExistInVirtualBucketResponse, error)

func (*UnimplementedCloudProxyServiceServer) Shutdown 

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

func (*UnimplementedCloudProxyServiceServer) Upload 

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

func (*UnimplementedCloudProxyServiceServer) VirtualBucketExist 

func (*UnimplementedCloudProxyServiceServer) VirtualBucketExist(context.Context, *VirtualBucketExistRequest) (*VirtualBucketExistResponse, error)

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 (x *VirtualBucketExistRequest) GetBucket() *v1alpha1.VirtualBucket

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 (x *VirtualBucketExistRequest) ProtoReflect() protoreflect.Message

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 (x *VirtualBucketExistResponse) ProtoReflect() protoreflect.Message

func (*VirtualBucketExistResponse) Reset 

func (x *VirtualBucketExistResponse) Reset()

func (*VirtualBucketExistResponse) String 

func (x *VirtualBucketExistResponse) String() string

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.