cmd

Documentation

Index

• func Execute(ver string)
• type Client
• type Config
• type Control
• type Health
  • func (h *Health) String() string
• type Queue
• type Queues
  • func (q *Queues) String() string

Functions

func Execute

func Execute(ver string)

Types

type Client

type Client struct {
	ClientId         string `json:"client_id"`
	Active           bool   `json:"active"`
	LastSequenceSent int64  `json:"last_sequence_sent"`
	IsStalled        bool   `json:"is_stalled"`
	Pending          int64  `json:"pending"`
}

type Config

type Config struct {
	Connections    []*option.Options
	StatsAddress   string
	HealthAddress  string
	MetricsAddress string
	MonitorAddress string
}

type Control

type Control struct {
	Address string
}

type Health

type Health []struct {
	Host    string    `json:"host"`
	UtcTime time.Time `json:"utc_time"`
	Grpc    struct {
		Connections struct {
			Total                int `json:"total"`
			EventsSenders        int `json:"events_senders"`
			EventsStreamSenders  int `json:"events_stream_senders"`
			EventsReceivers      int `json:"events_receivers"`
			EventsStoreReceivers int `json:"events_store_receivers"`
			RequestsSenders      int `json:"requests_senders"`
			ResponsesSenders     int `json:"responses_senders"`
			CommandsReceivers    int `json:"commands_receivers"`
			QueriesReceivers     int `json:"queries_receivers"`
		} `json:"connections"`
		Traffic struct {
			SentEvents          int `json:"sent_events"`
			ReceivedEvents      int `json:"received_events"`
			SentRequests        int `json:"sent_requests"`
			SentError           int `json:"sent_error"`
			SentResponses       int `json:"sent_responses"`
			ReceivedRequests    int `json:"received_requests"`
			SentEventsVol       int `json:"sent_events_vol"`
			ReceivedEventsVol   int `json:"received_events_vol"`
			SentRequestsVol     int `json:"sent_requests_vol"`
			SentErrorsVol       int `json:"sent_errors_vol"`
			SentResponsesVol    int `json:"sent_responses_vol"`
			ReceivedRequestsVol int `json:"received_requests_vol"`
			TotalMessages       int `json:"total_messages"`
			TotalVolume         int `json:"total_volume"`
		} `json:"traffic"`
	} `json:"grpc"`
	Rest struct {
		Connections struct {
			Total                int `json:"total"`
			EventsSenders        int `json:"events_senders"`
			EventsStreamSenders  int `json:"events_stream_senders"`
			EventsReceivers      int `json:"events_receivers"`
			EventsStoreReceivers int `json:"events_store_receivers"`
			RequestsSenders      int `json:"requests_senders"`
			ResponsesSenders     int `json:"responses_senders"`
			CommandsReceivers    int `json:"commands_receivers"`
			QueriesReceivers     int `json:"queries_receivers"`
		} `json:"connections"`
		Traffic struct {
			SentEvents          int `json:"sent_events"`
			ReceivedEvents      int `json:"received_events"`
			SentRequests        int `json:"sent_requests"`
			SentError           int `json:"sent_error"`
			SentResponses       int `json:"sent_responses"`
			ReceivedRequests    int `json:"received_requests"`
			SentEventsVol       int `json:"sent_events_vol"`
			ReceivedEventsVol   int `json:"received_events_vol"`
			SentRequestsVol     int `json:"sent_requests_vol"`
			SentErrorsVol       int `json:"sent_errors_vol"`
			SentResponsesVol    int `json:"sent_responses_vol"`
			ReceivedRequestsVol int `json:"received_requests_vol"`
			TotalMessages       int `json:"total_messages"`
			TotalVolume         int `json:"total_volume"`
		} `json:"traffic"`
	} `json:"rest"`
}

func (*Health) String

func (h *Health) String() string

type Queue

type Queue struct {
	Name          string    `json:"name"`
	Messages      int64     `json:"messages"`
	Bytes         int64     `json:"bytes"`
	FirstSequence int64     `json:"first_sequence"`
	LastSequence  int64     `json:"last_sequence"`
	Clients       []*Client `json:"clients"`
}

type Queues

type Queues struct {
	Now    time.Time `json:"now"`
	Total  int       `json:"total"`
	Queues []*Queue  `json:"queues"`
}

func (*Queues) String

func (q *Queues) String() string