pulsaradmin

type BrokerStatsTopicResult map[string]Namespace

type Client struct {
	Key string

	*http.Client
	// contains filtered or unexported fields
}

type Error struct {
	ErrorCode   int    `json:"error_code"`
	ErrorString string `json:"error"`
}

type ErrorResult struct {
	Error string `json:"error"`
}

type Namespace map[string]NamespaceBundle

type NamespaceBundle map[string]TopicType

type TopicStats struct {
	AverageMsgSize         float64 `json:"averageMsgSize"`
	MsgRateIn              float64 `json:"msgRateIn"`
	MsgRateOut             float64 `json:"msgRateOut"`
	MsgThroughputIn        float64 `json:"msgThroughputIn"`
	MsgThroughputOut       float64 `json:"msgThroughputOut"`
	PendingAddEntriesCount int64   `json:"pendingAddEntriesCount"`
	ProducerCount          int64   `json:"producerCount"`
	Publishers             []struct {
		Address        string  `json:"address"`
		AverageMsgSize float64 `json:"averageMsgSize"`
		ClientVersion  string  `json:"clientVersion"`
		ConnectedSince string  `json:"connectedSince"`
		Metadata       struct {
		} `json:"metadata"`
		MsgRateIn       float64 `json:"msgRateIn"`
		MsgThroughputIn float64 `json:"msgThroughputIn"`
		ProducerId      int64   `json:"producerId"`
		ProducerName    string  `json:"producerName"`
	} `json:"publishers"`
	Replication struct {
	} `json:"replication"`
	StorageSize   int64 `json:"storageSize"`
	Subscriptions struct {
		Subscription struct {
			BlockedSubscriptionOnUnackedMsgs bool `json:"blockedSubscriptionOnUnackedMsgs"`
			Consumers                        []struct {
				Address                      string `json:"address"`
				AvailablePermits             int64  `json:"availablePermits"`
				BlockedConsumerOnUnackedMsgs bool   `json:"blockedConsumerOnUnackedMsgs"`
				ClientVersion                string `json:"clientVersion"`
				ConnectedSince               string `json:"connectedSince"`
				ConsumerName                 string `json:"consumerName"`
				Metadata                     struct {
				} `json:"metadata"`
				MsgRateOut       float64 `json:"msgRateOut"`
				MsgRateRedeliver float64 `json:"msgRateRedeliver"`
				MsgThroughputOut float64 `json:"msgThroughputOut"`
				UnackedMessages  int64   `json:"unackedMessages"`
			} `json:"consumers"`
			MsgBacklog                               int64   `json:"msgBacklog"`
			MsgRateExpired                           float64 `json:"msgRateExpired"`
			MsgRateOut                               float64 `json:"msgRateOut"`
			MsgRateRedeliver                         float64 `json:"msgRateRedeliver"`
			MsgThroughputOut                         float64 `json:"msgThroughputOut"`
			NumberOfEntriesSinceFirstNotAckedMessage int64   `json:"numberOfEntriesSinceFirstNotAckedMessage"`
			TotalNonContiguousDeletedMessagesRange   int64   `json:"totalNonContiguousDeletedMessagesRange"`
			Type                                     string  `json:"type"`
			UnackedMessages                          int64   `json:"unackedMessages"`
		} `json:"subscription"`
	} `json:"subscriptions"`
}

type TopicType map[string]TopicStats