pmemcsidriver

Documentation

Index

• type NonBlockingGRPCServer
  • func NewNonBlockingGRPCServer() *NonBlockingGRPCServer
  • func (s *NonBlockingGRPCServer) ForceStop()
  • func (s *NonBlockingGRPCServer) Start(endpoint string, tlsConfig *tls.Config, services ...PmemService) error
  • func (s *NonBlockingGRPCServer) Stop()
  • func (s *NonBlockingGRPCServer) Wait()
• type PmemService

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(endpoint string, tlsConfig *tls.Config, services ...PmemService) error

func (*NonBlockingGRPCServer) Stop

func (s *NonBlockingGRPCServer) Stop()

func (*NonBlockingGRPCServer) Wait

func (s *NonBlockingGRPCServer) Wait()

type PmemService

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