cltclient

Documentation

Overview

Package cltclient provide fetch and merge data from collector

Index

• type Client
  • func New(nodes []string, httpclient *http.Client) (*Client, error)
  • func (c *Client) Status(ctx context.Context) ([]*CltStatus, error)
• type ClientStatus
• type ClientStatusResp
• type CltStatus

Types

type Client

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

Client collector client

func New

func New(nodes []string, httpclient *http.Client) (*Client, error)

New collector client

func (*Client) Status

func (c *Client) Status(ctx context.Context) ([]*CltStatus, error)

Status return all collector status

type ClientStatus

type ClientStatus struct {
	Addr     string `json:"addr"`
	UpTime   int64  `json:"up_time"`
	ErrCount int64  `json:"err_count"`
	Rate     int64  `json:"rate"`
}

ClientStatus client status

type ClientStatusResp

type ClientStatusResp struct {
	QueueLen int             `json:"queue_len"`
	Clients  []*ClientStatus `json:"clients"`
}

ClientStatusResp response clientstatus request just for debug

type CltStatus

type CltStatus struct {
	Node     string          `json:"node"`
	QueueLen int             `json:"queue_len"`
	Clients  []*ClientStatus `json:"clients"`
}

CltStatus collector status