bulk

Documentation

Index

• type BatchItem
• type Bulk
  • func NewBulk(config *config.Config, dcpCheckpointCommit func(), ...) (*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 BatchItem

type BatchItem struct {
	Action *document.ESActionDocument
	Bytes  []byte
}

type Bulk

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

func NewBulk

func NewBulk(
	config *config.Config,
	dcpCheckpointCommit func(),
	esClient *elasticsearch.Client,
	sinkResponseHandler dcpElasticsearch.SinkResponseHandler,
) (*Bulk, error)

func (*Bulk) AddActions

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

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
}