trace

type ClusterNodeInfo struct {
	Addr      string
	Slots     [][2]uint16
	IsPrimary bool
}

type ClusterRedirected struct {
	Addr          string
	Key           string
	Moved, Ask    bool
	RedirectCount int

	// If true, then the MOVED/ASK error which was received will not be honored,
	// and the call to Do will be returning the MOVED/ASK error.
	Final bool
}

type ClusterStateChange struct {
	IsDown bool
}

type ClusterTopoChanged struct {
	Added   []ClusterNodeInfo
	Removed []ClusterNodeInfo
	Changed []ClusterNodeInfo
}

type ClusterTrace struct {
	// StateChange is called when the cluster becomes down or becomes available again.
	StateChange func(ClusterStateChange)
	// TopoChanged is called when the cluster's topology changed.
	TopoChanged func(ClusterTopoChanged)
	// Redirected is called when radix.Do responded 'MOVED' or 'ASKED'.
	Redirected func(ClusterRedirected)
}

type PoolCommon struct {
	// Network and Addr indicate the network/address the Pool was created with
	// (useful for differentiating different redis instances in a Cluster).
	Network, Addr string

	// PoolSize and BufferSize indicate the Pool size and buffer size that the
	// Pool was initialized with.
	PoolSize, BufferSize int
}

type PoolConnClosed struct {
	PoolCommon

	// AvailCount indicates the total number of connections the Pool is holding
	// on to which are available for usage at the moment the trace occurs.
	AvailCount int

	// The reason the connection was closed.
	Reason PoolConnClosedReason
}

type PoolConnClosedReason string

type PoolConnCreated struct {
	PoolCommon

	// The reason the connection was created.
	Reason PoolConnCreatedReason

	// How long it took to create the connection.
	ConnectTime time.Duration

	// If connection creation failed, this is the error it failed with.
	Err error
}

type PoolConnCreatedReason string

type PoolDoCompleted struct {
	PoolCommon

	// AvailCount indicates the total number of connections the Pool is holding
	// on to which are available for usage at the moment the trace occurs.
	AvailCount int

	// How long it took to send command.
	ElapsedTime time.Duration

	// This is the error returned from redis.
	Err error
}

type PoolInitCompleted struct {
	PoolCommon

	// AvailCount indicates the total number of connections the Pool is holding
	// on to which are available for usage at the moment the trace occurs.
	AvailCount int

	// How long it took to fill all connections.
	ElapsedTime time.Duration
}

type PoolTrace struct {
	// ConnCreated is called when the Pool creates a new connection. The
	// provided Err indicates whether the connection successfully completed.
	ConnCreated func(PoolConnCreated)

	// ConnClosed is called before closing the connection.
	ConnClosed func(PoolConnClosed)

	// DoCompleted is called after command execution. Must consider race condition
	// for manipulating variables in DoCompleted callback since DoComplete
	// function can be called in many go-routines.
	DoCompleted func(PoolDoCompleted)

	// InitCompleted is called after pool fills its connections
	InitCompleted func(PoolInitCompleted)
}