handler

Documentation

Index

• type BatchHandler
  • func NewBatchHandler(esClient *dpelasticsearch.Client) *BatchHandler
  • func (batchHandler BatchHandler) Handle(ctx context.Context, url string, events []*models.SearchDataImportModel) error

Types

type BatchHandler

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

BatchHandler handles batches of SearchDataImportModel events that contain CSV row data.

func NewBatchHandler

func NewBatchHandler(esClient *dpelasticsearch.Client) *BatchHandler

NewBatchHandler returns a BatchHandler.

func (BatchHandler) Handle

func (batchHandler BatchHandler) Handle(ctx context.Context, url string, events []*models.SearchDataImportModel) error

Handle the given slice of SearchDataImport Model.