Documentation ¶
Index ¶
- func CloseGraphiteConnection(graphite *graphite.Graphite) error
- func GetGraphiteConnection(graphiteHost string, graphitePort int) (*graphite.Graphite, error)
- func SendMetrics(graphite *graphite.Graphite, metrics []graphite.Metric) error
- type BurrowClient
- func (bc *BurrowClient) ClusterDetails(cluster string) (*ClusterDetailsResp, error)
- func (bc *BurrowClient) ClusterTopicDetails(cluster, topic string) (*ClusterTopicDetailsResp, error)
- func (bc *BurrowClient) ConsumerGroupLag(cluster, consumerGroup string) (*ConsumerGroupLagResp, error)
- func (bc *BurrowClient) ConsumerGroupStatus(cluster, consumerGroup string) (*ConsumerGroupStatusResp, error)
- func (bc *BurrowClient) ConsumerGroupTopicDetails(cluster, consumerGroup, topic string) (*ConsumerGroupTopicDetailsResp, error)
- func (bc *BurrowClient) HealthCheck() (bool, error)
- func (bc *BurrowClient) ListClusterTopics(cluster string) (*TopicsResp, error)
- func (bc *BurrowClient) ListClusters() (*ClustersResp, error)
- func (bc *BurrowClient) ListConsumerTopics(cluster, consumerGroup string) (*TopicsResp, error)
- func (bc *BurrowClient) ListConsumers(cluster string) (*ConsumerGroupsResp, error)
- type BurrowExporter
- type BurrowResp
- type ClusterDetails
- type ClusterDetailsResp
- type ClusterTopicDetailsResp
- type ClustersResp
- type ConsumerGroupLag
- type ConsumerGroupLagResp
- type ConsumerGroupStatus
- type ConsumerGroupStatusResp
- type ConsumerGroupTopicDetailsResp
- type ConsumerGroupsResp
- type Offset
- type Partition
- type TopicsResp
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CloseGraphiteConnection ¶
func CloseGraphiteConnection(graphite *graphite.Graphite) error
func GetGraphiteConnection ¶
func SendMetrics ¶
func SendMetrics(graphite *graphite.Graphite, metrics []graphite.Metric) error
Types ¶
type BurrowClient ¶
type BurrowClient struct {
// contains filtered or unexported fields
}
func MakeBurrowClient ¶
func MakeBurrowClient(baseUrl string) *BurrowClient
func (*BurrowClient) ClusterDetails ¶
func (bc *BurrowClient) ClusterDetails(cluster string) (*ClusterDetailsResp, error)
func (*BurrowClient) ClusterTopicDetails ¶
func (bc *BurrowClient) ClusterTopicDetails(cluster, topic string) (*ClusterTopicDetailsResp, error)
func (*BurrowClient) ConsumerGroupLag ¶
func (bc *BurrowClient) ConsumerGroupLag(cluster, consumerGroup string) (*ConsumerGroupLagResp, error)
func (*BurrowClient) ConsumerGroupStatus ¶
func (bc *BurrowClient) ConsumerGroupStatus(cluster, consumerGroup string) (*ConsumerGroupStatusResp, error)
func (*BurrowClient) ConsumerGroupTopicDetails ¶
func (bc *BurrowClient) ConsumerGroupTopicDetails(cluster, consumerGroup, topic string) (*ConsumerGroupTopicDetailsResp, error)
func (*BurrowClient) HealthCheck ¶
func (bc *BurrowClient) HealthCheck() (bool, error)
func (*BurrowClient) ListClusterTopics ¶
func (bc *BurrowClient) ListClusterTopics(cluster string) (*TopicsResp, error)
func (*BurrowClient) ListClusters ¶
func (bc *BurrowClient) ListClusters() (*ClustersResp, error)
func (*BurrowClient) ListConsumerTopics ¶
func (bc *BurrowClient) ListConsumerTopics(cluster, consumerGroup string) (*TopicsResp, error)
func (*BurrowClient) ListConsumers ¶
func (bc *BurrowClient) ListConsumers(cluster string) (*ConsumerGroupsResp, error)
type BurrowExporter ¶
type BurrowExporter struct {
// contains filtered or unexported fields
}
func MakeBurrowExporter ¶
func MakeBurrowExporter(burrowUrl string, graphiteHost string, graphitePort int, interval int) *BurrowExporter
func (*BurrowExporter) Close ¶
func (be *BurrowExporter) Close()
func (*BurrowExporter) Start ¶
func (be *BurrowExporter) Start(ctx context.Context)
type BurrowResp ¶
type ClusterDetails ¶
type ClusterDetailsResp ¶
type ClusterDetailsResp struct { BurrowResp Cluster ClusterDetails `json:"cluster"` }
type ClusterTopicDetailsResp ¶
type ClusterTopicDetailsResp struct { BurrowResp Offsets []int64 `json:"offsets"` }
type ClustersResp ¶
type ClustersResp struct { BurrowResp Clusters []string `json:"clusters"` }
type ConsumerGroupLag ¶
type ConsumerGroupLag struct { Cluster string `json:"cluster"` Group string `json:"group"` Status string `json:"status"` Complete float32 `json:"complete"` MaxLag Partition `json:"maxlag"` Partitions []Partition `json:"partitions"` PartitionCount int32 `json:"partition_count"` TotalLag int64 `json:"totallag"` }
type ConsumerGroupLagResp ¶
type ConsumerGroupLagResp struct { BurrowResp Status ConsumerGroupLag `json:"status"` }
type ConsumerGroupStatus ¶
type ConsumerGroupStatus struct { Cluster string `json:"cluster"` Group string `json:"group"` Status string `json:"status"` Complete float32 `json:"complete"` MaxLag Partition `json:"maxlag"` Partitions []Partition `json:"partitions"` PartitionCount int32 `json:"partition_count"` TotalLag int64 `json:"totallag"` }
type ConsumerGroupStatusResp ¶
type ConsumerGroupStatusResp struct { BurrowResp Status ConsumerGroupStatus `json:"status"` }
type ConsumerGroupTopicDetailsResp ¶
type ConsumerGroupTopicDetailsResp struct { BurrowResp Offsets []int64 `json:"offsets"` }
type ConsumerGroupsResp ¶
type ConsumerGroupsResp struct { BurrowResp ConsumerGroups []string `json:"consumers"` }
type TopicsResp ¶
type TopicsResp struct { BurrowResp Topics []string `json:"topics"` }
Click to show internal directories.
Click to hide internal directories.