dcpManager

package

v0.0.0-...-bf7481f Latest Latest Go to latest Published: Jul 6, 2026 License: Apache-2.0 Imports: 12 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/couchbase/eventing

Links

Open Source Insights

Documentation ¶

Constants ¶

This section is empty.

Variables ¶

View Source

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(id uint16, vbno uint16)
	CloseRequest(id uint16, vbno uint16)
	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)

	GetRuntimeStats() common.StatsInterface

	ClosePossible() bool
	CloseManager()
}

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(managerConfig ManagerType, id string, bucketName string, notif notifier.Observer, dcpConnConfig map[dcpConn.ConfigKey]interface{}) DcpManager

func NewDcpManagerWithContext ¶

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

func NewDcpManagerWrapper ¶

func NewDcpManagerWrapper(manager DcpManager) DcpManager

type ManagerType ¶

type ManagerType struct {
	Mode           dcpConn.Mode
	SeqInterval    time.Duration
	WaitForConnect bool
}

func (ManagerType) String ¶

func (mt ManagerType) String() string

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL