v1

package
v0.3.126 Latest Latest
Warning

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

 Go to latest Published: Mar 30, 2021 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_github_com_metaprov_modeldapi_services_cloudsd_v1_cloudsd_proto protoreflect.FileDescriptor

Functions

func RegisterCloudsServiceServer 

func RegisterCloudsServiceServer(s *grpc.Server, srv CloudsServiceServer)

Types

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 CloudsServiceClient 

type CloudsServiceClient 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)
}

CloudsServiceClient is the client API for CloudsService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewCloudsServiceClient 

func NewCloudsServiceClient(cc grpc.ClientConnInterface) CloudsServiceClient

type CloudsServiceServer 

type CloudsServiceServer 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)
}

CloudsServiceServer is the server API for CloudsService service.

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 added in v0.3.2 

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

func (*CreateVirtualBucketRequest) GetConnection added in v0.3.2 

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 */
	// 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 added in v0.3.2 

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) 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 added in v0.3.2 

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"`
	Name       string               `protobuf:"bytes,2,opt,name=name,proto3" json:"name,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) GetConnection added in v0.3.2 

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

func (*KeyExistInVirtualBucketRequest) GetKey 

func (x *KeyExistInVirtualBucketRequest) GetKey() string

func (*KeyExistInVirtualBucketRequest) GetName 

func (x *KeyExistInVirtualBucketRequest) GetName() 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 UnimplementedCloudsServiceServer 

type UnimplementedCloudsServiceServer struct {
}

UnimplementedCloudsServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedCloudsServiceServer) CreateVirtualBucketIfNotExist 

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

func (*UnimplementedCloudsServiceServer) Download 

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

func (*UnimplementedCloudsServiceServer) KeyExistInVirtualBucket 

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

func (*UnimplementedCloudsServiceServer) Shutdown 

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

func (*UnimplementedCloudsServiceServer) Upload 

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

func (*UnimplementedCloudsServiceServer) VirtualBucketExist 

func (*UnimplementedCloudsServiceServer) 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 added in v0.3.2 

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

func (*VirtualBucketExistRequest) GetConnection added in v0.3.2 

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.