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) FulfillStorageClaim(ctx context.Context, req *pb.FulfillStorageClaimRequest) (*pb.FulfillStorageClaimResponse, error)
  • func (s *OCSProviderServer) GetStorageClaimConfig(ctx context.Context, req *pb.StorageClaimConfigRequest) (*pb.StorageClaimConfigResponse, 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) PeerStorageCluster(ctx context.Context, req *pb.PeerStorageClusterRequest) (*pb.PeerStorageClusterResponse, error)
  • func (s *OCSProviderServer) ReportStatus(ctx context.Context, req *pb.ReportStatusRequest) (*pb.ReportStatusResponse, error)
  • func (s *OCSProviderServer) RequestMaintenanceMode(ctx context.Context, req *pb.RequestMaintenanceModeRequest) (*pb.RequestMaintenanceModeResponse, error)
  • func (s *OCSProviderServer) RevokeStorageClaim(ctx context.Context, req *pb.RevokeStorageClaimRequest) (*pb.RevokeStorageClaimResponse, error)
  • func (s *OCSProviderServer) Start(port int, opts []grpc.ServerOption)

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) FulfillStorageClaim

func (s *OCSProviderServer) FulfillStorageClaim(ctx context.Context, req *pb.FulfillStorageClaimRequest) (*pb.FulfillStorageClaimResponse, error)

FulfillStorageClaim RPC call to create the StorageClaim CR on provider cluster.

func (*OCSProviderServer) GetStorageClaimConfig

func (s *OCSProviderServer) GetStorageClaimConfig(ctx context.Context, req *pb.StorageClaimConfigRequest) (*pb.StorageClaimConfigResponse, error)

GetStorageClaim RPC call to get the ceph resources for the StorageClaim.

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) PeerStorageCluster

func (s *OCSProviderServer) PeerStorageCluster(ctx context.Context, req *pb.PeerStorageClusterRequest) (*pb.PeerStorageClusterResponse, error)

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) RequestMaintenanceMode

func (s *OCSProviderServer) RequestMaintenanceMode(ctx context.Context, req *pb.RequestMaintenanceModeRequest) (*pb.RequestMaintenanceModeResponse, error)

func (*OCSProviderServer) RevokeStorageClaim

func (s *OCSProviderServer) RevokeStorageClaim(ctx context.Context, req *pb.RevokeStorageClaimRequest) (*pb.RevokeStorageClaimResponse, error)

RevokeStorageClaim RPC call to delete the StorageClaim CR on provider cluster.

func (*OCSProviderServer) Start

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