client

type DiskIoStats struct {
	ReadBytes    int64 `json:"readBytes"`
	WrittenBytes int64 `json:"writtenBytes"`
	ReadOps      int64 `json:"readOps"`
	WriteOps     int64 `json:"writeOps"`
}

type DriveStats struct {
	TotalBytes     int64 `json:"totalBytes"`
	AvailableBytes int64 `json:"availableBytes"`
}

type EsInfo struct {
	EsVersion   EventStoreVersion `json:"esVersion"`
	MemberState string            `json:"state"`
	Features    Features          `json:"features"`
}

type EsStats struct {
	Queues map[string]QueueStats `json:"queue"`
}

type EventPosition string

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

type EventStoreVersion string

type Features struct {
	Projections    bool `json:"projections"`
	UserManagement bool `json:"userManagement"`
	AtomPub        bool `json:"atomPub"`
}

type MemberStats struct {
	HTTPEndpointIP   string `json:"httpEndPointIp"`
	HTTPEndpointPort int    `json:"httpEndPointPort"`
	IsAlive          bool
}

type ProcessStats struct {
	CPU         float64     `json:"cpu"`
	MemoryBytes int64       `json:"mem"`
	DiskIo      DiskIoStats `json:"diskIo"`
	TCP         TCPStats    `json:"tcp"`
}

type ProjectionStats struct {
	EffectiveName               string  `json:"effectiveName"`
	Status                      string  `json:"status"`
	Progress                    float64 `json:"progress"`
	EventsProcessedAfterRestart int64   `json:"eventsProcessedAfterRestart"`
}

type QueueStats struct {
	QueueName      string `json:"queueName"`
	Length         int64  `json:"length"`
	ItemsProcessed int64  `json:"totalItemsProcessed"`
}

type ServerStats struct {
	Process ProcessStats `json:"proc"`
	System  SystemStats  `json:"sys"`
	Es      EsStats      `json:"es"`
}

type Stats struct {
	Info           *EsInfo
	Server         *ServerStats
	ClusterMembers []MemberStats
	Projections    []ProjectionStats
	Subscriptions  []SubscriptionStats
	Streams        []StreamStats
	TCPConnections []TCPConnectionStats
}

type StreamStats struct {
	EventStreamID      string
	LastCommitPosition int64
	LastEventNumber    int64
}

type SubscriptionStats struct {
	EventStreamID                   string `json:"eventStreamId"`
	GroupName                       string `json:"groupName"`
	TotalItemsProcessed             int64  `json:"totalItemsProcessed"`
	ConnectionCount                 int64  `json:"connectionCount"`
	LastKnownEventNumber            int64  `json:"lastKnownEventNumber"`
	LastProcessedEventNumber        int64  `json:"lastProcessedEventNumber"`
	LastCheckpointedEventPosition   string `json:"lastCheckpointedEventPosition"`
	LastKnownEventPosition          string `json:"lastKnownEventPosition"`
	TotalInFlightMessages           int64  `json:"totalInFlightMessages"`
	TotalNumberOfParkedMessages     int64
	OldestParkedMessageAgeInSeconds float64
}

type SystemStats struct {
	Drives map[string]DriveStats `json:"drive"`
}

type TCPConnectionStats struct {
	RemoteEndPoint       string `json:"remoteEndPoint"`
	LocalEndPoint        string `json:"localEndPoint"`
	ConnectionID         string `json:"connectionId"`
	ClientConnectionName string `json:"clientConnectionName"`
	TotalBytesSent       int64  `json:"totalBytesSent"`
	TotalBytesReceived   int64  `json:"totalBytesReceived"`
	PendingSendBytes     int64  `json:"pendingSendBytes"`
	PendingReceivedBytes int64  `json:"pendingReceivedBytes"`
	IsExternalConnection bool   `json:"isExternalConnection"`
	IsSslConnection      bool   `json:"isSslConnection"`
}

type TCPStats struct {
	SentBytes     int64 `json:"sentBytesTotal"`
	ReceivedBytes int64 `json:"receivedBytesTotal"`
	Connections   int64 `json:"connections"`
}