elasticgap

Documentation

Index

• type Auth0Client
• type ESResponseIndex
• type ElasticResponse
• type ElasticResponseItem
• type GapHandler
  • func NewGapHandler(gapURL string, httpClient HTTPClient, auth0Client Auth0Client) *GapHandler
  • func (g *GapHandler) HandleFailedData(data []elastic.BulkData, byteResponse []byte) (failedIndexes []elastic.BulkData, err error)
  • func (g *GapHandler) Send(data []elastic.BulkData) error
• type HTTPClient

Types

type Auth0Client

type Auth0Client interface {
	GetToken() (string, error)
}

Auth0Client ...

type ESResponseIndex

type ESResponseIndex struct {
	ID     string `json:"_id"`
	Status int
}

ESResponseIndex ...

type ElasticResponse

type ElasticResponse struct {
	Took   int
	Errors bool
	Items  []ElasticResponseItem
}

ElasticResponse ...

type ElasticResponseItem

type ElasticResponseItem struct {
	Index ESResponseIndex
}

ElasticResponseItem ...

type GapHandler

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

GapHandler ...

func NewGapHandler

func NewGapHandler(gapURL string, httpClient HTTPClient, auth0Client Auth0Client) *GapHandler

NewGapHandler ...

func (*GapHandler) HandleFailedData

func (g *GapHandler) HandleFailedData(data []elastic.BulkData, byteResponse []byte) (failedIndexes []elastic.BulkData, err error)

HandleFailedData ...

func (*GapHandler) Send

func (g *GapHandler) Send(data []elastic.BulkData) error

Send unsaved data to data-gap handler

type HTTPClient

type HTTPClient interface {
	Request(url string, method string, header map[string]string, body []byte, params map[string]string) (statusCode int, resBody []byte, err error)
}

HTTPClient used in connecting to remote http server