datasourcecache

Documentation

Index

• type ESClientProvider
• type Hits
• type NestedHits
• type Status
• type StatusProvider
  • func NewStatusProvider(esClient ESClientProvider, environment string) (*StatusProvider, error)
  • func (s *StatusProvider) Pull(projectSlug string, datasource string, endpoint string) (*Status, error)
  • func (s *StatusProvider) Store(status Status) error
• type TopHits

Types

type ESClientProvider

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

ESClientProvider used in connecting to ES server

type Hits

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

Hits result

type NestedHits

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

NestedHits is the actual hit data

type Status

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"`
}

Status ...

type StatusProvider

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

StatusProvider ...

func NewStatusProvider

func NewStatusProvider(esClient ESClientProvider, environment string) (*StatusProvider, error)

NewStatusProvider ...

func (*StatusProvider) Pull

func (s *StatusProvider) Pull(projectSlug string, datasource string, endpoint string) (*Status, error)

Pull ...

func (*StatusProvider) Store

func (s *StatusProvider) Store(status Status) error

Store ...

type TopHits

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

TopHits result