kafka

type AfterFailed func(request RecordPayload, err error, id uint64, uuid string)

type AfterSend func(request RecordPayload, response interface{}, id uint64, uuid string)

type BeforeSend func(request RecordPayload, tickerTimestamp time.Time, id uint64, uuid string)

type FailedChecker func(response interface{}) error

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

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

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

type RecordPayload []byte

type RequestFactory func(tickerTimestamp time.Time, id uint64, uuid string) RecordPayload

type Sender interface {
	InitializeWorker() *KafkaWorker
	Send(worker *KafkaWorker, request RecordPayload) (interface{}, error)
}