elasticgap

package
v1.5.32 Latest Latest
Warning

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

Go to latest
Published: Apr 27, 2023 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL