server

Documentation

Index

• type CSIDriverProviderServer
  • func New(constructPEMChain, writeCertAndKeyInSeparateFiles bool, ...) *CSIDriverProviderServer
  • func (s *CSIDriverProviderServer) Check(_ context.Context, _ *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)
  • func (s *CSIDriverProviderServer) Mount(ctx context.Context, req *v1alpha1.MountRequest) (*v1alpha1.MountResponse, error)
  • func (s *CSIDriverProviderServer) Version(_ context.Context, _ *v1alpha1.VersionRequest) (*v1alpha1.VersionResponse, error)
  • func (s *CSIDriverProviderServer) Watch(_ *grpc_health_v1.HealthCheckRequest, _ grpc_health_v1.Health_WatchServer) error
• type HealthZ
  • func (h *HealthZ) Serve()
  • func (h *HealthZ) ServeHTTP(w http.ResponseWriter, _ *http.Request)

Types

type CSIDriverProviderServer

type CSIDriverProviderServer struct {
	*grpc.Server
	// contains filtered or unexported fields
}

CSIDriverProviderServer providers a Secrets Store CSI Driver provider implementation

func New

func New(constructPEMChain, writeCertAndKeyInSeparateFiles bool, defaultCloudEnvironment azure.Environment) *CSIDriverProviderServer

New returns an instance of CSIDriverProviderServer

func (*CSIDriverProviderServer) Check

func (s *CSIDriverProviderServer) Check(_ context.Context, _ *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)

func (*CSIDriverProviderServer) Mount

func (s *CSIDriverProviderServer) Mount(ctx context.Context, req *v1alpha1.MountRequest) (*v1alpha1.MountResponse, error)

Mount executes the mount operation in the provider. The provider fetches the objects from Key Vault writes the contents to the pod mount and returns the object versions as part of MountResponse

func (*CSIDriverProviderServer) Version

func (s *CSIDriverProviderServer) Version(_ context.Context, _ *v1alpha1.VersionRequest) (*v1alpha1.VersionResponse, error)

func (*CSIDriverProviderServer) Watch

func (s *CSIDriverProviderServer) Watch(_ *grpc_health_v1.HealthCheckRequest, _ grpc_health_v1.Health_WatchServer) error

Watch for the serving status of the requested service.

type HealthZ

type HealthZ struct {
	HealthCheckURL *url.URL
	UnixSocketPath string
	RPCTimeout     time.Duration
}

func (*HealthZ) Serve

func (h *HealthZ) Serve()

Serve creates the http handler for serving health requests

func (*HealthZ) ServeHTTP

func (h *HealthZ) ServeHTTP(w http.ResponseWriter, _ *http.Request)