systree

type BytesMetric interface {
	Sent(bytes uint64)
	Received(bytes uint64)
}

type ClientConnectStatus struct {
	Address      string                 `json:"ipaddress"`
	Username     string                 `json:"username"`
	Timestamp    int64                  `json:"ts"`
	CleanSession bool                   `json:"session"`
	Protocol     packet.ProtocolVersion `json:"protocol"`
	ConnAckCode  packet.ReasonCode      `json:"connack"`
}

type Clients interface {
	Connected(id string, status *ClientConnectStatus)
	Disconnected(id string, reason packet.ReasonCode, retain bool)
}

type DynamicValue interface {
	Topic() string
	// Retained used by topics provider to get retained message when there is new subscription to given topic
	Retained() *packet.Publish
	// Publish used by systree update routine to publish new value when on periodic basis
	Publish() *packet.Publish
}

type MessagesStat interface {
	Sent(t packet.QosType)
	Received(t packet.QosType)
}

type Metric interface {
	Bytes() BytesMetric
	Packets() PacketsMetric
	Messages() MessagesStat
}

type PacketsMetric interface {
	Sent(t packet.Type)
	Received(t packet.Type)
}

type Provider interface {
	SetCallbacks(types.TopicMessenger)
	Metric() Metric
	Topics() TopicsStat
	Subscriptions() SubscriptionsStat
	Clients() Clients
	Sessions() Sessions
}

type SessionCreatedStatus struct {
	ExpiryInterval string `json:"expiryInterval,omitempty"`
	WillDelay      string `json:"willDelay,omitempty"`
	Timestamp      string `json:"timestamp"`
	Clean          bool   `json:"clean"`
}

type SessionDeletedStatus struct {
	Timestamp string `json:"timestamp"`
	Reason    string `json:"reason"`
}

type Sessions interface {
	Created(id string, status *SessionCreatedStatus)
	Removed(id string, status *SessionDeletedStatus)
}

type SubscriptionsStat interface {
	Subscribed()
	UnSubscribed()
}

type TopicsStat interface {
	Added()
	Removed()
}