bulk

Documentation

Index

• type BatchItem
• type Bulk
  • func NewBulk(cfg *config.Config, dcpCheckpointCommit func()) (*Bulk, error)
  • func (b *Bulk) AddActions(ctx *models.ListenerContext, eventTime time.Time, actions []mongodb.Model, ...)
  • func (b *Bulk) Close()
  • func (b *Bulk) StartBulk()

Types

type BatchItem

type BatchItem struct {
	Model mongodb.Model
	Bytes []byte
	Size  int
}

type Bulk

type Bulk struct {
	// contains filtered or unexported fields
}

func NewBulk

func NewBulk(cfg *config.Config, dcpCheckpointCommit func()) (*Bulk, error)

func (*Bulk) AddActions

func (b *Bulk) AddActions(
	ctx *models.ListenerContext,
	eventTime time.Time,
	actions []mongodb.Model,
	couchbaseCollectionName string,
)

func (*Bulk) Close

func (b *Bulk) Close()

func (*Bulk) StartBulk

func (b *Bulk) StartBulk()