listener

Documentation

Index

• func SetListenerServiceFactory(protocol model.ProtocolType, ...)
• type BaseListenerService
• type ListenerGracefulShutdownConfig
  • func (lgsc *ListenerGracefulShutdownConfig) AddActiveCount(num int32)
• type ListenerService
  • func CreateListenerService(lc *model.Listener, bs *model.Bootstrap) (ListenerService, error)

Functions

func SetListenerServiceFactory

func SetListenerServiceFactory(protocol model.ProtocolType, newRegFunc func(lc *model.Listener, bs *model.Bootstrap) (ListenerService, error))

SetListenerServiceFactory will store the listenerService factory by name

Types

type BaseListenerService

type BaseListenerService struct {
	Config      *model.Listener
	FilterChain *filterchain.NetworkFilterChain
}

type ListenerGracefulShutdownConfig

type ListenerGracefulShutdownConfig struct {
	ActiveCount   int32
	RejectRequest bool
}

func (*ListenerGracefulShutdownConfig) AddActiveCount

func (lgsc *ListenerGracefulShutdownConfig) AddActiveCount(num int32)

type ListenerService

type ListenerService interface {
	// Start the listener service
	Start() error
	// Close the listener service forcefully
	Close() error
	// ShutDown gracefully shuts down the listener.
	ShutDown(interface{}) error
	// Refresh config
	Refresh(model.Listener) error
}

func CreateListenerService

func CreateListenerService(lc *model.Listener, bs *model.Bootstrap) (ListenerService, error)

CreateListenerService create listener service