cluster

Documentation

Index

• func Handle(srv *Server, netCon net.Conn)
• type Server
  • func New(c lib.RelayerConfig, done chan bool) (*Server, error)
  • func (srv *Server) Exit()
  • func (srv *Server) Reload(c *lib.RelayerConfig) error
  • func (srv *Server) Start() (e error)

Functions

func Handle

func Handle(srv *Server, netCon net.Conn)

Types

type Server

type Server struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Server is the thread that listen for clients' connections

func New

func New(c lib.RelayerConfig, done chan bool) (*Server, error)

New creates a new Redis cluster or pool client

func (*Server) Exit

func (srv *Server) Exit()

Exit closes the listener and send done to main

func (*Server) Reload

func (srv *Server) Reload(c *lib.RelayerConfig) error

Reload the configuration

func (*Server) Start

func (srv *Server) Start() (e error)

Start listening in the specified local port