server

Documentation

Index

• Variables
• func GetInheritListeners() ([]net.Listener, net.Conn, error)
• func InitDefaultLogger(config *Config)
• func ListListenersFile() []*os.File
• func Milliseconds(d time.Duration) int64
• 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)
• 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)

InitDefaultLogger init default logger

func ListListenersFile

func ListListenersFile() []*os.File

ListListenersFile returns all server listener's fds

func Milliseconds

func Milliseconds(d time.Duration) int64

compatible with go 1.12.x

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

Stop the server

func StopAccept

func StopAccept()

StopAccept stops all listeners in servers

func StopConnection

func StopConnection()

StopConnection stops all connections in servers

func StopReconfigureHandler

func StopReconfigureHandler()

func WaitConnectionsDone

func WaitConnectionsDone(duration time.Duration)

WaitConnectionsDone Wait for all connections to be finished

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

NewConfig get Config by ServerConfig

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) 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) (types.ListenerEventListener, error)

	Start()

	Restart()

	Close()

	Handler() types.ConnectionHandler
}

func GetServer

func GetServer() Server

GetServer currently, only one server supported

func NewServer

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

NewServer get a new server