server

package
v1.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 5, 2024 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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)
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.