Documentation ¶
Index ¶
- Variables
- func RegisterOCSProviderServer(s grpc.ServiceRegistrar, srv OCSProviderServer)
- type AcknowledgeOnboardingRequest
- func (*AcknowledgeOnboardingRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AcknowledgeOnboardingRequest) GetStorageConsumerUUID() string
- func (*AcknowledgeOnboardingRequest) ProtoMessage()
- func (x *AcknowledgeOnboardingRequest) ProtoReflect() protoreflect.Message
- func (x *AcknowledgeOnboardingRequest) Reset()
- func (x *AcknowledgeOnboardingRequest) String() string
- type AcknowledgeOnboardingResponse
- func (*AcknowledgeOnboardingResponse) Descriptor() ([]byte, []int)deprecated
- func (*AcknowledgeOnboardingResponse) ProtoMessage()
- func (x *AcknowledgeOnboardingResponse) ProtoReflect() protoreflect.Message
- func (x *AcknowledgeOnboardingResponse) Reset()
- func (x *AcknowledgeOnboardingResponse) String() string
- type ExternalResource
- func (*ExternalResource) Descriptor() ([]byte, []int)deprecated
- func (x *ExternalResource) GetData() []byte
- func (x *ExternalResource) GetKind() string
- func (x *ExternalResource) GetName() string
- func (*ExternalResource) ProtoMessage()
- func (x *ExternalResource) ProtoReflect() protoreflect.Message
- func (x *ExternalResource) Reset()
- func (x *ExternalResource) String() string
- type FulfillStorageClassClaimRequest
- func (*FulfillStorageClassClaimRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FulfillStorageClassClaimRequest) GetEncryptionMethod() string
- func (x *FulfillStorageClassClaimRequest) GetStorageClassClaimName() string
- func (x *FulfillStorageClassClaimRequest) GetStorageConsumerUUID() string
- func (x *FulfillStorageClassClaimRequest) GetStorageProfile() string
- func (x *FulfillStorageClassClaimRequest) GetStorageType() FulfillStorageClassClaimRequest_StorageType
- func (*FulfillStorageClassClaimRequest) ProtoMessage()
- func (x *FulfillStorageClassClaimRequest) ProtoReflect() protoreflect.Message
- func (x *FulfillStorageClassClaimRequest) Reset()
- func (x *FulfillStorageClassClaimRequest) String() string
- type FulfillStorageClassClaimRequest_StorageType
- func (FulfillStorageClassClaimRequest_StorageType) Descriptor() protoreflect.EnumDescriptor
- func (x FulfillStorageClassClaimRequest_StorageType) Enum() *FulfillStorageClassClaimRequest_StorageType
- func (FulfillStorageClassClaimRequest_StorageType) EnumDescriptor() ([]byte, []int)deprecated
- func (x FulfillStorageClassClaimRequest_StorageType) Number() protoreflect.EnumNumber
- func (x FulfillStorageClassClaimRequest_StorageType) String() string
- func (FulfillStorageClassClaimRequest_StorageType) Type() protoreflect.EnumType
- type FulfillStorageClassClaimResponse
- func (*FulfillStorageClassClaimResponse) Descriptor() ([]byte, []int)deprecated
- func (*FulfillStorageClassClaimResponse) ProtoMessage()
- func (x *FulfillStorageClassClaimResponse) ProtoReflect() protoreflect.Message
- func (x *FulfillStorageClassClaimResponse) Reset()
- func (x *FulfillStorageClassClaimResponse) String() string
- type OCSProviderClient
- type OCSProviderServer
- type OffboardConsumerRequest
- func (*OffboardConsumerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *OffboardConsumerRequest) GetStorageConsumerUUID() string
- func (*OffboardConsumerRequest) ProtoMessage()
- func (x *OffboardConsumerRequest) ProtoReflect() protoreflect.Message
- func (x *OffboardConsumerRequest) Reset()
- func (x *OffboardConsumerRequest) String() string
- type OffboardConsumerResponse
- type OnboardConsumerRequest
- func (*OnboardConsumerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *OnboardConsumerRequest) GetCapacity() string
- func (x *OnboardConsumerRequest) GetConsumerName() string
- func (x *OnboardConsumerRequest) GetOnboardingTicket() string
- func (*OnboardConsumerRequest) ProtoMessage()
- func (x *OnboardConsumerRequest) ProtoReflect() protoreflect.Message
- func (x *OnboardConsumerRequest) Reset()
- func (x *OnboardConsumerRequest) String() string
- type OnboardConsumerResponse
- func (*OnboardConsumerResponse) Descriptor() ([]byte, []int)deprecated
- func (x *OnboardConsumerResponse) GetGrantedCapacity() string
- func (x *OnboardConsumerResponse) GetStorageConsumerUUID() string
- func (*OnboardConsumerResponse) ProtoMessage()
- func (x *OnboardConsumerResponse) ProtoReflect() protoreflect.Message
- func (x *OnboardConsumerResponse) Reset()
- func (x *OnboardConsumerResponse) String() string
- type ReportStatusRequest
- func (*ReportStatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReportStatusRequest) GetStorageConsumerUUID() string
- func (*ReportStatusRequest) ProtoMessage()
- func (x *ReportStatusRequest) ProtoReflect() protoreflect.Message
- func (x *ReportStatusRequest) Reset()
- func (x *ReportStatusRequest) String() string
- type ReportStatusResponse
- type RevokeStorageClassClaimRequest
- func (*RevokeStorageClassClaimRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RevokeStorageClassClaimRequest) GetStorageClassClaimName() string
- func (x *RevokeStorageClassClaimRequest) GetStorageConsumerUUID() string
- func (*RevokeStorageClassClaimRequest) ProtoMessage()
- func (x *RevokeStorageClassClaimRequest) ProtoReflect() protoreflect.Message
- func (x *RevokeStorageClassClaimRequest) Reset()
- func (x *RevokeStorageClassClaimRequest) String() string
- type RevokeStorageClassClaimResponse
- func (*RevokeStorageClassClaimResponse) Descriptor() ([]byte, []int)deprecated
- func (*RevokeStorageClassClaimResponse) ProtoMessage()
- func (x *RevokeStorageClassClaimResponse) ProtoReflect() protoreflect.Message
- func (x *RevokeStorageClassClaimResponse) Reset()
- func (x *RevokeStorageClassClaimResponse) String() string
- type StorageClassClaimConfigRequest
- func (*StorageClassClaimConfigRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StorageClassClaimConfigRequest) GetStorageClassClaimName() string
- func (x *StorageClassClaimConfigRequest) GetStorageConsumerUUID() string
- func (*StorageClassClaimConfigRequest) ProtoMessage()
- func (x *StorageClassClaimConfigRequest) ProtoReflect() protoreflect.Message
- func (x *StorageClassClaimConfigRequest) Reset()
- func (x *StorageClassClaimConfigRequest) String() string
- type StorageClassClaimConfigResponse
- func (*StorageClassClaimConfigResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StorageClassClaimConfigResponse) GetExternalResource() []*ExternalResource
- func (*StorageClassClaimConfigResponse) ProtoMessage()
- func (x *StorageClassClaimConfigResponse) ProtoReflect() protoreflect.Message
- func (x *StorageClassClaimConfigResponse) Reset()
- func (x *StorageClassClaimConfigResponse) String() string
- type StorageConfigRequest
- func (*StorageConfigRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StorageConfigRequest) GetStorageConsumerUUID() string
- func (*StorageConfigRequest) ProtoMessage()
- func (x *StorageConfigRequest) ProtoReflect() protoreflect.Message
- func (x *StorageConfigRequest) Reset()
- func (x *StorageConfigRequest) String() string
- type StorageConfigResponse
- func (*StorageConfigResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StorageConfigResponse) GetExternalResource() []*ExternalResource
- func (*StorageConfigResponse) ProtoMessage()
- func (x *StorageConfigResponse) ProtoReflect() protoreflect.Message
- func (x *StorageConfigResponse) Reset()
- func (x *StorageConfigResponse) String() string
- type UnimplementedOCSProviderServer
- func (UnimplementedOCSProviderServer) AcknowledgeOnboarding(context.Context, *AcknowledgeOnboardingRequest) (*AcknowledgeOnboardingResponse, error)
- func (UnimplementedOCSProviderServer) FulfillStorageClassClaim(context.Context, *FulfillStorageClassClaimRequest) (*FulfillStorageClassClaimResponse, error)
- func (UnimplementedOCSProviderServer) GetStorageClassClaimConfig(context.Context, *StorageClassClaimConfigRequest) (*StorageClassClaimConfigResponse, error)
- func (UnimplementedOCSProviderServer) GetStorageConfig(context.Context, *StorageConfigRequest) (*StorageConfigResponse, error)
- func (UnimplementedOCSProviderServer) OffboardConsumer(context.Context, *OffboardConsumerRequest) (*OffboardConsumerResponse, error)
- func (UnimplementedOCSProviderServer) OnboardConsumer(context.Context, *OnboardConsumerRequest) (*OnboardConsumerResponse, error)
- func (UnimplementedOCSProviderServer) ReportStatus(context.Context, *ReportStatusRequest) (*ReportStatusResponse, error)
- func (UnimplementedOCSProviderServer) RevokeStorageClassClaim(context.Context, *RevokeStorageClassClaimRequest) (*RevokeStorageClassClaimResponse, error)
- func (UnimplementedOCSProviderServer) UpdateCapacity(context.Context, *UpdateCapacityRequest) (*UpdateCapacityResponse, error)
- type UnsafeOCSProviderServer
- type UpdateCapacityRequest
- func (*UpdateCapacityRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateCapacityRequest) GetCapacity() string
- func (x *UpdateCapacityRequest) GetStorageConsumerUUID() string
- func (*UpdateCapacityRequest) ProtoMessage()
- func (x *UpdateCapacityRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateCapacityRequest) Reset()
- func (x *UpdateCapacityRequest) String() string
- type UpdateCapacityResponse
- func (*UpdateCapacityResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateCapacityResponse) GetGrantedCapacity() string
- func (*UpdateCapacityResponse) ProtoMessage()
- func (x *UpdateCapacityResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateCapacityResponse) Reset()
- func (x *UpdateCapacityResponse) String() string
Constants ¶
This section is empty.
Variables ¶
var ( FulfillStorageClassClaimRequest_StorageType_name = map[int32]string{ 0: "SHAREDFILESYSTEM", 1: "BLOCKPOOL", } FulfillStorageClassClaimRequest_StorageType_value = map[string]int32{ "SHAREDFILESYSTEM": 0, "BLOCKPOOL": 1, } )
Enum value maps for FulfillStorageClassClaimRequest_StorageType.
var File_provider_proto protoreflect.FileDescriptor
var OCSProvider_ServiceDesc = grpc.ServiceDesc{ ServiceName: "provider.OCSProvider", HandlerType: (*OCSProviderServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "OnboardConsumer", Handler: _OCSProvider_OnboardConsumer_Handler, }, { MethodName: "GetStorageConfig", Handler: _OCSProvider_GetStorageConfig_Handler, }, { MethodName: "OffboardConsumer", Handler: _OCSProvider_OffboardConsumer_Handler, }, { MethodName: "UpdateCapacity", Handler: _OCSProvider_UpdateCapacity_Handler, }, { MethodName: "AcknowledgeOnboarding", Handler: _OCSProvider_AcknowledgeOnboarding_Handler, }, { MethodName: "FulfillStorageClassClaim", Handler: _OCSProvider_FulfillStorageClassClaim_Handler, }, { MethodName: "RevokeStorageClassClaim", Handler: _OCSProvider_RevokeStorageClassClaim_Handler, }, { MethodName: "GetStorageClassClaimConfig", Handler: _OCSProvider_GetStorageClassClaimConfig_Handler, }, { MethodName: "ReportStatus", Handler: _OCSProvider_ReportStatus_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "provider.proto", }
OCSProvider_ServiceDesc is the grpc.ServiceDesc for OCSProvider service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterOCSProviderServer ¶
func RegisterOCSProviderServer(s grpc.ServiceRegistrar, srv OCSProviderServer)
Types ¶
type AcknowledgeOnboardingRequest ¶
type AcknowledgeOnboardingRequest struct { // K8s UID (UUID) of the consumer cluster StorageConsumerUUID string `protobuf:"bytes,1,opt,name=storageConsumerUUID,proto3" json:"storageConsumerUUID,omitempty"` // contains filtered or unexported fields }
AcknowledgeOnboardingRequest holds the information required to acknowledge the onboarding
func (*AcknowledgeOnboardingRequest) Descriptor
deprecated
func (*AcknowledgeOnboardingRequest) Descriptor() ([]byte, []int)
Deprecated: Use AcknowledgeOnboardingRequest.ProtoReflect.Descriptor instead.
func (*AcknowledgeOnboardingRequest) GetStorageConsumerUUID ¶
func (x *AcknowledgeOnboardingRequest) GetStorageConsumerUUID() string
func (*AcknowledgeOnboardingRequest) ProtoMessage ¶
func (*AcknowledgeOnboardingRequest) ProtoMessage()
func (*AcknowledgeOnboardingRequest) ProtoReflect ¶
func (x *AcknowledgeOnboardingRequest) ProtoReflect() protoreflect.Message
func (*AcknowledgeOnboardingRequest) Reset ¶
func (x *AcknowledgeOnboardingRequest) Reset()
func (*AcknowledgeOnboardingRequest) String ¶
func (x *AcknowledgeOnboardingRequest) String() string
type AcknowledgeOnboardingResponse ¶
type AcknowledgeOnboardingResponse struct {
// contains filtered or unexported fields
}
AcknowledgeOnboardingResponse holds the response for the AcknowledgeOnboarding API request
func (*AcknowledgeOnboardingResponse) Descriptor
deprecated
func (*AcknowledgeOnboardingResponse) Descriptor() ([]byte, []int)
Deprecated: Use AcknowledgeOnboardingResponse.ProtoReflect.Descriptor instead.
func (*AcknowledgeOnboardingResponse) ProtoMessage ¶
func (*AcknowledgeOnboardingResponse) ProtoMessage()
func (*AcknowledgeOnboardingResponse) ProtoReflect ¶
func (x *AcknowledgeOnboardingResponse) ProtoReflect() protoreflect.Message
func (*AcknowledgeOnboardingResponse) Reset ¶
func (x *AcknowledgeOnboardingResponse) Reset()
func (*AcknowledgeOnboardingResponse) String ¶
func (x *AcknowledgeOnboardingResponse) String() string
type ExternalResource ¶
type ExternalResource struct { // Name of the external storage cluster resource Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"` // Kind of the external storage cluster resource Kind string `protobuf:"bytes,2,opt,name=kind,proto3" json:"kind,omitempty"` // Data contains the contents of the external cluster resource Data []byte `protobuf:"bytes,3,opt,name=Data,proto3" json:"Data,omitempty"` // contains filtered or unexported fields }
ExternalResource holds the configuration data of the resources in external storage cluster
func (*ExternalResource) Descriptor
deprecated
func (*ExternalResource) Descriptor() ([]byte, []int)
Deprecated: Use ExternalResource.ProtoReflect.Descriptor instead.
func (*ExternalResource) GetData ¶
func (x *ExternalResource) GetData() []byte
func (*ExternalResource) GetKind ¶
func (x *ExternalResource) GetKind() string
func (*ExternalResource) GetName ¶
func (x *ExternalResource) GetName() string
func (*ExternalResource) ProtoMessage ¶
func (*ExternalResource) ProtoMessage()
func (*ExternalResource) ProtoReflect ¶
func (x *ExternalResource) ProtoReflect() protoreflect.Message
func (*ExternalResource) Reset ¶
func (x *ExternalResource) Reset()
func (*ExternalResource) String ¶
func (x *ExternalResource) String() string
type FulfillStorageClassClaimRequest ¶ added in v0.4.11
type FulfillStorageClassClaimRequest struct { // name of the storageclassclaim on the consumer cluster. StorageClassClaimName string `protobuf:"bytes,1,opt,name=storageClassClaimName,proto3" json:"storageClassClaimName,omitempty"` // K8s UID (UUID) of the consumer cluster. StorageConsumerUUID string `protobuf:"bytes,2,opt,name=storageConsumerUUID,proto3" json:"storageConsumerUUID,omitempty"` // encryption method of the storageclassclaim. EncryptionMethod string `protobuf:"bytes,3,opt,name=encryptionMethod,proto3" json:"encryptionMethod,omitempty"` StorageType FulfillStorageClassClaimRequest_StorageType `` /* 134-byte string literal not displayed */ // storageProfile of the storageclassclaim. StorageProfile string `protobuf:"bytes,5,opt,name=storageProfile,proto3" json:"storageProfile,omitempty"` // contains filtered or unexported fields }
FulfillStorageClassClaimRequest holds the information required to create the StorageclassClaim CR on provider cluster.
func (*FulfillStorageClassClaimRequest) Descriptor
deprecated
added in
v0.4.11
func (*FulfillStorageClassClaimRequest) Descriptor() ([]byte, []int)
Deprecated: Use FulfillStorageClassClaimRequest.ProtoReflect.Descriptor instead.
func (*FulfillStorageClassClaimRequest) GetEncryptionMethod ¶ added in v0.4.11
func (x *FulfillStorageClassClaimRequest) GetEncryptionMethod() string
func (*FulfillStorageClassClaimRequest) GetStorageClassClaimName ¶ added in v0.4.11
func (x *FulfillStorageClassClaimRequest) GetStorageClassClaimName() string
func (*FulfillStorageClassClaimRequest) GetStorageConsumerUUID ¶ added in v0.4.11
func (x *FulfillStorageClassClaimRequest) GetStorageConsumerUUID() string
func (*FulfillStorageClassClaimRequest) GetStorageProfile ¶ added in v0.4.12
func (x *FulfillStorageClassClaimRequest) GetStorageProfile() string
func (*FulfillStorageClassClaimRequest) GetStorageType ¶ added in v0.4.11
func (x *FulfillStorageClassClaimRequest) GetStorageType() FulfillStorageClassClaimRequest_StorageType
func (*FulfillStorageClassClaimRequest) ProtoMessage ¶ added in v0.4.11
func (*FulfillStorageClassClaimRequest) ProtoMessage()
func (*FulfillStorageClassClaimRequest) ProtoReflect ¶ added in v0.4.11
func (x *FulfillStorageClassClaimRequest) ProtoReflect() protoreflect.Message
func (*FulfillStorageClassClaimRequest) Reset ¶ added in v0.4.11
func (x *FulfillStorageClassClaimRequest) Reset()
func (*FulfillStorageClassClaimRequest) String ¶ added in v0.4.11
func (x *FulfillStorageClassClaimRequest) String() string
type FulfillStorageClassClaimRequest_StorageType ¶ added in v0.4.11
type FulfillStorageClassClaimRequest_StorageType int32
StorageType of the storageclassClaim
const ( FulfillStorageClassClaimRequest_SHAREDFILESYSTEM FulfillStorageClassClaimRequest_StorageType = 0 FulfillStorageClassClaimRequest_BLOCKPOOL FulfillStorageClassClaimRequest_StorageType = 1 )
func (FulfillStorageClassClaimRequest_StorageType) Descriptor ¶ added in v0.4.11
func (FulfillStorageClassClaimRequest_StorageType) Descriptor() protoreflect.EnumDescriptor
func (FulfillStorageClassClaimRequest_StorageType) EnumDescriptor
deprecated
added in
v0.4.11
func (FulfillStorageClassClaimRequest_StorageType) EnumDescriptor() ([]byte, []int)
Deprecated: Use FulfillStorageClassClaimRequest_StorageType.Descriptor instead.
func (FulfillStorageClassClaimRequest_StorageType) Number ¶ added in v0.4.11
func (x FulfillStorageClassClaimRequest_StorageType) Number() protoreflect.EnumNumber
func (FulfillStorageClassClaimRequest_StorageType) String ¶ added in v0.4.11
func (x FulfillStorageClassClaimRequest_StorageType) String() string
func (FulfillStorageClassClaimRequest_StorageType) Type ¶ added in v0.4.11
func (FulfillStorageClassClaimRequest_StorageType) Type() protoreflect.EnumType
type FulfillStorageClassClaimResponse ¶ added in v0.4.11
type FulfillStorageClassClaimResponse struct {
// contains filtered or unexported fields
}
FulfillStorageClassClaimResponse holds the response for the FulfillStorageClassClaim API request.
func (*FulfillStorageClassClaimResponse) Descriptor
deprecated
added in
v0.4.11
func (*FulfillStorageClassClaimResponse) Descriptor() ([]byte, []int)
Deprecated: Use FulfillStorageClassClaimResponse.ProtoReflect.Descriptor instead.
func (*FulfillStorageClassClaimResponse) ProtoMessage ¶ added in v0.4.11
func (*FulfillStorageClassClaimResponse) ProtoMessage()
func (*FulfillStorageClassClaimResponse) ProtoReflect ¶ added in v0.4.11
func (x *FulfillStorageClassClaimResponse) ProtoReflect() protoreflect.Message
func (*FulfillStorageClassClaimResponse) Reset ¶ added in v0.4.11
func (x *FulfillStorageClassClaimResponse) Reset()
func (*FulfillStorageClassClaimResponse) String ¶ added in v0.4.11
func (x *FulfillStorageClassClaimResponse) String() string
type OCSProviderClient ¶
type OCSProviderClient interface { // OnboardConsumer RPC call to validate the consumer and create StorageConsumer // resource on the StorageProvider cluster OnboardConsumer(ctx context.Context, in *OnboardConsumerRequest, opts ...grpc.CallOption) (*OnboardConsumerResponse, error) // GetStorageConfig RPC call to generate the json config for connecting to storage provider cluster GetStorageConfig(ctx context.Context, in *StorageConfigRequest, opts ...grpc.CallOption) (*StorageConfigResponse, error) // OffboardConsumer RPC call to delete StorageConsumer CR on the storage provider cluster. OffboardConsumer(ctx context.Context, in *OffboardConsumerRequest, opts ...grpc.CallOption) (*OffboardConsumerResponse, error) // UpdateCapacity PRC call to increase or decrease the block pool size UpdateCapacity(ctx context.Context, in *UpdateCapacityRequest, opts ...grpc.CallOption) (*UpdateCapacityResponse, error) // AcknowledgeOnboarding RPC call acknowledge the onboarding AcknowledgeOnboarding(ctx context.Context, in *AcknowledgeOnboardingRequest, opts ...grpc.CallOption) (*AcknowledgeOnboardingResponse, error) // FulfillStorageClassClaim RPC call to create the StorageclassClaim CR on // provider cluster. FulfillStorageClassClaim(ctx context.Context, in *FulfillStorageClassClaimRequest, opts ...grpc.CallOption) (*FulfillStorageClassClaimResponse, error) // RevokeStorageClassClaim RPC call to delete the StorageclassClaim CR // on provider cluster. RevokeStorageClassClaim(ctx context.Context, in *RevokeStorageClassClaimRequest, opts ...grpc.CallOption) (*RevokeStorageClassClaimResponse, error) // GetStorageClassClaimConfig RPC call to generate the json config for claim // specific resources. GetStorageClassClaimConfig(ctx context.Context, in *StorageClassClaimConfigRequest, opts ...grpc.CallOption) (*StorageClassClaimConfigResponse, error) ReportStatus(ctx context.Context, in *ReportStatusRequest, opts ...grpc.CallOption) (*ReportStatusResponse, error) }
OCSProviderClient is the client API for OCSProvider 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 NewOCSProviderClient ¶
func NewOCSProviderClient(cc grpc.ClientConnInterface) OCSProviderClient
type OCSProviderServer ¶
type OCSProviderServer interface { // OnboardConsumer RPC call to validate the consumer and create StorageConsumer // resource on the StorageProvider cluster OnboardConsumer(context.Context, *OnboardConsumerRequest) (*OnboardConsumerResponse, error) // GetStorageConfig RPC call to generate the json config for connecting to storage provider cluster GetStorageConfig(context.Context, *StorageConfigRequest) (*StorageConfigResponse, error) // OffboardConsumer RPC call to delete StorageConsumer CR on the storage provider cluster. OffboardConsumer(context.Context, *OffboardConsumerRequest) (*OffboardConsumerResponse, error) // UpdateCapacity PRC call to increase or decrease the block pool size UpdateCapacity(context.Context, *UpdateCapacityRequest) (*UpdateCapacityResponse, error) // AcknowledgeOnboarding RPC call acknowledge the onboarding AcknowledgeOnboarding(context.Context, *AcknowledgeOnboardingRequest) (*AcknowledgeOnboardingResponse, error) // FulfillStorageClassClaim RPC call to create the StorageclassClaim CR on // provider cluster. FulfillStorageClassClaim(context.Context, *FulfillStorageClassClaimRequest) (*FulfillStorageClassClaimResponse, error) // RevokeStorageClassClaim RPC call to delete the StorageclassClaim CR // on provider cluster. RevokeStorageClassClaim(context.Context, *RevokeStorageClassClaimRequest) (*RevokeStorageClassClaimResponse, error) // GetStorageClassClaimConfig RPC call to generate the json config for claim // specific resources. GetStorageClassClaimConfig(context.Context, *StorageClassClaimConfigRequest) (*StorageClassClaimConfigResponse, error) ReportStatus(context.Context, *ReportStatusRequest) (*ReportStatusResponse, error) // contains filtered or unexported methods }
OCSProviderServer is the server API for OCSProvider service. All implementations must embed UnimplementedOCSProviderServer for forward compatibility
type OffboardConsumerRequest ¶
type OffboardConsumerRequest struct { // K8s UID (UUID) of the consumer cluster StorageConsumerUUID string `protobuf:"bytes,1,opt,name=storageConsumerUUID,proto3" json:"storageConsumerUUID,omitempty"` // contains filtered or unexported fields }
OffboardConsumerRequest holds the required information to delete the StorageConsumer CR on the storage provider cluster.
func (*OffboardConsumerRequest) Descriptor
deprecated
func (*OffboardConsumerRequest) Descriptor() ([]byte, []int)
Deprecated: Use OffboardConsumerRequest.ProtoReflect.Descriptor instead.
func (*OffboardConsumerRequest) GetStorageConsumerUUID ¶
func (x *OffboardConsumerRequest) GetStorageConsumerUUID() string
func (*OffboardConsumerRequest) ProtoMessage ¶
func (*OffboardConsumerRequest) ProtoMessage()
func (*OffboardConsumerRequest) ProtoReflect ¶
func (x *OffboardConsumerRequest) ProtoReflect() protoreflect.Message
func (*OffboardConsumerRequest) Reset ¶
func (x *OffboardConsumerRequest) Reset()
func (*OffboardConsumerRequest) String ¶
func (x *OffboardConsumerRequest) String() string
type OffboardConsumerResponse ¶
type OffboardConsumerResponse struct {
// contains filtered or unexported fields
}
OffboardConsumerResponse holds the response for the OffboardConsumer API request
func (*OffboardConsumerResponse) Descriptor
deprecated
func (*OffboardConsumerResponse) Descriptor() ([]byte, []int)
Deprecated: Use OffboardConsumerResponse.ProtoReflect.Descriptor instead.
func (*OffboardConsumerResponse) ProtoMessage ¶
func (*OffboardConsumerResponse) ProtoMessage()
func (*OffboardConsumerResponse) ProtoReflect ¶
func (x *OffboardConsumerResponse) ProtoReflect() protoreflect.Message
func (*OffboardConsumerResponse) Reset ¶
func (x *OffboardConsumerResponse) Reset()
func (*OffboardConsumerResponse) String ¶
func (x *OffboardConsumerResponse) String() string
type OnboardConsumerRequest ¶
type OnboardConsumerRequest struct { // onboardingTicket authenticates the storage consumer cluster OnboardingTicket string `protobuf:"bytes,1,opt,name=onboardingTicket,proto3" json:"onboardingTicket,omitempty"` // consumerName is the name of the consumer that is used to create the storageConsumer resource ConsumerName string `protobuf:"bytes,2,opt,name=consumerName,proto3" json:"consumerName,omitempty"` // capacity is the desired storage requested by the consumer cluster Capacity string `protobuf:"bytes,3,opt,name=capacity,proto3" json:"capacity,omitempty"` // contains filtered or unexported fields }
OnboardConsumerRequest holds the required information to validate the consumer and create StorageConsumer resource on the StorageProvider cluster
func (*OnboardConsumerRequest) Descriptor
deprecated
func (*OnboardConsumerRequest) Descriptor() ([]byte, []int)
Deprecated: Use OnboardConsumerRequest.ProtoReflect.Descriptor instead.
func (*OnboardConsumerRequest) GetCapacity ¶
func (x *OnboardConsumerRequest) GetCapacity() string
func (*OnboardConsumerRequest) GetConsumerName ¶
func (x *OnboardConsumerRequest) GetConsumerName() string
func (*OnboardConsumerRequest) GetOnboardingTicket ¶
func (x *OnboardConsumerRequest) GetOnboardingTicket() string
func (*OnboardConsumerRequest) ProtoMessage ¶
func (*OnboardConsumerRequest) ProtoMessage()
func (*OnboardConsumerRequest) ProtoReflect ¶
func (x *OnboardConsumerRequest) ProtoReflect() protoreflect.Message
func (*OnboardConsumerRequest) Reset ¶
func (x *OnboardConsumerRequest) Reset()
func (*OnboardConsumerRequest) String ¶
func (x *OnboardConsumerRequest) String() string
type OnboardConsumerResponse ¶
type OnboardConsumerResponse struct { // K8s UID (UUID) of the consumer cluster StorageConsumerUUID string `protobuf:"bytes,1,opt,name=storageConsumerUUID,proto3" json:"storageConsumerUUID,omitempty"` // grantedCapacity is the storage granted by the provider cluster GrantedCapacity string `protobuf:"bytes,2,opt,name=grantedCapacity,proto3" json:"grantedCapacity,omitempty"` // contains filtered or unexported fields }
OnboardConsumerResponse holds the response for OnboardConsumer API request
func (*OnboardConsumerResponse) Descriptor
deprecated
func (*OnboardConsumerResponse) Descriptor() ([]byte, []int)
Deprecated: Use OnboardConsumerResponse.ProtoReflect.Descriptor instead.
func (*OnboardConsumerResponse) GetGrantedCapacity ¶
func (x *OnboardConsumerResponse) GetGrantedCapacity() string
func (*OnboardConsumerResponse) GetStorageConsumerUUID ¶
func (x *OnboardConsumerResponse) GetStorageConsumerUUID() string
func (*OnboardConsumerResponse) ProtoMessage ¶
func (*OnboardConsumerResponse) ProtoMessage()
func (*OnboardConsumerResponse) ProtoReflect ¶
func (x *OnboardConsumerResponse) ProtoReflect() protoreflect.Message
func (*OnboardConsumerResponse) Reset ¶
func (x *OnboardConsumerResponse) Reset()
func (*OnboardConsumerResponse) String ¶
func (x *OnboardConsumerResponse) String() string
type ReportStatusRequest ¶ added in v0.4.11
type ReportStatusRequest struct { StorageConsumerUUID string `protobuf:"bytes,1,opt,name=storageConsumerUUID,proto3" json:"storageConsumerUUID,omitempty"` // contains filtered or unexported fields }
func (*ReportStatusRequest) Descriptor
deprecated
added in
v0.4.11
func (*ReportStatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReportStatusRequest.ProtoReflect.Descriptor instead.
func (*ReportStatusRequest) GetStorageConsumerUUID ¶ added in v0.4.11
func (x *ReportStatusRequest) GetStorageConsumerUUID() string
func (*ReportStatusRequest) ProtoMessage ¶ added in v0.4.11
func (*ReportStatusRequest) ProtoMessage()
func (*ReportStatusRequest) ProtoReflect ¶ added in v0.4.11
func (x *ReportStatusRequest) ProtoReflect() protoreflect.Message
func (*ReportStatusRequest) Reset ¶ added in v0.4.11
func (x *ReportStatusRequest) Reset()
func (*ReportStatusRequest) String ¶ added in v0.4.11
func (x *ReportStatusRequest) String() string
type ReportStatusResponse ¶ added in v0.4.11
type ReportStatusResponse struct {
// contains filtered or unexported fields
}
func (*ReportStatusResponse) Descriptor
deprecated
added in
v0.4.11
func (*ReportStatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReportStatusResponse.ProtoReflect.Descriptor instead.
func (*ReportStatusResponse) ProtoMessage ¶ added in v0.4.11
func (*ReportStatusResponse) ProtoMessage()
func (*ReportStatusResponse) ProtoReflect ¶ added in v0.4.11
func (x *ReportStatusResponse) ProtoReflect() protoreflect.Message
func (*ReportStatusResponse) Reset ¶ added in v0.4.11
func (x *ReportStatusResponse) Reset()
func (*ReportStatusResponse) String ¶ added in v0.4.11
func (x *ReportStatusResponse) String() string
type RevokeStorageClassClaimRequest ¶ added in v0.4.11
type RevokeStorageClassClaimRequest struct { // name of the storageclassclaim on the consumer cluster. StorageClassClaimName string `protobuf:"bytes,1,opt,name=storageClassClaimName,proto3" json:"storageClassClaimName,omitempty"` // K8s UID (UUID) of the consumer cluster. StorageConsumerUUID string `protobuf:"bytes,2,opt,name=storageConsumerUUID,proto3" json:"storageConsumerUUID,omitempty"` // contains filtered or unexported fields }
RevokeStorageClassClaimRequest holds the information required to delete the StorageclassClaim CR on provider cluster.
func (*RevokeStorageClassClaimRequest) Descriptor
deprecated
added in
v0.4.11
func (*RevokeStorageClassClaimRequest) Descriptor() ([]byte, []int)
Deprecated: Use RevokeStorageClassClaimRequest.ProtoReflect.Descriptor instead.
func (*RevokeStorageClassClaimRequest) GetStorageClassClaimName ¶ added in v0.4.11
func (x *RevokeStorageClassClaimRequest) GetStorageClassClaimName() string
func (*RevokeStorageClassClaimRequest) GetStorageConsumerUUID ¶ added in v0.4.11
func (x *RevokeStorageClassClaimRequest) GetStorageConsumerUUID() string
func (*RevokeStorageClassClaimRequest) ProtoMessage ¶ added in v0.4.11
func (*RevokeStorageClassClaimRequest) ProtoMessage()
func (*RevokeStorageClassClaimRequest) ProtoReflect ¶ added in v0.4.11
func (x *RevokeStorageClassClaimRequest) ProtoReflect() protoreflect.Message
func (*RevokeStorageClassClaimRequest) Reset ¶ added in v0.4.11
func (x *RevokeStorageClassClaimRequest) Reset()
func (*RevokeStorageClassClaimRequest) String ¶ added in v0.4.11
func (x *RevokeStorageClassClaimRequest) String() string
type RevokeStorageClassClaimResponse ¶ added in v0.4.11
type RevokeStorageClassClaimResponse struct {
// contains filtered or unexported fields
}
RevokeStorageClassClaimResponse holds the response for the RevokeStorageClassClaim API request.
func (*RevokeStorageClassClaimResponse) Descriptor
deprecated
added in
v0.4.11
func (*RevokeStorageClassClaimResponse) Descriptor() ([]byte, []int)
Deprecated: Use RevokeStorageClassClaimResponse.ProtoReflect.Descriptor instead.
func (*RevokeStorageClassClaimResponse) ProtoMessage ¶ added in v0.4.11
func (*RevokeStorageClassClaimResponse) ProtoMessage()
func (*RevokeStorageClassClaimResponse) ProtoReflect ¶ added in v0.4.11
func (x *RevokeStorageClassClaimResponse) ProtoReflect() protoreflect.Message
func (*RevokeStorageClassClaimResponse) Reset ¶ added in v0.4.11
func (x *RevokeStorageClassClaimResponse) Reset()
func (*RevokeStorageClassClaimResponse) String ¶ added in v0.4.11
func (x *RevokeStorageClassClaimResponse) String() string
type StorageClassClaimConfigRequest ¶ added in v0.4.11
type StorageClassClaimConfigRequest struct { // name of the storageclassclaim on the consumer cluster. StorageClassClaimName string `protobuf:"bytes,1,opt,name=storageClassClaimName,proto3" json:"storageClassClaimName,omitempty"` // K8s UID (UUID) of the consumer cluster. StorageConsumerUUID string `protobuf:"bytes,2,opt,name=storageConsumerUUID,proto3" json:"storageConsumerUUID,omitempty"` // contains filtered or unexported fields }
StorageClassClaimConfigRequest holds the information required to generate the json config for StorageClassClaim specific resources.
func (*StorageClassClaimConfigRequest) Descriptor
deprecated
added in
v0.4.11
func (*StorageClassClaimConfigRequest) Descriptor() ([]byte, []int)
Deprecated: Use StorageClassClaimConfigRequest.ProtoReflect.Descriptor instead.
func (*StorageClassClaimConfigRequest) GetStorageClassClaimName ¶ added in v0.4.11
func (x *StorageClassClaimConfigRequest) GetStorageClassClaimName() string
func (*StorageClassClaimConfigRequest) GetStorageConsumerUUID ¶ added in v0.4.11
func (x *StorageClassClaimConfigRequest) GetStorageConsumerUUID() string
func (*StorageClassClaimConfigRequest) ProtoMessage ¶ added in v0.4.11
func (*StorageClassClaimConfigRequest) ProtoMessage()
func (*StorageClassClaimConfigRequest) ProtoReflect ¶ added in v0.4.11
func (x *StorageClassClaimConfigRequest) ProtoReflect() protoreflect.Message
func (*StorageClassClaimConfigRequest) Reset ¶ added in v0.4.11
func (x *StorageClassClaimConfigRequest) Reset()
func (*StorageClassClaimConfigRequest) String ¶ added in v0.4.11
func (x *StorageClassClaimConfigRequest) String() string
type StorageClassClaimConfigResponse ¶ added in v0.4.11
type StorageClassClaimConfigResponse struct { // ExternalResource holds the configuration data of external storage cluster ExternalResource []*ExternalResource `protobuf:"bytes,1,rep,name=externalResource,proto3" json:"externalResource,omitempty"` // contains filtered or unexported fields }
StorageClassClaimConfigResponse holds the response for the StorageClassClaimConfig API request.
func (*StorageClassClaimConfigResponse) Descriptor
deprecated
added in
v0.4.11
func (*StorageClassClaimConfigResponse) Descriptor() ([]byte, []int)
Deprecated: Use StorageClassClaimConfigResponse.ProtoReflect.Descriptor instead.
func (*StorageClassClaimConfigResponse) GetExternalResource ¶ added in v0.4.11
func (x *StorageClassClaimConfigResponse) GetExternalResource() []*ExternalResource
func (*StorageClassClaimConfigResponse) ProtoMessage ¶ added in v0.4.11
func (*StorageClassClaimConfigResponse) ProtoMessage()
func (*StorageClassClaimConfigResponse) ProtoReflect ¶ added in v0.4.11
func (x *StorageClassClaimConfigResponse) ProtoReflect() protoreflect.Message
func (*StorageClassClaimConfigResponse) Reset ¶ added in v0.4.11
func (x *StorageClassClaimConfigResponse) Reset()
func (*StorageClassClaimConfigResponse) String ¶ added in v0.4.11
func (x *StorageClassClaimConfigResponse) String() string
type StorageConfigRequest ¶
type StorageConfigRequest struct { // K8s UID (UUID) of the consumer cluster StorageConsumerUUID string `protobuf:"bytes,1,opt,name=storageConsumerUUID,proto3" json:"storageConsumerUUID,omitempty"` // contains filtered or unexported fields }
StorageConfigRequest holds the information required generate the json config for connecting to storage provider cluster
func (*StorageConfigRequest) Descriptor
deprecated
func (*StorageConfigRequest) Descriptor() ([]byte, []int)
Deprecated: Use StorageConfigRequest.ProtoReflect.Descriptor instead.
func (*StorageConfigRequest) GetStorageConsumerUUID ¶
func (x *StorageConfigRequest) GetStorageConsumerUUID() string
func (*StorageConfigRequest) ProtoMessage ¶
func (*StorageConfigRequest) ProtoMessage()
func (*StorageConfigRequest) ProtoReflect ¶
func (x *StorageConfigRequest) ProtoReflect() protoreflect.Message
func (*StorageConfigRequest) Reset ¶
func (x *StorageConfigRequest) Reset()
func (*StorageConfigRequest) String ¶
func (x *StorageConfigRequest) String() string
type StorageConfigResponse ¶
type StorageConfigResponse struct { // ExternalResource holds the configuration data of external storage cluster ExternalResource []*ExternalResource `protobuf:"bytes,1,rep,name=externalResource,proto3" json:"externalResource,omitempty"` // contains filtered or unexported fields }
StorageConfigResponse holds the response for the GetStorageConfig API request
func (*StorageConfigResponse) Descriptor
deprecated
func (*StorageConfigResponse) Descriptor() ([]byte, []int)
Deprecated: Use StorageConfigResponse.ProtoReflect.Descriptor instead.
func (*StorageConfigResponse) GetExternalResource ¶
func (x *StorageConfigResponse) GetExternalResource() []*ExternalResource
func (*StorageConfigResponse) ProtoMessage ¶
func (*StorageConfigResponse) ProtoMessage()
func (*StorageConfigResponse) ProtoReflect ¶
func (x *StorageConfigResponse) ProtoReflect() protoreflect.Message
func (*StorageConfigResponse) Reset ¶
func (x *StorageConfigResponse) Reset()
func (*StorageConfigResponse) String ¶
func (x *StorageConfigResponse) String() string
type UnimplementedOCSProviderServer ¶
type UnimplementedOCSProviderServer struct { }
UnimplementedOCSProviderServer must be embedded to have forward compatible implementations.
func (UnimplementedOCSProviderServer) AcknowledgeOnboarding ¶
func (UnimplementedOCSProviderServer) AcknowledgeOnboarding(context.Context, *AcknowledgeOnboardingRequest) (*AcknowledgeOnboardingResponse, error)
func (UnimplementedOCSProviderServer) FulfillStorageClassClaim ¶ added in v0.4.11
func (UnimplementedOCSProviderServer) FulfillStorageClassClaim(context.Context, *FulfillStorageClassClaimRequest) (*FulfillStorageClassClaimResponse, error)
func (UnimplementedOCSProviderServer) GetStorageClassClaimConfig ¶ added in v0.4.11
func (UnimplementedOCSProviderServer) GetStorageClassClaimConfig(context.Context, *StorageClassClaimConfigRequest) (*StorageClassClaimConfigResponse, error)
func (UnimplementedOCSProviderServer) GetStorageConfig ¶
func (UnimplementedOCSProviderServer) GetStorageConfig(context.Context, *StorageConfigRequest) (*StorageConfigResponse, error)
func (UnimplementedOCSProviderServer) OffboardConsumer ¶
func (UnimplementedOCSProviderServer) OffboardConsumer(context.Context, *OffboardConsumerRequest) (*OffboardConsumerResponse, error)
func (UnimplementedOCSProviderServer) OnboardConsumer ¶
func (UnimplementedOCSProviderServer) OnboardConsumer(context.Context, *OnboardConsumerRequest) (*OnboardConsumerResponse, error)
func (UnimplementedOCSProviderServer) ReportStatus ¶ added in v0.4.11
func (UnimplementedOCSProviderServer) ReportStatus(context.Context, *ReportStatusRequest) (*ReportStatusResponse, error)
func (UnimplementedOCSProviderServer) RevokeStorageClassClaim ¶ added in v0.4.11
func (UnimplementedOCSProviderServer) RevokeStorageClassClaim(context.Context, *RevokeStorageClassClaimRequest) (*RevokeStorageClassClaimResponse, error)
func (UnimplementedOCSProviderServer) UpdateCapacity ¶
func (UnimplementedOCSProviderServer) UpdateCapacity(context.Context, *UpdateCapacityRequest) (*UpdateCapacityResponse, error)
type UnsafeOCSProviderServer ¶
type UnsafeOCSProviderServer interface {
// contains filtered or unexported methods
}
UnsafeOCSProviderServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to OCSProviderServer will result in compilation errors.
type UpdateCapacityRequest ¶
type UpdateCapacityRequest struct { // K8s UID (UUID) of the consumer cluster StorageConsumerUUID string `protobuf:"bytes,1,opt,name=storageConsumerUUID,proto3" json:"storageConsumerUUID,omitempty"` // capacity is the desired storage requested by the consumer cluster Capacity string `protobuf:"bytes,2,opt,name=capacity,proto3" json:"capacity,omitempty"` // contains filtered or unexported fields }
UpdateCapacityRequest holds the information required to increase or decrease the block pool size on the provider cluster
func (*UpdateCapacityRequest) Descriptor
deprecated
func (*UpdateCapacityRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateCapacityRequest.ProtoReflect.Descriptor instead.
func (*UpdateCapacityRequest) GetCapacity ¶
func (x *UpdateCapacityRequest) GetCapacity() string
func (*UpdateCapacityRequest) GetStorageConsumerUUID ¶
func (x *UpdateCapacityRequest) GetStorageConsumerUUID() string
func (*UpdateCapacityRequest) ProtoMessage ¶
func (*UpdateCapacityRequest) ProtoMessage()
func (*UpdateCapacityRequest) ProtoReflect ¶
func (x *UpdateCapacityRequest) ProtoReflect() protoreflect.Message
func (*UpdateCapacityRequest) Reset ¶
func (x *UpdateCapacityRequest) Reset()
func (*UpdateCapacityRequest) String ¶
func (x *UpdateCapacityRequest) String() string
type UpdateCapacityResponse ¶
type UpdateCapacityResponse struct { // grantedCapacity is the storage granted by the provider cluster GrantedCapacity string `protobuf:"bytes,2,opt,name=grantedCapacity,proto3" json:"grantedCapacity,omitempty"` // contains filtered or unexported fields }
UpdateCapacityResponse holds the response for UpdateCapacity API request
func (*UpdateCapacityResponse) Descriptor
deprecated
func (*UpdateCapacityResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateCapacityResponse.ProtoReflect.Descriptor instead.
func (*UpdateCapacityResponse) GetGrantedCapacity ¶
func (x *UpdateCapacityResponse) GetGrantedCapacity() string
func (*UpdateCapacityResponse) ProtoMessage ¶
func (*UpdateCapacityResponse) ProtoMessage()
func (*UpdateCapacityResponse) ProtoReflect ¶
func (x *UpdateCapacityResponse) ProtoReflect() protoreflect.Message
func (*UpdateCapacityResponse) Reset ¶
func (x *UpdateCapacityResponse) Reset()
func (*UpdateCapacityResponse) String ¶
func (x *UpdateCapacityResponse) String() string