stats

Documentation

Index

• func Initialize()
• func SubscriptionDetail(id string) ([]byte, error)
• func SubscriptionSummary() ([]byte, error)
• func Summary() ([]byte, error)
• func TopicDetail(id string) ([]byte, error)
• func TopicSummary() ([]byte, error)
• type SubscriptionAdapter
  • func GetSubscriptionAdapter() *SubscriptionAdapter
  • func (t *SubscriptionAdapter) AddMessage(subID string, num int)
  • func (t *SubscriptionAdapter) AddSubscription(subID string, num int)
  • func (t *SubscriptionAdapter) CurrentMessages(subID string, msgs []string)
• type TopicAdapter
  • func GetTopicAdapter() *TopicAdapter
  • func (t *TopicAdapter) AddMessage(topicID string, num int)
  • func (t *TopicAdapter) AddTopic(topicID string, num int)

Functions

func Initialize

func Initialize()

Initialize prepare collector and forwarder object

func SubscriptionDetail

func SubscriptionDetail(id string) ([]byte, error)

SubscriptionDetail returns detail of the subscription stats

func SubscriptionSummary

func SubscriptionSummary() ([]byte, error)

SubscriptionSummary returns summary of the subscription stats

func Summary

func Summary() ([]byte, error)

Summary returns summary of the all stats

func TopicDetail

func TopicDetail(id string) ([]byte, error)

TopicDetail returns detail of the topic stats

func TopicSummary

func TopicSummary() ([]byte, error)

TopicSummary returns summary of the topic stats

Types

type SubscriptionAdapter

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

SubscriptionAdapter is adapter of operation metrics for Subscription

func GetSubscriptionAdapter

func GetSubscriptionAdapter() *SubscriptionAdapter

GetSubscriptionAdapter return prepared SubscriptionAdapter

func (*SubscriptionAdapter) AddMessage

func (t *SubscriptionAdapter) AddMessage(subID string, num int)

AddMessage send metrics the added message

func (*SubscriptionAdapter) AddSubscription

func (t *SubscriptionAdapter) AddSubscription(subID string, num int)

AddSubscription send metrics the topic

func (*SubscriptionAdapter) CurrentMessages

func (t *SubscriptionAdapter) CurrentMessages(subID string, msgs []string)

CurrentMessages send metrics the added message

type TopicAdapter

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

TopicAdapter is adapter of operation metrics for Topic

func GetTopicAdapter

func GetTopicAdapter() *TopicAdapter

GetTopicAdapter return prepared TopicAdapter

func (*TopicAdapter) AddMessage

func (t *TopicAdapter) AddMessage(topicID string, num int)

AddMessage send metrics the added message

func (*TopicAdapter) AddTopic

func (t *TopicAdapter) AddTopic(topicID string, num int)

AddTopic send metrics the topic