dcpManager

Documentation

Index

• Variables
• func NewDummyManager() dummy
• type DcpManager
  • func NewDcpManager(mode dcpConn.Mode, id string, bucketName string, notif notifier.Observer, ...) DcpManager
  • func NewDcpManagerWithContext(ctx context.Context, mode dcpConn.Mode, id string, bucketName string, ...) DcpManager
  • func NewDcpManagerWrapper(manager DcpManager) DcpManager

Variables

var (
	ErrTryLater = errors.New("dcp consumer not spawned try later")
)

Functions

func NewDummyManager

func NewDummyManager() dummy

Types

type DcpManager

type DcpManager interface {
	DoneDcpEvent(event *dcpConn.DcpEvent)
	StartStreamReq(sr *dcpConn.StreamReq) error
	PauseStreamReq(sr *dcpConn.StreamReq)
	CloseRequest(sr *dcpConn.StreamReq) (*dcpConn.StreamReq, error)
	GetFailoverLog(vbs []uint16) (map[uint16]dcpConn.FailoverLog, error)
	GetSeqNumber(vbs []uint16, collectionID string) (map[uint16]uint64, error)

	RegisterID(id uint16, sendChannel chan<- *dcpConn.DcpEvent)
	DeregisterID(id uint16)

	CloseManager()
	CloseConditional() bool
}

DcpManager manages dcp connection It will send the dcp messages to the receiver It will manage all the connection till caller calls close dcp

func NewDcpManager

func NewDcpManager(mode dcpConn.Mode, id string, bucketName string, notif notifier.Observer, dcpConnConfig map[dcpConn.ConfigKey]interface{}) DcpManager

func NewDcpManagerWithContext

func NewDcpManagerWithContext(ctx context.Context, mode dcpConn.Mode, id string, bucketName string, notif notifier.Observer, dcpConnConfig map[dcpConn.ConfigKey]interface{}) DcpManager

func NewDcpManagerWrapper

func NewDcpManagerWrapper(manager DcpManager) DcpManager