tcp

package

v1.0.14 Latest Latest Go to latest Published: Feb 5, 2026 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewBalancer(nodes []*Node) *Balancer

type Mode int

const (
	Follower Mode = iota
	Leader
)

type Node struct {
	Address string
	Alive   atomic.Bool
	Conns   atomic.Int64
}

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

func New(port int) *Server

func (s *Server) AddNode(address string)

* * AddNode * @param address string *

func (s *Server) Listen() error

* * Listen * @return error *

func (s *Server) SetMode(m Mode)

* * SetMode * @param m Mode *