server

Documentation

Index

• Constants
• type OCSProviderServer
  • func NewOCSProviderServer(ctx context.Context, namespace string) (*OCSProviderServer, error)
  • func (s *OCSProviderServer) AcknowledgeOnboarding(ctx context.Context, req *pb.AcknowledgeOnboardingRequest) (*pb.AcknowledgeOnboardingResponse, error)
  • func (s *OCSProviderServer) FulfillStorageClassClaim(ctx context.Context, req *pb.FulfillStorageClassClaimRequest) (*pb.FulfillStorageClassClaimResponse, error)
  • func (s *OCSProviderServer) GetStorageClassClaimConfig(ctx context.Context, req *pb.StorageClassClaimConfigRequest) (*pb.StorageClassClaimConfigResponse, error)
  • func (s *OCSProviderServer) GetStorageConfig(ctx context.Context, req *pb.StorageConfigRequest) (*pb.StorageConfigResponse, error)
  • func (s *OCSProviderServer) OffboardConsumer(ctx context.Context, req *pb.OffboardConsumerRequest) (*pb.OffboardConsumerResponse, error)
  • func (s *OCSProviderServer) OnboardConsumer(ctx context.Context, req *pb.OnboardConsumerRequest) (*pb.OnboardConsumerResponse, error)
  • func (s *OCSProviderServer) ReportStatus(ctx context.Context, req *pb.ReportStatusRequest) (*pb.ReportStatusResponse, error)
  • func (s *OCSProviderServer) RevokeStorageClassClaim(ctx context.Context, req *pb.RevokeStorageClassClaimRequest) (*pb.RevokeStorageClassClaimResponse, error)
  • func (s *OCSProviderServer) Start(port int, opts []grpc.ServerOption)
  • func (s *OCSProviderServer) UpdateCapacity(ctx context.Context, req *pb.UpdateCapacityRequest) (*pb.UpdateCapacityResponse, error)

Constants

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

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

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

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

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

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