pmemcsidriver

Documentation

Index

• type NonBlockingGRPCServer
  • func NewNonBlockingGRPCServer() *NonBlockingGRPCServer
  • func (s *NonBlockingGRPCServer) ForceStop()
  • func (s *NonBlockingGRPCServer) Start(ctx context.Context, endpoint, errorPrefix string, tlsConfig *tls.Config, ...) error
  • func (s *NonBlockingGRPCServer) Stop()
  • func (s *NonBlockingGRPCServer) Wait()
• type Service

Types

type NonBlockingGRPCServer

type NonBlockingGRPCServer struct {
	// contains filtered or unexported fields
}

NonBlocking server

func NewNonBlockingGRPCServer

func NewNonBlockingGRPCServer() *NonBlockingGRPCServer

func (*NonBlockingGRPCServer) ForceStop

func (s *NonBlockingGRPCServer) ForceStop()

func (*NonBlockingGRPCServer) Start

func (s *NonBlockingGRPCServer) Start(ctx context.Context, endpoint, errorPrefix string, tlsConfig *tls.Config, csiMetricsManager metrics.CSIMetricsManager, services ...Service) error

func (*NonBlockingGRPCServer) Stop

func (s *NonBlockingGRPCServer) Stop()

func (*NonBlockingGRPCServer) Wait

func (s *NonBlockingGRPCServer) Wait()

type Service

type Service interface {
	// RegisterService will be called by NonBlockingGRPCServer whenever
	// its about to start a grpc server on an endpoint.
	RegisterService(s *grpc.Server)
}