mongo-driver: go.mongodb.org/mongo-driver/event Index | Files

package event

import "go.mongodb.org/mongo-driver/event"

Index

Package Files

monitoring.go

Constants

const (
    ReasonIdle              = "idle"
    ReasonPoolClosed        = "poolClosed"
    ReasonStale             = "stale"
    ReasonConnectionErrored = "connectionError"
    ReasonTimedOut          = "timeout"
)

strings for pool command monitoring reasons

const (
    ConnectionClosed   = "ConnectionClosed"
    PoolCreated        = "ConnectionPoolCreated"
    ConnectionCreated  = "ConnectionCreated"
    GetFailed          = "ConnectionCheckOutFailed"
    GetSucceeded       = "ConnectionCheckedOut"
    ConnectionReturned = "ConnectionCheckedIn"
    PoolCleared        = "ConnectionPoolCleared"
    PoolClosedEvent    = "ConnectionPoolClosed"
)

strings for pool command monitoring types

type CommandFailedEvent Uses

type CommandFailedEvent struct {
    CommandFinishedEvent
    Failure string
}

CommandFailedEvent represents an event generated when a command's execution fails.

type CommandFinishedEvent Uses

type CommandFinishedEvent struct {
    DurationNanos int64
    CommandName   string
    RequestID     int64
    ConnectionID  string
}

CommandFinishedEvent represents a generic command finishing.

type CommandMonitor Uses

type CommandMonitor struct {
    Started   func(context.Context, *CommandStartedEvent)
    Succeeded func(context.Context, *CommandSucceededEvent)
    Failed    func(context.Context, *CommandFailedEvent)
}

CommandMonitor represents a monitor that is triggered for different events.

type CommandStartedEvent Uses

type CommandStartedEvent struct {
    Command      bson.Raw
    DatabaseName string
    CommandName  string
    RequestID    int64
    ConnectionID string
}

CommandStartedEvent represents an event generated when a command is sent to a server.

type CommandSucceededEvent Uses

type CommandSucceededEvent struct {
    CommandFinishedEvent
    Reply bson.Raw
}

CommandSucceededEvent represents an event generated when a command's execution succeeds.

type MonitorPoolOptions Uses

type MonitorPoolOptions struct {
    MaxPoolSize        uint64 `json:"maxPoolSize"`
    MinPoolSize        uint64 `json:"minPoolSize"`
    WaitQueueTimeoutMS uint64 `json:"maxIdleTimeMS"`
}

MonitorPoolOptions contains pool options as formatted in pool events

type PoolEvent Uses

type PoolEvent struct {
    Type         string              `json:"type"`
    Address      string              `json:"address"`
    ConnectionID uint64              `json:"connectionId"`
    PoolOptions  *MonitorPoolOptions `json:"options"`
    Reason       string              `json:"reason"`
}

PoolEvent contains all information summarizing a pool event

type PoolMonitor Uses

type PoolMonitor struct {
    Event func(*PoolEvent)
}

PoolMonitor is a function that allows the user to gain access to events occurring in the pool

Package event imports 2 packages (graph) and is imported by 13 packages. Updated 2019-08-14. Refresh now. Tools for package owners.