trace

type ClusterInternalError struct {
	Err error
}

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

type ClusterRedirected struct {
	// Context is the Context passed into the Do call which is performing the
	// Action which received a MOVED/ASK error.
	Context context.Context

	// Addr is the address of the redis instance the Action was performed
	// against.
	Addr string

	// Key is the key that the Action would operate on.
	Key string

	// Moved and Ask denote which kind of error was returned. One will be true.
	Moved, Ask bool

	// RedirectCount denotes how many times the Action has been redirected so
	// far.
	RedirectCount int

	// Final indicates that 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 changes.
	TopoChanged func(ClusterTopoChanged)

	// Redirected is called when redis responds to an Action with a 'MOVED' or
	// 'ASK' error.
	Redirected func(ClusterRedirected)

	// InternalError is called whenever the Cluster encounters an error which is
	// not otherwise communicated to the user.
	InternalError func(ClusterInternalError)
}

type PersistentPubSubInternalError struct {
	Err error
}

type PersistentPubSubTrace struct {
	// InternalError is called whenever the PersistentPubSub encounters an error
	// which is not otherwise communicated to the user.
	InternalError func(PersistentPubSubInternalError)
}

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 indicates the PoolSize that the Pool was initialized with.
	PoolSize int
}

type PoolConnClosed struct {
	PoolCommon

	// Reason describes why the Conn was closed.
	Reason PoolConnClosedReason
}

type PoolConnClosedReason string

type PoolConnCreated struct {
	PoolCommon

	// Context is the Context used when creating the Conn.
	Context context.Context

	// Reason describes why the Conn was created.
	Reason PoolConnCreatedReason

	// ConnectTime is how long it took to create the Conn.
	ConnectTime time.Duration

	// Err will be filled if creating the Conn failed.
	Err error
}

type PoolConnCreatedReason string

type PoolInitCompleted struct {
	PoolCommon

	// ElapsedTime is how long it took to finish initialization.
	ElapsedTime time.Duration
}

type PoolTrace struct {
	// ConnCreated is called when the Pool creates a new Conn.
	ConnCreated func(PoolConnCreated)

	// ConnClosed is called when the Pool closes a Conn.
	ConnClosed func(PoolConnClosed)

	// InitCompleted is called after the Pool creates all Conns during
	// initialization.
	InitCompleted func(PoolInitCompleted)
}

type SentinelInternalError struct {
	Err error
}

type SentinelNodeInfo struct {
	Addr      string
	IsPrimary bool
}

type SentinelTopoChanged struct {
	Added   []SentinelNodeInfo
	Removed []SentinelNodeInfo
	Changed []SentinelNodeInfo
}

type SentinelTrace struct {
	// TopoChanged is called when the Sentinel's replica set's topology changes.
	TopoChanged func(SentinelTopoChanged)

	// InternalError is called whenever the Sentinel encounters an error which
	// is not otherwise communicated to the user.
	InternalError func(SentinelInternalError)
}