beekeeper

type Config struct {
	// Name of the node. It defaults to the system's hostname.
	Name string `mapstructure:"name,omitempty"`

	// Debug toggles between verbosity for debugging.
	Debug bool `mapstructure:"debug,omitempty"`

	// Token is a passphrase used to restrict usage of the node. Must match on the receiving node.
	Token string `mapstructure:"token,omitempty"`

	// InboundPort is the port to be used for receiving connections. Defaults to 2020.
	InboundPort int `mapstructure:"inbound_port,omitempty"`

	// OutboundPort is the port assumed to be used by a remote node. It's only used to establish a connection, and
	// afterwards a port is negotiated with the remote node. Defaults to 2020.
	OutboundPort int `mapstructure:"outbound_port,omitempty"`

	// TLSCertificate is used for TLS connections between nodes. If none is given a certificate is created on the first
	// run and reused as needed.
	TLSCertificate []byte

	// TLSPrivateKey is used for TLS connections between nodes. If none is given a key is created on the first
	// run and reused as needed.
	TLSPrivateKey []byte

	// AllowExternal sets whether non-local connections should be accepted. It's heavily encouraged that a whitelist
	// and token is set with this featured turn on. Defaults to false.
	AllowExternal bool `mapstructure:"allow_external,omitempty"`

	// Whitelist contains a list of allowed hosts. If none is provided it's understood that the whitelist is disabled.
	// A wildcard sign (*) can be used.
	Whitelist []string `mapstructure:"whitelist,omitempty"`

	// MaxMessageSize is the size limit in bytes for incoming messages. It defaults to 1.024 MB
	MaxMessageSize uint64 `mapstructure:"max_message_size,omitempty"`

	// DisableCleanup turns off the post-build cleanup
	DisableCleanup bool `mapstructure:"disable_cleanup,omitempty"`

	// DisableConnectionWatchdog disables the connection watchdog, and stops disconnection notifications.
	DisableConnectionWatchdog bool `mapstructure:"disable_connection_watchdog,omitempty"`
}

type Conn struct {
	*tls.Conn
}

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

type Message struct {
	// SentAt timestamp for the Message.
	SentAt time.Time

	// Name the sender's name.
	Name string

	// Operation operation the remote node wishes to execute. It may be nilled with OperationNone.
	Operation Operation

	// Data the body of the message. Contains the payload needed for the execution if the Operation.
	Data []byte

	// Token is used as a passphrase to operate in a multi-node environment.
	Token string

	// Addr is the address of the sender
	Addr *net.TCPAddr

	// RespondOnPort is the port that the sender wishes to be used for the response.
	RespondOnPort int

	// Status represents the current action the node is doing.
	Status Status

	// NodeInfo contains metadata about the sender, like OS and current usage.
	NodeInfo NodeInfo
}

type Monitor struct {
	App         *tview.Application
	Pages       *tview.Pages
	CurrentPage int
	// contains filtered or unexported fields
}

type Node struct {
	Conn   *Conn
	Addr   *net.TCPAddr
	Name   string
	Status Status
	Info   NodeInfo
}

type NodeInfo struct {
	// CPUTemp is the temperature as measured in the CPU dice when possible. Certain OS can return 0.
	CPUTemp float32

	// Usage is the percentage of usage of the host system in a range from 1 (max) to 0 (min).
	Usage float32

	// OS is the GOOS of the host system.
	OS string
}

type Nodes []Node

type Operation int

type Request struct {
	Msg  Message
	Conn Conn
}

type Result struct {
	UUID  string
	Task  Task
	Error string
}

type Server struct {
	// Config hold the configuration data of the server.
	Config Config

	// Status represents the action the server is currently doing.
	Status Status
	// contains filtered or unexported fields
}

type Status int

type Task struct {
	UUID      string
	Arguments map[string]interface{}
	Returns   map[string]interface{}
	Error     string
}