Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DcpManagerType ¶
type DcpManagerType uint8
const ( CommonConn DcpManagerType = iota DedicatedConn )
type ManagerPool ¶
type ManagerPool interface {
GetDcpManagerPool(dcpManagerType DcpManagerType, identifier string, bucketName string, sendChannel chan<- *dcpConn.DcpEvent) dcpManager.DcpManager
GetSeqManager(bucketName string) SeqNumerInterface
GetCheckpointManager(appId uint32, instanceID string, interruptCallback checkpointManager.InterruptFunction, appLocation application.AppLocation, keyspace application.Keyspace) checkpointManager.Checkpoint
TlsSettingsChanged(gocbCluster *gocb.Cluster)
GetRuntimeStats() common.StatsInterface
CloseConditional()
ClosePool()
}
func NewManagerPool ¶
func NewManagerPool(ctx context.Context, poolID string, clusterSettings *common.ClusterSettings, notif notifier.Observer, gocbCluster *gocb.Cluster, broadcaster common.Broadcaster) ManagerPool
type SeqNumerInterface ¶
type SeqNumerInterface interface {
RegisterID(id uint16, sendChannel chan<- *dcpConn.DcpEvent)
GetSeqNumber(vbs []uint16, collectionID string) (map[uint16]uint64, error)
GetFailoverLog(vbs []uint16) (map[uint16]dcpConn.FailoverLog, error)
DeregisterID(id uint16)
GetRuntimeStats() common.StatsInterface
CloseManager()
}
Source Files
Click to show internal directories.
Click to hide internal directories.