service

Documentation

Index

• Constants
• Variables
• type Driver
  • func NewDriver() Driver
• type NonBlockingGRPCServer
  • func NewNonBlockingGRPCServer() NonBlockingGRPCServer

Constants

const (

	// UnixSocketPrefix is the prefix before the path on disk.
	UnixSocketPrefix = "unix://"
)

Variables

var (
	// COInitParams stores the input params required for initiating the
	// CO agnostic orchestrator for the controller as well as node containers.
	COInitParams interface{}
)

var Version string

Version of the driver. This should be set via ldflags.

Types

type Driver

type Driver interface {
	csi.IdentityServer
	csi.NodeServer
	GetController() csi.ControllerServer
	BeforeServe(context.Context) error
	Run(ctx context.Context, endpoint string)
}

Driver is a CSI SP and idempotency.Provider.

func NewDriver

func NewDriver() Driver

NewDriver returns a new Driver.

type NonBlockingGRPCServer

type NonBlockingGRPCServer interface {
	// Start services at the endpoint.
	Start(endpoint string, ids csi.IdentityServer, cs csi.ControllerServer, ns csi.NodeServer)

	// Stop stops the gRPC server. It immediately closes all open connections
	// and listeners. It cancels all active RPCs on the server side and the
	// corresponding pending RPCs on the client side will get notified by
	// connection errors.
	Stop()

	// GracefulStop stops the gRPC server gracefully. It stops the server
	// from accepting new connections and RPCs and blocks until all the
	// pending RPCs are finished.
	GracefulStop()
}

NonBlockingGRPCServer defines non-blocking GRPC server interfaces.

func NewNonBlockingGRPCServer

func NewNonBlockingGRPCServer() NonBlockingGRPCServer

NewNonBlockingGRPCServer returns an instance of nonBlockingGRPCServer.