ingestjob

type ESLogProvider interface {
	CreateDocument(index, documentID string, body []byte) ([]byte, error)
	Get(index string, query map[string]interface{}, result interface{}) 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"`
	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 TopHits struct {
	Hits Hits `json:"hits"`
}