orchestrator

Documentation

Index

• Constants
• func DisconnectThread(orchestrator *Orchestrator, ctx context.Context, logger *slog.Logger, ...)
• func GetCliCommand() *cli.Command
• func OServerThread(orchestrator *Orchestrator, ctx context.Context, logger *slog.Logger, ...)
• type NodeConnection
• type NodeRegistration
• type Orchestrator
  • func (orchestrator *Orchestrator) Run() (err error)

Constants

const DisconnectStaleNodePeriod = 10 * time.Second

Functions

func DisconnectThread

func DisconnectThread(orchestrator *Orchestrator, ctx context.Context, logger *slog.Logger, done func())

func GetCliCommand

func GetCliCommand() *cli.Command

func OServerThread

func OServerThread(orchestrator *Orchestrator, ctx context.Context, logger *slog.Logger, done func())

Types

type NodeConnection

type NodeConnection struct {
	Name            string    `json:"name"`
	Address         string    `json:"address"`
	Port            int       `json:"port"`
	LastInteraction time.Time `json:"last_interaction"`
}

type NodeRegistration

type NodeRegistration struct {
	NodeName string `json:"name"`
	NodeAddr string `json:"addr"`
	NodePort int    `json:"port"`
}

type Orchestrator

type Orchestrator struct {
	Port     int
	Nodes    map[string]*NodeConnection
	LogFile  string
	CertPath string
}

func (*Orchestrator) Run

func (orchestrator *Orchestrator) Run() (err error)