elasticsearch

Documentation

Index

• type RejectionLog
• type RejectionLogSinkResponseHandler
  • func (crh *RejectionLogSinkResponseHandler) OnError(ctx *SinkResponseHandlerContext)
  • func (crh *RejectionLogSinkResponseHandler) OnInit(ctx *SinkResponseHandlerInitContext)
  • func (crh *RejectionLogSinkResponseHandler) OnSuccess(_ *SinkResponseHandlerContext)
• type SinkResponseHandler
  • func NewRejectionLogSinkResponseHandler() SinkResponseHandler
• type SinkResponseHandlerContext
• type SinkResponseHandlerInitContext

Types

type RejectionLog

type RejectionLog struct {
	Index      string
	Action     string
	Error      string
	Source     string
	DocumentID []byte
}

type RejectionLogSinkResponseHandler

type RejectionLogSinkResponseHandler struct {
	Config              *config.Config
	ElasticsearchClient *elasticsearch.Client
	Index               string
}

func (*RejectionLogSinkResponseHandler) OnError

func (crh *RejectionLogSinkResponseHandler) OnError(ctx *SinkResponseHandlerContext)

func (*RejectionLogSinkResponseHandler) OnInit

func (crh *RejectionLogSinkResponseHandler) OnInit(ctx *SinkResponseHandlerInitContext)

func (*RejectionLogSinkResponseHandler) OnSuccess

func (crh *RejectionLogSinkResponseHandler) OnSuccess(_ *SinkResponseHandlerContext)

type SinkResponseHandler

type SinkResponseHandler interface {
	OnSuccess(ctx *SinkResponseHandlerContext)
	OnError(ctx *SinkResponseHandlerContext)
	OnInit(ctx *SinkResponseHandlerInitContext)
}

func NewRejectionLogSinkResponseHandler

func NewRejectionLogSinkResponseHandler() SinkResponseHandler

type SinkResponseHandlerContext

type SinkResponseHandlerContext struct {
	Action *document.ESActionDocument
	Err    error
}

type SinkResponseHandlerInitContext

type SinkResponseHandlerInitContext struct {
	Config              *config.Config
	ElasticsearchClient *elasticsearch.Client
}