server

package

v0.4.13 Latest Latest Go to latest Published: Jun 1, 2023 License: Apache-2.0 Imports: 39 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/red-hat-storage/ocs-operator

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type OCSProviderServer
- func NewOCSProviderServer(ctx context.Context, namespace string) (*OCSProviderServer, error)

Constants ¶

View Source

const (
	TicketAnnotation        = "ocs.openshift.io/provider-onboarding-ticket"
	ProviderCertsMountPoint = "/mnt/cert"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type OCSProviderServer ¶

type OCSProviderServer struct {
	pb.UnimplementedOCSProviderServer
	// contains filtered or unexported fields
}

func NewOCSProviderServer ¶

func NewOCSProviderServer(ctx context.Context, namespace string) (*OCSProviderServer, error)

func (*OCSProviderServer) AcknowledgeOnboarding ¶

func (s *OCSProviderServer) AcknowledgeOnboarding(ctx context.Context, req *pb.AcknowledgeOnboardingRequest) (*pb.AcknowledgeOnboardingResponse, error)

AcknowledgeOnboarding acknowledge the onboarding is complete

func (*OCSProviderServer) FulfillStorageClassClaim ¶ added in v0.4.11

func (s *OCSProviderServer) FulfillStorageClassClaim(ctx context.Context, req *pb.FulfillStorageClassClaimRequest) (*pb.FulfillStorageClassClaimResponse, error)

FulfillStorageClassClaim RPC call to create the StorageclassClaim CR on provider cluster.

func (*OCSProviderServer) GetStorageClassClaimConfig ¶ added in v0.4.11

func (s *OCSProviderServer) GetStorageClassClaimConfig(ctx context.Context, req *pb.StorageClassClaimConfigRequest) (*pb.StorageClassClaimConfigResponse, error)

GetStorageClassClaim RPC call to get the ceph resources for the StorageclassClaim.

func (*OCSProviderServer) GetStorageConfig ¶

func (s *OCSProviderServer) GetStorageConfig(ctx context.Context, req *pb.StorageConfigRequest) (*pb.StorageConfigResponse, error)

GetStorageConfig RPC call to onboard a new OCS consumer cluster.

func (*OCSProviderServer) OffboardConsumer ¶

func (s *OCSProviderServer) OffboardConsumer(ctx context.Context, req *pb.OffboardConsumerRequest) (*pb.OffboardConsumerResponse, error)

OffboardConsumer RPC call to delete the StorageConsumer CR

func (*OCSProviderServer) OnboardConsumer ¶

func (s *OCSProviderServer) OnboardConsumer(ctx context.Context, req *pb.OnboardConsumerRequest) (*pb.OnboardConsumerResponse, error)

OnboardConsumer RPC call to onboard a new OCS consumer cluster.

func (*OCSProviderServer) ReportStatus ¶ added in v0.4.11

func (s *OCSProviderServer) ReportStatus(ctx context.Context, req *pb.ReportStatusRequest) (*pb.ReportStatusResponse, error)

ReportStatus rpc call to check if a consumer can reach to the provider.

func (*OCSProviderServer) RevokeStorageClassClaim ¶ added in v0.4.11

func (s *OCSProviderServer) RevokeStorageClassClaim(ctx context.Context, req *pb.RevokeStorageClassClaimRequest) (*pb.RevokeStorageClassClaimResponse, error)

RevokeStorageClassClaim RPC call to delete the StorageclassClaim CR on provider cluster.

func (*OCSProviderServer) Start ¶

func (s *OCSProviderServer) Start(port int, opts []grpc.ServerOption)

func (*OCSProviderServer) UpdateCapacity ¶

func (s *OCSProviderServer) UpdateCapacity(ctx context.Context, req *pb.UpdateCapacityRequest) (*pb.UpdateCapacityResponse, error)

UpdateCapacity PRC call to increase or decrease the storage pool size

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL