streaming

type AgentConnectedEvent struct {
	Agent ConnectedAgent `json:"agent"`
	StreamingEvent
}

type AgentDisconnectedEvent struct {
	Agent ConnectedAgent `json:"agent"`
	StreamingEvent
}

type AgentHub struct {
	Agents map[string]*ConnectedAgent

	// Register requests from the agents.
	Register chan *ConnectedAgent

	// Unregister requests from agents.
	Unregister chan *ConnectedAgent
	// contains filtered or unexported fields
}

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

type ClientHub struct {
	// Registered clients.
	Clients map[*Client]bool

	// Updates to be broadcasted to the clients.
	Broadcast chan []byte

	// Register requests from the clients.
	Register chan *Client

	// Unregister requests from clients.
	Unregister chan *Client
}

type ConnectedAgent struct {
	Name         string       `json:"name"`
	Namespace    string       `json:"namespace"`
	EventChannel chan []byte  `json:"-"`
	Stacks       []*api.Stack `json:"-"`
}

type EnvsUpdatedEvent struct {
	Envs []*api.Env `json:"envs"`
	StreamingEvent
}

type StaleRepoDataEvent struct {
	Repo string `json:"repo"`
	StreamingEvent
}

type StreamingEvent struct {
	Event string `json:"event"`
}