controlplane

package

v1.1.104 Latest Latest Go to latest Published: Aug 5, 2025 License: MIT Imports: 15 Imported by: 0

Details

This section is empty.

This section is empty.

func GetNodeID(name string, maxNodes int, serverHost string, serverPort int) (int, error)

* * GetNodeID * @param name string, maxNodes int, serverHost string, serverPort int * @return int, error *

func HTTPClient(w http.ResponseWriter, r *http.Request)

* * HTTPClient * @param w http.ResponseWriter * @param r *http.Request *

func HTTPPing(w http.ResponseWriter, r *http.Request)

* * HTTPReset * @param w http.ResponseWriter * @param r *http.Request *

func HTTPReset(w http.ResponseWriter, r *http.Request)

* * HTTPReset * @param w http.ResponseWriter * @param r *http.Request *

func LoadClient() error

* * LoadClient * @return error *

func LoadServer() error

* * LoadServer * @return error *

func Reset(name string) error

type Client int

func (s *Client) Ping(args et.Json, reply *string) error

* * Ping * @param args et.Json, reply *string * @return error *

type ControlPlane struct {
	Nodes    map[int]*NodeInfo
	MaxNodes int
	// contains filtered or unexported fields
}

func NewStorage() *ControlPlane

type NodeInfo struct {
	ID         int
	InstanceID string
	LastSeen   time.Time
	Service    string
	Host       string
	Port       int
}

Control Plane Structs

func NewNodeID() *NodeInfo

type Server int

func (s *Server) GetNodeID(args et.Json, reply *int) error

* * GetNodeID * @param args et.Json, reply int * @return error *