bulk

Documentation

Index

• type Bulk
  • func NewBulk(config *config.Config, logger logger.Logger, errorLogger logger.Logger, ...) (*Bulk, error)
  • func (b *Bulk) AddActions(ctx *models.ListenerContext, eventTime time.Time, ...)
  • func (b *Bulk) Close()
  • func (b *Bulk) GetMetric() *Metric
  • func (b *Bulk) PrepareEndRebalancing()
  • func (b *Bulk) PrepareStartRebalancing()
  • func (b *Bulk) StartBulk()
• type Metric

Types

type Bulk

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

func NewBulk

func NewBulk(
	config *config.Config,
	logger logger.Logger,
	errorLogger logger.Logger,
	dcpCheckpointCommit func(),
) (*Bulk, error)

func (*Bulk) AddActions

func (b *Bulk) AddActions(
	ctx *models.ListenerContext,
	eventTime time.Time,
	actions []document.ESActionDocument,
	collectionName string,
)

func (*Bulk) Close

func (b *Bulk) Close()

func (*Bulk) GetMetric

func (b *Bulk) GetMetric() *Metric

func (*Bulk) PrepareEndRebalancing

func (b *Bulk) PrepareEndRebalancing()

func (*Bulk) PrepareStartRebalancing

func (b *Bulk) PrepareStartRebalancing()

func (*Bulk) StartBulk

func (b *Bulk) StartBulk()

type Metric

type Metric struct {
	ProcessLatencyMs            int64
	BulkRequestProcessLatencyMs int64
}