search

Documentation

Index

• type Client
  • func New(User string, Password string, URL []string) (*Client, error)
  • func (c *Client) AddJob(CI string, Organization string, Repository string, RunId int64) (string, error)
  • func (c *Client) CreateJobsIndex() error
  • func (c *Client) CreateWorkflowIndex(CI string, Organization string, Repository string, RunId int64) (string, error)
  • func (c *Client) DeleteJob(DocumentId string) error
  • func (c *Client) PendingJobs() (JobList, error)
  • func (c Client) ValidateSetup() error
• type Job
• type JobList

Types

type Client

type Client struct {
	OpenSearch *opensearchapi.Client
}

func New

func New(User string, Password string, URL []string) (*Client, error)

func (*Client) AddJob

func (c *Client) AddJob(CI string, Organization string, Repository string, RunId int64) (string, error)

func (*Client) CreateJobsIndex

func (c *Client) CreateJobsIndex() error

func (*Client) CreateWorkflowIndex

func (c *Client) CreateWorkflowIndex(CI string, Organization string, Repository string, RunId int64) (string, error)

func (*Client) DeleteJob

func (c *Client) DeleteJob(DocumentId string) error

func (*Client) PendingJobs

func (c *Client) PendingJobs() (JobList, error)

func (Client) ValidateSetup

func (c Client) ValidateSetup() error

Validate the index setup in the opensearch cluster

type Job

type Job struct {
	Timestamp    time.Time `json:"@timestamp"`
	CI           string    `json:"ci"`
	Organization string    `json:"organization"`
	Repository   string    `json:"repository"`
	RunId        int64     `json:"runid"`
}

type JobList

type JobList map[string]Job