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
- type 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
Constants ¶
This section is empty.
Variables ¶
View Source
var GracefulTimeout = time.Second * 30 //default 30s
Functions ¶
func InitDefaultLogger ¶
func InitDefaultLogger(config *Config)
func ListListenersFile ¶
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 StopAccept ¶
func StopAccept()
func StopConnection ¶
func StopConnection()
func StopReconfigureHandler ¶
func StopReconfigureHandler()
func WaitConnectionsDone ¶
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 NewServer ¶
func NewServer(config *Config, cmFilter types.ClusterManagerFilter, clMng types.ClusterManager) Server
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.