Documentation ¶
Index ¶
- Constants
- type DiskIoStats
- type DriveStats
- type EsInfo
- type EsStats
- type EventPosition
- type EventStoreStatsClient
- type EventStoreVersion
- type Features
- type MemberStats
- type ProcessStats
- type ProjectionStats
- type QueueStats
- type ServerStats
- type Stats
- type StreamStats
- type SubscriptionStats
- type SystemStats
- type TCPConnectionStats
- type TCPStats
Constants ¶
View Source
const ( MemberStateLeader string = "leader" MemberStateFollower string = "follower" MemberStateReadOnlyReplica string = "readonlyreplica" MemberStateClone string = "clone" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DiskIoStats ¶ added in v0.11.0
type DriveStats ¶ added in v0.11.0
type EsInfo ¶ added in v0.15.1
type EsInfo struct { EsVersion EventStoreVersion `json:"esVersion"` MemberState string `json:"state"` Features Features `json:"features"` }
type EsStats ¶ added in v0.15.1
type EsStats struct {
Queues map[string]QueueStats `json:"queue"`
}
type EventPosition ¶ added in v0.15.1
type EventPosition string
func (EventPosition) ParseCommitPreparePosition ¶ added in v0.15.1
func (position EventPosition) ParseCommitPreparePosition() (commit int64, prepare int64, err error)
parseEventPosition extracts commit and prepare position from strings like "C:1234/P:5678"
type EventStoreStatsClient ¶
type EventStoreStatsClient struct {
// contains filtered or unexported fields
}
func New ¶
func New(config *config.Config) *EventStoreStatsClient
type EventStoreVersion ¶
type EventStoreVersion string
func (EventStoreVersion) IsAtLeastVersion ¶
func (esVersion EventStoreVersion) IsAtLeastVersion(minVersion string) bool
func (EventStoreVersion) IsVersionLowerThan ¶
func (esVersion EventStoreVersion) IsVersionLowerThan(maxVersion string) bool
type MemberStats ¶ added in v0.11.0
type ProcessStats ¶ added in v0.11.0
type ProcessStats struct { CPU float64 `json:"cpu"` MemoryBytes int64 `json:"mem"` DiskIo DiskIoStats `json:"diskIo"` TCP TCPStats `json:"tcp"` }
type ProjectionStats ¶ added in v0.11.0
type QueueStats ¶ added in v0.11.0
type ServerStats ¶ added in v0.15.1
type ServerStats struct { Process ProcessStats `json:"proc"` System SystemStats `json:"sys"` Es EsStats `json:"es"` }
type Stats ¶
type Stats struct { Info *EsInfo Server *ServerStats ClusterMembers []MemberStats Projections []ProjectionStats Subscriptions []SubscriptionStats Streams []StreamStats TCPConnections []TCPConnectionStats }
type StreamStats ¶ added in v0.11.0
type SubscriptionStats ¶ added in v0.11.0
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 ¶ added in v0.15.1
type SystemStats struct {
Drives map[string]DriveStats `json:"drive"`
}
type TCPConnectionStats ¶ added in v0.15.2
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"` }
Click to show internal directories.
Click to hide internal directories.