server

Documentation

Index

• Variables
• func GetInheritListeners() ([]net.Listener, net.Conn, error)
• func InitDefaultLogger(config *Config)
• func ListListenersFile() []*os.File
• func NewHandler(clusterManagerFilter types.ClusterManagerFilter, clMng types.ClusterManager) types.ConnectionHandler
• func ReconfigureHandler()
• func ResetAdapter()
• func Stop()
• func StopAccept()
• func StopConnection()
• func StopReconfigureHandler()
• func WaitConnectionsDone(duration time.Duration) error
• type Config
  • func NewConfig(c *v2.ServerConfig) *Config
• type ListenerAdapter
  • func GetListenerAdapterInstance() *ListenerAdapter
  • func (adapter *ListenerAdapter) AddOrUpdateListener(serverName string, lc *v2.Listener, ...) error
  • func (adapter *ListenerAdapter) DeleteListener(serverName string, listenerName string) error
  • func (adapter *ListenerAdapter) FindListenerByName(serverName string, listenerName string) types.Listener
  • func (adapter *ListenerAdapter) UpdateListenerTLS(serverName string, listenerName string, inspector bool, ...) error
• type Server
  • func GetServer() Server
  • func NewServer(config *Config, cmFilter types.ClusterManagerFilter, ...) Server

Variables

var GracefulTimeout = time.Second * 30 //default 30s

Functions

func GetInheritListeners

func GetInheritListeners() ([]net.Listener, net.Conn, error)

func InitDefaultLogger

func InitDefaultLogger(config *Config)

func ListListenersFile

func ListListenersFile() []*os.File

func NewHandler

func NewHandler(clusterManagerFilter types.ClusterManagerFilter, clMng types.ClusterManager) types.ConnectionHandler

NewHandler create types.ConnectionHandler's implement connHandler with cluster manager and logger

func ReconfigureHandler

func ReconfigureHandler()

func ResetAdapter

func ResetAdapter()

ResetAdapter only used in test/debug mode

func Stop

func Stop()

func StopAccept

func StopAccept()

func StopConnection

func StopConnection()

func StopReconfigureHandler

func StopReconfigureHandler()

func WaitConnectionsDone

func WaitConnectionsDone(duration time.Duration) error

Types

type Config

type Config struct {
	ServerName      string
	LogPath         string
	LogLevel        log.Level
	LogRoller       string
	GracefulTimeout time.Duration
	Processor       int
	UseNetpollMode  bool
}

func NewConfig

func NewConfig(c *v2.ServerConfig) *Config

type ListenerAdapter

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

func GetListenerAdapterInstance

func GetListenerAdapterInstance() *ListenerAdapter

func (*ListenerAdapter) AddOrUpdateListener

func (adapter *ListenerAdapter) AddOrUpdateListener(serverName string, lc *v2.Listener,
	networkFiltersFactories []types.NetworkFilterChainFactory, streamFiltersFactories []types.StreamFilterChainFactory) error

AddOrUpdateListener used to: Add and start listener when listener doesn't exist Update listener when listener already exist

func (*ListenerAdapter) DeleteListener

func (adapter *ListenerAdapter) DeleteListener(serverName string, listenerName string) error

func (*ListenerAdapter) FindListenerByName

func (adapter *ListenerAdapter) FindListenerByName(serverName string, listenerName string) types.Listener

FindListenerByName

func (*ListenerAdapter) UpdateListenerTLS

func (adapter *ListenerAdapter) UpdateListenerTLS(serverName string, listenerName string, inspector bool, tlsConfigs []v2.TLSConfig) error

type Server

type Server interface {
	AddListener(lc *v2.Listener, networkFiltersFactories []types.NetworkFilterChainFactory,
		streamFiltersFactories []types.StreamFilterChainFactory) (types.ListenerEventListener, error)

	Start()

	Restart()

	Close()

	Handler() types.ConnectionHandler
}

func GetServer

func GetServer() Server

currently, only one server supported

func NewServer

func NewServer(config *Config, cmFilter types.ClusterManagerFilter, clMng types.ClusterManager) Server