tcp

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

type Client struct {
	CreatedAt  time.Time `json:"created_at"`
	ID         string    `json:"id"`
	Addr       string    `json:"addr"`
	LocalAddr  string    `json:"local_addr"`
	RemoteAddr string    `json:"remote_addr"`
	Status     Status    `json:"status"`
	Ctx        et.Json   `json:"-"`
	// contains filtered or unexported fields
}

type Config struct {
	Nodes []string `json:"nodes"`
	// contains filtered or unexported fields
}

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

type HandlerFunc func(request *Message) *Response

type HeartbeatArgs struct {
	Term     int
	LeaderID string
}

type HeartbeatReply struct {
	Term int
	Ok   bool
}

type Message struct {
	ID         string `json:"id"`
	Type       int    `json:"type"`
	Method     string `json:"method"`
	Payload    []byte `json:"payload"`
	Error      string `json:"error"`
	Args       []any  `json:"args"`
	IsResponse bool   `json:"is_response"`
}

type Mode int

type Msg struct {
	To  *Client  `json:"to"`
	Msg *Message `json:"msg"`
}

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

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

type RequestVoteArgs struct {
	Term        int
	CandidateID string
}

type RequestVoteReply struct {
	Term        int
	VoteGranted bool
}

type Response struct {
	Response []any `json:"response"`
	Error    error `json:"error"`
}

type ResponseBool struct {
	Ok    bool
	Error error
}

type Service interface {
	Execute(name string, request *Message) *Response
}

type Status string

type Tcp struct {
	Ping HandlerFunc
	// contains filtered or unexported fields
}