server

Documentation

Index

• func Run(servers ...Server) error
• type HealthServer
  • func NewHealthServer(addr string, l *logrus.Entry) (*HealthServer, error)
  • func (s *HealthServer) Run() error
  • func (s *HealthServer) Stop(sig os.Signal)
• type PluginServer
  • func NewControllerPluginServer(addr string, controllerServer csi.ControllerServer, ...) (*PluginServer, error)
  • func NewNodePluginServer(addr string, nodeServer csi.NodeServer, identity csi.IdentityServer, ...) (*PluginServer, error)
  • func NewPluginServer(addr string, controllerServer csi.ControllerServer, nodeServer csi.NodeServer, ...) (*PluginServer, error)
  • func (s *PluginServer) GetServiceInfo() map[string]grpc.ServiceInfo
  • func (s *PluginServer) Run() error
  • func (s *PluginServer) Stop(sig os.Signal)
• type Server

Functions

func Run

func Run(servers ...Server) error

Types

type HealthServer

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

func NewHealthServer

func NewHealthServer(addr string, l *logrus.Entry) (*HealthServer, error)

func (*HealthServer) Run

func (s *HealthServer) Run() error

func (*HealthServer) Stop

func (s *HealthServer) Stop(sig os.Signal)

type PluginServer

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

func NewControllerPluginServer

func NewControllerPluginServer(addr string, controllerServer csi.ControllerServer, identity csi.IdentityServer, l *logrus.Entry) (*PluginServer, error)

func NewNodePluginServer

func NewNodePluginServer(addr string, nodeServer csi.NodeServer, identity csi.IdentityServer, l *logrus.Entry) (*PluginServer, error)

func NewPluginServer

func NewPluginServer(addr string, controllerServer csi.ControllerServer, nodeServer csi.NodeServer, identity csi.IdentityServer, l *logrus.Entry) (*PluginServer, error)

func (*PluginServer) GetServiceInfo

func (s *PluginServer) GetServiceInfo() map[string]grpc.ServiceInfo

func (*PluginServer) Run

func (s *PluginServer) Run() error

func (*PluginServer) Stop

func (s *PluginServer) Stop(sig os.Signal)

Stop stops the plugin.

type Server

type Server interface {
	Run() error
	Stop(os.Signal)
}