datasourcecache

type ESClientProvider 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)
}

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

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

type Status struct {
	ProjectSlug         string      `json:"project_slug"`
	Datasource          string      `json:"datasource"`
	Endpoint            string      `json:"endpoint"`
	UpdatedAt           time.Time   `json:"updated_at"`
	CreatedAt           time.Time   `json:"created_at"`
	ErrorMessage        string      `json:"error_message"`
	Status              int         `json:"status"`
	LastSuccessfulEvent interface{} `json:"last_successful_event"`
}

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

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