ftl_orchestrator

type Callbacks struct {
	OnIntro               func(message IntroMessage)
	OnOutro               func(message OutroMessage)
	OnNodeState           func(message NodeStateMessage)
	OnChannelSubscription func(message ChannelSubscriptionMessage)
	OnStreamPublishing    func(message StreamPublishingMessage)
	OnStreamRelaying      func(message StreamRelayingMessage)
}

type ChannelSubscriptionMessage struct {
	Context   uint8
	ChannelID types.ChannelID
	StreamKey string
}

type Client struct {
	ClientHostname string
	// contains filtered or unexported fields
}

type Config struct {
	// Address of the remote orchestrator ip:port format
	Address string
	// RegionCode we are representing
	RegionCode string
	// Hostname for ourselves, so edges know how to reach us
	Hostname string
	// Handler for callbacks
	Callbacks Callbacks
}

type IntroMessage struct {
	VersionMajor    uint8
	VersionMinor    uint8
	VersionRevision uint8
	RelayLayer      uint8
	RegionCode      string
	Hostname        string
}

type MessageHeader struct {
	// Request Serializes from Request / Response
	Request bool
	// Success Serializes from Success / Failure
	Success       bool
	Type          uint8
	ID            uint8
	PayloadLength uint16
}

type NodeStateMessage struct {
	CurrentLoad uint32
	MaximumLoad uint32
}

type OutroMessage struct {
	Reason string
}

type StreamPublishingMessage struct {
	Context   uint8
	ChannelID types.ChannelID
	StreamID  types.StreamID
}

type StreamRelayingMessage struct {
	Context        uint8
	ChannelID      types.ChannelID
	StreamID       types.StreamID
	TargetHostname string
	StreamKey      []byte
}