kinesis

Documentation

Index

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

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 local server

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

Reload the configuration

func (*Server) Start

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

Start accepts incoming connections on the Listener