Documentation
¶
Index ¶
- type IdentityServer
- func (is *IdentityServer) GetCapabilities(ctx context.Context, req *identity.GetCapabilitiesRequest) (*identity.GetCapabilitiesResponse, error)
- func (is *IdentityServer) GetIdentity(ctx context.Context, req *identity.GetIdentityRequest) (*identity.GetIdentityResponse, error)
- func (is *IdentityServer) Probe(ctx context.Context, req *identity.ProbeRequest) (*identity.ProbeResponse, error)
- func (is *IdentityServer) RegisterService(server grpc.ServiceRegistrar)
- type NetworkFenceServer
- func (ns *NetworkFenceServer) FenceClusterNetwork(ctx context.Context, req *proto.NetworkFenceRequest) (*proto.NetworkFenceResponse, error)
- func (ns *NetworkFenceServer) RegisterService(server grpc.ServiceRegistrar)
- func (ns *NetworkFenceServer) UnFenceClusterNetwork(ctx context.Context, req *proto.NetworkFenceRequest) (*proto.NetworkFenceResponse, error)
- type ReclaimSpaceServer
- func (rs *ReclaimSpaceServer) ControllerReclaimSpace(ctx context.Context, req *proto.ReclaimSpaceRequest) (*proto.ReclaimSpaceResponse, error)
- func (rs *ReclaimSpaceServer) NodeReclaimSpace(ctx context.Context, req *proto.ReclaimSpaceRequest) (*proto.ReclaimSpaceResponse, error)
- func (rs *ReclaimSpaceServer) RegisterService(server grpc.ServiceRegistrar)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type IdentityServer ¶
type IdentityServer struct {
*identity.UnimplementedIdentityServer
// contains filtered or unexported fields
}
IdentityServer struct of sidecar with supported methods of CSI identity server spec and also containing client to csi driver.
func NewIdentityServer ¶
func NewIdentityServer(client *grpc.ClientConn) *IdentityServer
NewIdentityServer creates a new IdentityServer which handles the Identity Service requests from the CSI-Addons specification.
func (*IdentityServer) GetCapabilities ¶
func (is *IdentityServer) GetCapabilities( ctx context.Context, req *identity.GetCapabilitiesRequest) (*identity.GetCapabilitiesResponse, error)
GetCapabilities returns available capabilities from the driver.
func (*IdentityServer) GetIdentity ¶
func (is *IdentityServer) GetIdentity( ctx context.Context, req *identity.GetIdentityRequest) (*identity.GetIdentityResponse, error)
GetIdentity returns available capabilities from the driver.
func (*IdentityServer) Probe ¶
func (is *IdentityServer) Probe( ctx context.Context, req *identity.ProbeRequest) (*identity.ProbeResponse, error)
Probe is called by the CO plugin to validate that the CSI-Addons Node is still healthy.
func (*IdentityServer) RegisterService ¶
func (is *IdentityServer) RegisterService(server grpc.ServiceRegistrar)
type NetworkFenceServer ¶
type NetworkFenceServer struct {
proto.UnimplementedNetworkFenceServer
// contains filtered or unexported fields
}
NetworkFenceServer struct of sidecar with supported methods of proto networkFence server spec and controller client to csi driver.
func NewNetworkFenceServer ¶
func NewNetworkFenceServer(c *grpc.ClientConn, kc *kubernetes.Clientset) *NetworkFenceServer
NewNetworkFenceServer creates a new NetworkFenceServer which handles the proto.NetworkFence Service requests.
func (*NetworkFenceServer) FenceClusterNetwork ¶
func (ns *NetworkFenceServer) FenceClusterNetwork( ctx context.Context, req *proto.NetworkFenceRequest) (*proto.NetworkFenceResponse, error)
FenceClusterNetwork fetches required information from kubernetes cluster and calls CSI-Addons FenceClusterNetwork service.
func (*NetworkFenceServer) RegisterService ¶
func (ns *NetworkFenceServer) RegisterService(server grpc.ServiceRegistrar)
RegisterService registers service with the server.
func (*NetworkFenceServer) UnFenceClusterNetwork ¶
func (ns *NetworkFenceServer) UnFenceClusterNetwork( ctx context.Context, req *proto.NetworkFenceRequest) (*proto.NetworkFenceResponse, error)
UnFenceClusterNetwork fetches required information from kubernetes cluster and calls CSI-Addons UnFenceClusterNetwork service.
type ReclaimSpaceServer ¶
type ReclaimSpaceServer struct {
proto.UnimplementedReclaimSpaceServer
// contains filtered or unexported fields
}
ReclaimSpaceServer struct of sidecar with supported methods of proto reclaim space server spec and also containing reclaimspace node and controller client to csi driver.
func NewReclaimSpaceServer ¶
func NewReclaimSpaceServer(c *grpc.ClientConn, kc *kubernetes.Clientset, sp string) *ReclaimSpaceServer
NewReclaimSpaceServer creates a new ReclaimSpaceServer which handles the proto.ReclaimSpace Service requests.
func (*ReclaimSpaceServer) ControllerReclaimSpace ¶
func (rs *ReclaimSpaceServer) ControllerReclaimSpace( ctx context.Context, req *proto.ReclaimSpaceRequest) (*proto.ReclaimSpaceResponse, error)
ControllerReclaimSpace fetches required information from kubernetes cluster and calls CSI-Addons ControllerReclaimSpace service.
func (*ReclaimSpaceServer) NodeReclaimSpace ¶
func (rs *ReclaimSpaceServer) NodeReclaimSpace( ctx context.Context, req *proto.ReclaimSpaceRequest) (*proto.ReclaimSpaceResponse, error)
NodeReclaimSpace fetches required information from kubernetes cluster and calls CSI-Addons NodeReclaimSpace service.
func (*ReclaimSpaceServer) RegisterService ¶
func (rs *ReclaimSpaceServer) RegisterService(server grpc.ServiceRegistrar)
RegisterService registers service with the server.
Source Files