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 FulfillStorageClaimRequest
- func (*FulfillStorageClaimRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FulfillStorageClaimRequest) GetEncryptionMethod() string
- func (x *FulfillStorageClaimRequest) GetStorageClaimName() string
- func (x *FulfillStorageClaimRequest) GetStorageConsumerUUID() string
- func (x *FulfillStorageClaimRequest) GetStorageProfile() string
- func (x *FulfillStorageClaimRequest) GetStorageType() FulfillStorageClaimRequest_StorageType
- func (*FulfillStorageClaimRequest) ProtoMessage()
- func (x *FulfillStorageClaimRequest) ProtoReflect() protoreflect.Message
- func (x *FulfillStorageClaimRequest) Reset()
- func (x *FulfillStorageClaimRequest) String() string
- type FulfillStorageClaimRequest_StorageType
- func (FulfillStorageClaimRequest_StorageType) Descriptor() protoreflect.EnumDescriptor
- func (x FulfillStorageClaimRequest_StorageType) Enum() *FulfillStorageClaimRequest_StorageType
- func (FulfillStorageClaimRequest_StorageType) EnumDescriptor() ([]byte, []int)deprecated
- func (x FulfillStorageClaimRequest_StorageType) Number() protoreflect.EnumNumber
- func (x FulfillStorageClaimRequest_StorageType) String() string
- func (FulfillStorageClaimRequest_StorageType) Type() protoreflect.EnumType
- type FulfillStorageClaimResponse
- 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) GetClientOperatorVersion() 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 (o *OnboardConsumerRequest) SetClientOperatorVersion(version string) ifaces.StorageClientOnboarding
- func (o *OnboardConsumerRequest) SetConsumerName(name string) ifaces.StorageClientOnboarding
- func (o *OnboardConsumerRequest) SetOnboardingTicket(ticket string) ifaces.StorageClientOnboarding
- func (x *OnboardConsumerRequest) String() string
- type OnboardConsumerResponse
- func (*OnboardConsumerResponse) Descriptor() ([]byte, []int)deprecated
- 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) GetClientName() string
- func (x *ReportStatusRequest) GetClientOperatorVersion() string
- func (x *ReportStatusRequest) GetClientPlatformVersion() string
- func (x *ReportStatusRequest) GetClusterID() string
- func (x *ReportStatusRequest) GetClusterName() string
- func (r *ReportStatusRequest) GetOperatorVersion() string
- func (r *ReportStatusRequest) GetPlatformVersion() string
- func (x *ReportStatusRequest) GetStorageConsumerUUID() string
- func (*ReportStatusRequest) ProtoMessage()
- func (x *ReportStatusRequest) ProtoReflect() protoreflect.Message
- func (x *ReportStatusRequest) Reset()
- func (r *ReportStatusRequest) SetClientName(clientName string) ifaces.StorageClientStatus
- func (r *ReportStatusRequest) SetClusterID(clusterID string) ifaces.StorageClientStatus
- func (r *ReportStatusRequest) SetClusterName(clusterName string) ifaces.StorageClientStatus
- func (r *ReportStatusRequest) SetOperatorVersion(version string) ifaces.StorageClientStatus
- func (r *ReportStatusRequest) SetPlatformVersion(version string) ifaces.StorageClientStatus
- func (x *ReportStatusRequest) String() string
- type ReportStatusResponse
- func (*ReportStatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ReportStatusResponse) GetDesiredClientOperatorChannel() string
- func (*ReportStatusResponse) ProtoMessage()
- func (x *ReportStatusResponse) ProtoReflect() protoreflect.Message
- func (x *ReportStatusResponse) Reset()
- func (x *ReportStatusResponse) String() string
- type RevokeStorageClaimRequest
- func (*RevokeStorageClaimRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RevokeStorageClaimRequest) GetStorageClaimName() string
- func (x *RevokeStorageClaimRequest) GetStorageConsumerUUID() string
- func (*RevokeStorageClaimRequest) ProtoMessage()
- func (x *RevokeStorageClaimRequest) ProtoReflect() protoreflect.Message
- func (x *RevokeStorageClaimRequest) Reset()
- func (x *RevokeStorageClaimRequest) String() string
- type RevokeStorageClaimResponse
- type StorageClaimConfigRequest
- func (*StorageClaimConfigRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StorageClaimConfigRequest) GetStorageClaimName() string
- func (x *StorageClaimConfigRequest) GetStorageConsumerUUID() string
- func (*StorageClaimConfigRequest) ProtoMessage()
- func (x *StorageClaimConfigRequest) ProtoReflect() protoreflect.Message
- func (x *StorageClaimConfigRequest) Reset()
- func (x *StorageClaimConfigRequest) String() string
- type StorageClaimConfigResponse
- func (*StorageClaimConfigResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StorageClaimConfigResponse) GetExternalResource() []*ExternalResource
- func (*StorageClaimConfigResponse) ProtoMessage()
- func (x *StorageClaimConfigResponse) ProtoReflect() protoreflect.Message
- func (x *StorageClaimConfigResponse) Reset()
- func (x *StorageClaimConfigResponse) 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) FulfillStorageClaim(context.Context, *FulfillStorageClaimRequest) (*FulfillStorageClaimResponse, error)
- func (UnimplementedOCSProviderServer) GetStorageClaimConfig(context.Context, *StorageClaimConfigRequest) (*StorageClaimConfigResponse, 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) RevokeStorageClaim(context.Context, *RevokeStorageClaimRequest) (*RevokeStorageClaimResponse, error)
- type UnsafeOCSProviderServer
Constants ¶
This section is empty.
Variables ¶
var ( FulfillStorageClaimRequest_StorageType_name = map[int32]string{ 0: "SHAREDFILE", 1: "BLOCK", } FulfillStorageClaimRequest_StorageType_value = map[string]int32{ "SHAREDFILE": 0, "BLOCK": 1, } )
Enum value maps for FulfillStorageClaimRequest_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: "AcknowledgeOnboarding", Handler: _OCSProvider_AcknowledgeOnboarding_Handler, }, { MethodName: "FulfillStorageClaim", Handler: _OCSProvider_FulfillStorageClaim_Handler, }, { MethodName: "RevokeStorageClaim", Handler: _OCSProvider_RevokeStorageClaim_Handler, }, { MethodName: "GetStorageClaimConfig", Handler: _OCSProvider_GetStorageClaimConfig_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 FulfillStorageClaimRequest ¶
type FulfillStorageClaimRequest struct { // name of the storageClaim on the consumer cluster. StorageClaimName string `protobuf:"bytes,1,opt,name=storageClaimName,proto3" json:"storageClaimName,omitempty"` // K8s UID (UUID) of the consumer cluster. StorageConsumerUUID string `protobuf:"bytes,2,opt,name=storageConsumerUUID,proto3" json:"storageConsumerUUID,omitempty"` // encryption method of the storageClaim. EncryptionMethod string `protobuf:"bytes,3,opt,name=encryptionMethod,proto3" json:"encryptionMethod,omitempty"` StorageType FulfillStorageClaimRequest_StorageType `` /* 129-byte string literal not displayed */ // storageProfile of the storageClaim. StorageProfile string `protobuf:"bytes,5,opt,name=storageProfile,proto3" json:"storageProfile,omitempty"` // contains filtered or unexported fields }
FulfillStorageClaimRequest holds the information required to create the StorageClaim CR on provider cluster.
func (*FulfillStorageClaimRequest) Descriptor
deprecated
func (*FulfillStorageClaimRequest) Descriptor() ([]byte, []int)
Deprecated: Use FulfillStorageClaimRequest.ProtoReflect.Descriptor instead.
func (*FulfillStorageClaimRequest) GetEncryptionMethod ¶
func (x *FulfillStorageClaimRequest) GetEncryptionMethod() string
func (*FulfillStorageClaimRequest) GetStorageClaimName ¶
func (x *FulfillStorageClaimRequest) GetStorageClaimName() string
func (*FulfillStorageClaimRequest) GetStorageConsumerUUID ¶
func (x *FulfillStorageClaimRequest) GetStorageConsumerUUID() string
func (*FulfillStorageClaimRequest) GetStorageProfile ¶
func (x *FulfillStorageClaimRequest) GetStorageProfile() string
func (*FulfillStorageClaimRequest) GetStorageType ¶
func (x *FulfillStorageClaimRequest) GetStorageType() FulfillStorageClaimRequest_StorageType
func (*FulfillStorageClaimRequest) ProtoMessage ¶
func (*FulfillStorageClaimRequest) ProtoMessage()
func (*FulfillStorageClaimRequest) ProtoReflect ¶
func (x *FulfillStorageClaimRequest) ProtoReflect() protoreflect.Message
func (*FulfillStorageClaimRequest) Reset ¶
func (x *FulfillStorageClaimRequest) Reset()
func (*FulfillStorageClaimRequest) String ¶
func (x *FulfillStorageClaimRequest) String() string
type FulfillStorageClaimRequest_StorageType ¶
type FulfillStorageClaimRequest_StorageType int32
StorageType of the storageClaim
const ( FulfillStorageClaimRequest_SHAREDFILE FulfillStorageClaimRequest_StorageType = 0 FulfillStorageClaimRequest_BLOCK FulfillStorageClaimRequest_StorageType = 1 )
func (FulfillStorageClaimRequest_StorageType) Descriptor ¶
func (FulfillStorageClaimRequest_StorageType) Descriptor() protoreflect.EnumDescriptor
func (FulfillStorageClaimRequest_StorageType) EnumDescriptor
deprecated
func (FulfillStorageClaimRequest_StorageType) EnumDescriptor() ([]byte, []int)
Deprecated: Use FulfillStorageClaimRequest_StorageType.Descriptor instead.
func (FulfillStorageClaimRequest_StorageType) Number ¶
func (x FulfillStorageClaimRequest_StorageType) Number() protoreflect.EnumNumber
func (FulfillStorageClaimRequest_StorageType) String ¶
func (x FulfillStorageClaimRequest_StorageType) String() string
func (FulfillStorageClaimRequest_StorageType) Type ¶
func (FulfillStorageClaimRequest_StorageType) Type() protoreflect.EnumType
type FulfillStorageClaimResponse ¶
type FulfillStorageClaimResponse struct {
// contains filtered or unexported fields
}
FulfillStorageClaimResponse holds the response for the FulfillStorageClaim API request.
func (*FulfillStorageClaimResponse) Descriptor
deprecated
func (*FulfillStorageClaimResponse) Descriptor() ([]byte, []int)
Deprecated: Use FulfillStorageClaimResponse.ProtoReflect.Descriptor instead.
func (*FulfillStorageClaimResponse) ProtoMessage ¶
func (*FulfillStorageClaimResponse) ProtoMessage()
func (*FulfillStorageClaimResponse) ProtoReflect ¶
func (x *FulfillStorageClaimResponse) ProtoReflect() protoreflect.Message
func (*FulfillStorageClaimResponse) Reset ¶
func (x *FulfillStorageClaimResponse) Reset()
func (*FulfillStorageClaimResponse) String ¶
func (x *FulfillStorageClaimResponse) 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) // AcknowledgeOnboarding RPC call acknowledge the onboarding AcknowledgeOnboarding(ctx context.Context, in *AcknowledgeOnboardingRequest, opts ...grpc.CallOption) (*AcknowledgeOnboardingResponse, error) // FulfillStorageClaim RPC call to create the StorageClaim CR on // provider cluster. FulfillStorageClaim(ctx context.Context, in *FulfillStorageClaimRequest, opts ...grpc.CallOption) (*FulfillStorageClaimResponse, error) // RevokeStorageClaim RPC call to delete the StorageClaim CR // on provider cluster. RevokeStorageClaim(ctx context.Context, in *RevokeStorageClaimRequest, opts ...grpc.CallOption) (*RevokeStorageClaimResponse, error) // GetStorageClaimConfig RPC call to generate the json config for claim // specific resources. GetStorageClaimConfig(ctx context.Context, in *StorageClaimConfigRequest, opts ...grpc.CallOption) (*StorageClaimConfigResponse, 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) // AcknowledgeOnboarding RPC call acknowledge the onboarding AcknowledgeOnboarding(context.Context, *AcknowledgeOnboardingRequest) (*AcknowledgeOnboardingResponse, error) // FulfillStorageClaim RPC call to create the StorageClaim CR on // provider cluster. FulfillStorageClaim(context.Context, *FulfillStorageClaimRequest) (*FulfillStorageClaimResponse, error) // RevokeStorageClaim RPC call to delete the StorageClaim CR // on provider cluster. RevokeStorageClaim(context.Context, *RevokeStorageClaimRequest) (*RevokeStorageClaimResponse, error) // GetStorageClaimConfig RPC call to generate the json config for claim // specific resources. GetStorageClaimConfig(context.Context, *StorageClaimConfigRequest) (*StorageClaimConfigResponse, 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"` // clientOperatorVersion is the semver version of ocs-client-operator ClientOperatorVersion string `protobuf:"bytes,3,opt,name=clientOperatorVersion,proto3" json:"clientOperatorVersion,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) GetClientOperatorVersion ¶
func (x *OnboardConsumerRequest) GetClientOperatorVersion() 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) SetClientOperatorVersion ¶
func (o *OnboardConsumerRequest) SetClientOperatorVersion(version string) ifaces.StorageClientOnboarding
func (*OnboardConsumerRequest) SetConsumerName ¶
func (o *OnboardConsumerRequest) SetConsumerName(name string) ifaces.StorageClientOnboarding
func (*OnboardConsumerRequest) SetOnboardingTicket ¶
func (o *OnboardConsumerRequest) SetOnboardingTicket(ticket string) ifaces.StorageClientOnboarding
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"` // 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) 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 ¶
type ReportStatusRequest struct { StorageConsumerUUID string `protobuf:"bytes,1,opt,name=storageConsumerUUID,proto3" json:"storageConsumerUUID,omitempty"` ClientPlatformVersion string `protobuf:"bytes,2,opt,name=clientPlatformVersion,proto3" json:"clientPlatformVersion,omitempty"` ClientOperatorVersion string `protobuf:"bytes,3,opt,name=clientOperatorVersion,proto3" json:"clientOperatorVersion,omitempty"` // clusterID is the id of the openshift cluster ClusterID string `protobuf:"bytes,4,opt,name=clusterID,proto3" json:"clusterID,omitempty"` // clusterName is the name of the openshift cluster ClusterName string `protobuf:"bytes,5,opt,name=clusterName,proto3" json:"clusterName,omitempty"` // clientName is the name of the connected storageclient ClientName string `protobuf:"bytes,6,opt,name=clientName,proto3" json:"clientName,omitempty"` // contains filtered or unexported fields }
func (*ReportStatusRequest) Descriptor
deprecated
func (*ReportStatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReportStatusRequest.ProtoReflect.Descriptor instead.
func (*ReportStatusRequest) GetClientName ¶
func (x *ReportStatusRequest) GetClientName() string
func (*ReportStatusRequest) GetClientOperatorVersion ¶
func (x *ReportStatusRequest) GetClientOperatorVersion() string
func (*ReportStatusRequest) GetClientPlatformVersion ¶
func (x *ReportStatusRequest) GetClientPlatformVersion() string
func (*ReportStatusRequest) GetClusterID ¶
func (x *ReportStatusRequest) GetClusterID() string
func (*ReportStatusRequest) GetClusterName ¶
func (x *ReportStatusRequest) GetClusterName() string
func (*ReportStatusRequest) GetOperatorVersion ¶
func (r *ReportStatusRequest) GetOperatorVersion() string
func (*ReportStatusRequest) GetPlatformVersion ¶
func (r *ReportStatusRequest) GetPlatformVersion() string
func (*ReportStatusRequest) GetStorageConsumerUUID ¶
func (x *ReportStatusRequest) GetStorageConsumerUUID() string
func (*ReportStatusRequest) ProtoMessage ¶
func (*ReportStatusRequest) ProtoMessage()
func (*ReportStatusRequest) ProtoReflect ¶
func (x *ReportStatusRequest) ProtoReflect() protoreflect.Message
func (*ReportStatusRequest) Reset ¶
func (x *ReportStatusRequest) Reset()
func (*ReportStatusRequest) SetClientName ¶
func (r *ReportStatusRequest) SetClientName(clientName string) ifaces.StorageClientStatus
func (*ReportStatusRequest) SetClusterID ¶
func (r *ReportStatusRequest) SetClusterID(clusterID string) ifaces.StorageClientStatus
func (*ReportStatusRequest) SetClusterName ¶
func (r *ReportStatusRequest) SetClusterName(clusterName string) ifaces.StorageClientStatus
func (*ReportStatusRequest) SetOperatorVersion ¶
func (r *ReportStatusRequest) SetOperatorVersion(version string) ifaces.StorageClientStatus
func (*ReportStatusRequest) SetPlatformVersion ¶
func (r *ReportStatusRequest) SetPlatformVersion(version string) ifaces.StorageClientStatus
func (*ReportStatusRequest) String ¶
func (x *ReportStatusRequest) String() string
type ReportStatusResponse ¶
type ReportStatusResponse struct { // Contains subscription channel of provider operator for client operator to match DesiredClientOperatorChannel string `protobuf:"bytes,1,opt,name=desiredClientOperatorChannel,proto3" json:"desiredClientOperatorChannel,omitempty"` // contains filtered or unexported fields }
func (*ReportStatusResponse) Descriptor
deprecated
func (*ReportStatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReportStatusResponse.ProtoReflect.Descriptor instead.
func (*ReportStatusResponse) GetDesiredClientOperatorChannel ¶
func (x *ReportStatusResponse) GetDesiredClientOperatorChannel() string
func (*ReportStatusResponse) ProtoMessage ¶
func (*ReportStatusResponse) ProtoMessage()
func (*ReportStatusResponse) ProtoReflect ¶
func (x *ReportStatusResponse) ProtoReflect() protoreflect.Message
func (*ReportStatusResponse) Reset ¶
func (x *ReportStatusResponse) Reset()
func (*ReportStatusResponse) String ¶
func (x *ReportStatusResponse) String() string
type RevokeStorageClaimRequest ¶
type RevokeStorageClaimRequest struct { // name of the storageClaim on the consumer cluster. StorageClaimName string `protobuf:"bytes,1,opt,name=storageClaimName,proto3" json:"storageClaimName,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 }
RevokeStorageClaimRequest holds the information required to delete the StorageClaim CR on provider cluster.
func (*RevokeStorageClaimRequest) Descriptor
deprecated
func (*RevokeStorageClaimRequest) Descriptor() ([]byte, []int)
Deprecated: Use RevokeStorageClaimRequest.ProtoReflect.Descriptor instead.
func (*RevokeStorageClaimRequest) GetStorageClaimName ¶
func (x *RevokeStorageClaimRequest) GetStorageClaimName() string
func (*RevokeStorageClaimRequest) GetStorageConsumerUUID ¶
func (x *RevokeStorageClaimRequest) GetStorageConsumerUUID() string
func (*RevokeStorageClaimRequest) ProtoMessage ¶
func (*RevokeStorageClaimRequest) ProtoMessage()
func (*RevokeStorageClaimRequest) ProtoReflect ¶
func (x *RevokeStorageClaimRequest) ProtoReflect() protoreflect.Message
func (*RevokeStorageClaimRequest) Reset ¶
func (x *RevokeStorageClaimRequest) Reset()
func (*RevokeStorageClaimRequest) String ¶
func (x *RevokeStorageClaimRequest) String() string
type RevokeStorageClaimResponse ¶
type RevokeStorageClaimResponse struct {
// contains filtered or unexported fields
}
RevokeStorageClaimResponse holds the response for the RevokeStorageClaim API request.
func (*RevokeStorageClaimResponse) Descriptor
deprecated
func (*RevokeStorageClaimResponse) Descriptor() ([]byte, []int)
Deprecated: Use RevokeStorageClaimResponse.ProtoReflect.Descriptor instead.
func (*RevokeStorageClaimResponse) ProtoMessage ¶
func (*RevokeStorageClaimResponse) ProtoMessage()
func (*RevokeStorageClaimResponse) ProtoReflect ¶
func (x *RevokeStorageClaimResponse) ProtoReflect() protoreflect.Message
func (*RevokeStorageClaimResponse) Reset ¶
func (x *RevokeStorageClaimResponse) Reset()
func (*RevokeStorageClaimResponse) String ¶
func (x *RevokeStorageClaimResponse) String() string
type StorageClaimConfigRequest ¶
type StorageClaimConfigRequest struct { // name of the storageClaim on the consumer cluster. StorageClaimName string `protobuf:"bytes,1,opt,name=storageClaimName,proto3" json:"storageClaimName,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 }
StorageClaimConfigRequest holds the information required to generate the json config for StorageClaim specific resources.
func (*StorageClaimConfigRequest) Descriptor
deprecated
func (*StorageClaimConfigRequest) Descriptor() ([]byte, []int)
Deprecated: Use StorageClaimConfigRequest.ProtoReflect.Descriptor instead.
func (*StorageClaimConfigRequest) GetStorageClaimName ¶
func (x *StorageClaimConfigRequest) GetStorageClaimName() string
func (*StorageClaimConfigRequest) GetStorageConsumerUUID ¶
func (x *StorageClaimConfigRequest) GetStorageConsumerUUID() string
func (*StorageClaimConfigRequest) ProtoMessage ¶
func (*StorageClaimConfigRequest) ProtoMessage()
func (*StorageClaimConfigRequest) ProtoReflect ¶
func (x *StorageClaimConfigRequest) ProtoReflect() protoreflect.Message
func (*StorageClaimConfigRequest) Reset ¶
func (x *StorageClaimConfigRequest) Reset()
func (*StorageClaimConfigRequest) String ¶
func (x *StorageClaimConfigRequest) String() string
type StorageClaimConfigResponse ¶
type StorageClaimConfigResponse 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 }
StorageClaimConfigResponse holds the response for the StorageClaimConfig API request.
func (*StorageClaimConfigResponse) Descriptor
deprecated
func (*StorageClaimConfigResponse) Descriptor() ([]byte, []int)
Deprecated: Use StorageClaimConfigResponse.ProtoReflect.Descriptor instead.
func (*StorageClaimConfigResponse) GetExternalResource ¶
func (x *StorageClaimConfigResponse) GetExternalResource() []*ExternalResource
func (*StorageClaimConfigResponse) ProtoMessage ¶
func (*StorageClaimConfigResponse) ProtoMessage()
func (*StorageClaimConfigResponse) ProtoReflect ¶
func (x *StorageClaimConfigResponse) ProtoReflect() protoreflect.Message
func (*StorageClaimConfigResponse) Reset ¶
func (x *StorageClaimConfigResponse) Reset()
func (*StorageClaimConfigResponse) String ¶
func (x *StorageClaimConfigResponse) 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) FulfillStorageClaim ¶
func (UnimplementedOCSProviderServer) FulfillStorageClaim(context.Context, *FulfillStorageClaimRequest) (*FulfillStorageClaimResponse, error)
func (UnimplementedOCSProviderServer) GetStorageClaimConfig ¶
func (UnimplementedOCSProviderServer) GetStorageClaimConfig(context.Context, *StorageClaimConfigRequest) (*StorageClaimConfigResponse, 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 ¶
func (UnimplementedOCSProviderServer) ReportStatus(context.Context, *ReportStatusRequest) (*ReportStatusResponse, error)
func (UnimplementedOCSProviderServer) RevokeStorageClaim ¶
func (UnimplementedOCSProviderServer) RevokeStorageClaim(context.Context, *RevokeStorageClaimRequest) (*RevokeStorageClaimResponse, 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.