ingestjob

type ESLogProvider interface {
	CreateDocument(index, documentID string, body []byte) ([]byte, error)
	Get(index string, query map[string]interface{}, result interface{}) error
	BackOffGet(index string, query map[string]interface{}, result interface{}, attempts uint, delay time.Duration) error
	UpdateDocument(index string, id string, body interface{}) ([]byte, error)
	Count(index string, query map[string]interface{}) (int, error)
}

type Hits struct {
	Hits []NestedHits `json:"hits"`
}

type Log struct {
	Connector     string              `json:"connector"`
	Configuration []map[string]string `json:"configuration"`
	Status        string              `json:"status"`
	CreatedAt     time.Time           `json:"created_at"`
	UpdatedAt     time.Time           `json:"updated_at"`
	Message       string              `json:"message"`
	TaskARN       string              `json:"task_arn"`
	From          *time.Time          `json:"from,omitempty"`
	To            *time.Time          `json:"to,omitempty"`
}

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

type NestedHits struct {
	ID     string `json:"_id"`
	Source Log    `json:"_source"`
}

type TaskHits struct {
	Hits []TaskNestedHits `json:"hits"`
}

type TaskLog struct {
	Id            string              `json:"id"`            // task id
	Connector     string              `json:"connector"`     // name of connector as https://github.com/LF-Engineering/lfx-event-schema/blob/main/service/insights/shared.go#L32-L49
	EndpointId    string              `json:"endpoint_id"`   // generated ID of the endpoint per lfx-event-schema generator functions
	Configuration []map[string]string `json:"configuration"` // metadata
	CreatedAt     *time.Time          `json:"created_at,omitempty"`
}

type TaskNestedHits struct {
	ID     string  `json:"_id"`
	Source TaskLog `json:"_source"`
}

type TaskTopHits struct {
	Hits TaskHits `json:"hits"`
}

type TopHits struct {
	Hits Hits `json:"hits"`
}