providerpb

package
v0.4.11 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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.

View Source 
var File_provider_proto protoreflect.FileDescriptor
View Source 
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 */
	// 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) 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) Enum added in v0.4.11 

func (x FulfillStorageClassClaimRequest_StorageType) Enum() *FulfillStorageClassClaimRequest_StorageType

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

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.