provider

Documentation

Index

• type ServiceProvider
  • func New(opts []grpc.ServerOption, interceptors []grpc.UnaryServerInterceptor) ServiceProvider

Types

type ServiceProvider

type ServiceProvider interface {

	// Serve accepts incoming connections on the listener lis, creating
	// a new ServerTransport and service goroutine for each. The service
	// goroutine read gRPC requests and then call the registered handlers
	// to reply to them. Serve returns when lis.Accept fails with fatal
	// errors.  lis will be closed when this method returns.
	// Serve always returns non-nil error.
	Serve(ctx context.Context, lis net.Listener) error

	// 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(ctx context.Context)

	// 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(ctx context.Context)
}

ServiceProvider is a gRPC endpoint that provides the CSI services: Controller, Identity, Node.

func New

func New(
	opts []grpc.ServerOption,
	interceptors []grpc.UnaryServerInterceptor) ServiceProvider

New returns a new service provider.