service

package
v0.8.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 15, 2023 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

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.

type ReplicationServer added in v0.5.0 

type ReplicationServer struct {
	proto.UnimplementedReplicationServer
	// contains filtered or unexported fields
}

ReplicationServer struct of sidecar with supported methods of proto replication server spec and also containing replication controller client to csi driver.

func NewReplicationServer added in v0.5.0 

func NewReplicationServer(c *grpc.ClientConn, kc *kubernetes.Clientset) *ReplicationServer

NewReplicationServer creates a new ReplicationServer which handles the proto.Replication Service requests.

func (*ReplicationServer) DemoteVolume added in v0.5.0 

func (rs *ReplicationServer) DemoteVolume(
	ctx context.Context,
	req *proto.DemoteVolumeRequest) (*proto.DemoteVolumeResponse, error)

DemoteVolume fetches required information from kubernetes cluster and calls CSI-Addons DemoteVolume service.

func (*ReplicationServer) DisableVolumeReplication added in v0.5.0 

func (rs *ReplicationServer) DisableVolumeReplication(
	ctx context.Context,
	req *proto.DisableVolumeReplicationRequest) (*proto.DisableVolumeReplicationResponse, error)

DisableVolumeReplication fetches required information from kubernetes cluster and calls CSI-Addons DisableVolumeReplication service.

func (*ReplicationServer) EnableVolumeReplication added in v0.5.0 

func (rs *ReplicationServer) EnableVolumeReplication(
	ctx context.Context,
	req *proto.EnableVolumeReplicationRequest) (*proto.EnableVolumeReplicationResponse, error)

EnableVolumeReplication fetches required information from kubernetes cluster and calls CSI-Addons EnableVolumeReplication service.

func (*ReplicationServer) GetVolumeReplicationInfo added in v0.6.0 

func (rs *ReplicationServer) GetVolumeReplicationInfo(
	ctx context.Context,
	req *proto.GetVolumeReplicationInfoRequest) (*proto.GetVolumeReplicationInfoResponse, error)

GetVolumeReplicationInfo fetches required information from kubernetes cluster and calls CSI-Addons GetVolumeReplicationInfo service.

func (*ReplicationServer) PromoteVolume added in v0.5.0 

func (rs *ReplicationServer) PromoteVolume(
	ctx context.Context,
	req *proto.PromoteVolumeRequest) (*proto.PromoteVolumeResponse, error)

PromoteVolume fetches required information from kubernetes cluster and calls CSI-Addons PromoteVolume service.

func (*ReplicationServer) RegisterService added in v0.5.0 

func (rs *ReplicationServer) RegisterService(server grpc.ServiceRegistrar)

RegisterService registers service with the server.

func (*ReplicationServer) ResyncVolume added in v0.5.0 

func (rs *ReplicationServer) ResyncVolume(
	ctx context.Context,
	req *proto.ResyncVolumeRequest) (*proto.ResyncVolumeResponse, error)

ResyncVolume fetches required information from kubernetes cluster and calls CSI-Addons ResyncVolume service.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.