handler

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 19, 2023 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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, cfg *config.Config) *BatchHandler

NewBatchHandler returns a BatchHandler.

func (*BatchHandler) Handle 

func (h *BatchHandler) Handle(ctx context.Context, batch []kafka.Message) error

type Error added in v0.13.0 

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

Error is the handler package's error type. Is not meant to be compared as a type, but information should be extracted via the interfaces it implements with callback functions. Is not guaranteed to remain exported so shouldn't be treated as such.

func NewError added in v0.13.0 

func NewError(err error, logData map[string]interface{}) *Error

NewError creates a new Error

func (*Error) Error added in v0.13.0 

func (e *Error) Error() string

Error implements the Go standard error interface

func (*Error) LogData added in v0.13.0 

func (e *Error) LogData() map[string]interface{}

LogData implements the DataLogger interface which allows you extract embedded log.Data from an error

func (*Error) Unwrap added in v0.13.0 

func (e *Error) Unwrap() error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.