agent

type AgentAddress struct {
	Name                  string
	AddressSpace          string
	AddressSpaceNamespace string
	Address               string
	Depth                 int
	MessagesIn            int `json:"messages_in"`
	MessagesOut           int `json:"messages_out"`
	Senders               int
	Receivers             int
	Shards                []AgentAddressShards
}

type AgentAddressLink struct {
	Address string
	Name    interface{}
	Uuid    string
	/* Populated for Standard */
	Accepted    int
	Released    int
	Rejected    int
	Modified    int
	Unsettled   int
	Undelivered int
	Presettled  int
	Links       []AgentLink /* the individual links, >1 for the fanout cases */
	/* Populated for Standard and Brokered */
	Deliveries int
}

type AgentAddressShards struct {
	Name         string
	Consumers    int
	Enqueued     int
	Acknowledged int
	Killed       int
}

type AgentConnection struct {
	Id                    string
	Uuid                  string
	Host                  string
	Container             string
	AddressSpace          string
	AddressSpaceNamespace string
	AddressSpaceType      string
	Properties            map[string]string
	Encrypted             bool
	SaslMechanism         string `json:"sasl_mechanism"`
	User                  string
	CreationTimestamp     int64 `json:"creationTimestamp"`
	MessagesIn            int   `json:"messages_in"`
	MessagesOut           int   `json:"messages_out"`
	Outcomes              map[string]AgentOutcome
	Senders               []AgentAddressLink
	Receivers             []AgentAddressLink
	LastUpdated           int64
}

type AgentEvent struct {
	InfraUuid             string
	AddressSpace          string
	AddressSpaceNamespace string
	Type                  AgentEventType
	Object                interface{}
}

type AgentEventType string

type AgentLink struct {
	Identity         string
	Name             string
	OperStatus       string
	AdminStatus      string
	DeliveryCount    int
	Capacity         int
	Backlog          int
	RouterName       string
	ClientName       string
	AcceptedCount    int
	ReleasedCount    int
	ModifiedCount    int
	UnsettledCount   int
	PresettledCount  int
	UndeliveredCount int
	LastUpdated      int64
}

type AgentOutcome struct {
	Accepted    int
	Released    int
	Rejected    int
	Modified    int
	Unsettled   int
	Presettled  int
	Undelivered int
	Links       []AgentLink
}

type CommandDelegate interface {
	PurgeAddress(address string) error
	CloseConnection(address v1.ObjectMeta) error
	Shutdown()
}

type Delegate interface {
	Collect(handler EventHandler) error
	CommandDelegate(bearerToken string, impersonateUser string) (CommandDelegate, error)
	Shutdown()
}

type DelegateCreator = func(bearerToken, host string, port int32) Delegate

type EventHandler = func(event AgentEvent) error