monitoring

Documentation

Index

• type AccountDetail
• type ConsumerInfo
• type JSInfo
• type Monitor
  • func NewMonitor(monitorConfig config.Monitor, client *http.Client, baseURL string) *Monitor
  • func (m *Monitor) StartMonitor()
• type StreamDetail

Types

type AccountDetail

type AccountDetail struct {
	Name    string         `json:"name"`
	Id      string         `json:"id"`
	Streams []StreamDetail `json:"stream_detail,omitempty"`
}

type ConsumerInfo

type ConsumerInfo struct {
	Stream        string `json:"stream_name"`
	Name          string `json:"name"`
	NumAckPending uint64 `json:"num_ack_pending"`
	NumPending    uint64 `json:"num_pending"`
}

type JSInfo

type JSInfo struct {
	ID string `json:"server_id"`

	// aggregate raft info
	AccountDetails []*AccountDetail `json:"account_details,omitempty"`
}

JSInfo has detailed information on JetStream.

type Monitor

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

func NewMonitor

func NewMonitor(monitorConfig config.Monitor, client *http.Client, baseURL string) *Monitor

func (*Monitor) StartMonitor

func (m *Monitor) StartMonitor()

type StreamDetail

type StreamDetail struct {
	Name      string          `json:"name"`
	Consumers []*ConsumerInfo `json:"consumer_detail,omitempty"`
}