client

Documentation

Index

• Constants
• type Client
  • func (c *Client) CreateJob(job *jw.Job) (*jw.Job, error)
  • func (c *Client) CreateWorkflow(wf *jw.Workflow) (*jw.Workflow, error)
  • func (c *Client) NextJob(namespace string) (*jw.Job, error)
  • func (c *Client) UpdateJob(job *jw.Job) (*jw.Job, error)
• type Config
  • func (c *Config) BuildClient() (*Client, error)
• type ConfigOption
  • func WithCertKeyFiles(certFile, keyFile string) ConfigOption
  • func WithEndpoint(ep *Endpoint) ConfigOption
  • func WithLogger(logger Logger) ConfigOption
• type Endpoint
  • func NewEndpoint(url, username, password string, options ...EndpointOption) *Endpoint
• type EndpointOption
  • func WithCAFile(filename string) EndpointOption
• type Logger

Constants

const (
	ErrJobRunning = errors.Sentinel("job running")
	ErrJobUpdated = errors.Sentinel("job updated")
)

Types

type Client

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

func (*Client) CreateJob

func (c *Client) CreateJob(job *jw.Job) (*jw.Job, error)

func (*Client) CreateWorkflow

func (c *Client) CreateWorkflow(wf *jw.Workflow) (*jw.Workflow, error)

func (*Client) NextJob

func (c *Client) NextJob(namespace string) (*jw.Job, error)

func (*Client) UpdateJob

func (c *Client) UpdateJob(job *jw.Job) (*jw.Job, error)

type Config

type Config struct {
	Endpoints []*Endpoint `cfg:"endpoints"`
	CertFile  string      `cfg:"cert_file"`
	KeyFile   string      `cfg:"key_file"`
	Logger    Logger
}

func (*Config) BuildClient

func (c *Config) BuildClient() (*Client, error)

type ConfigOption

type ConfigOption func(*Config)

func WithCertKeyFiles

func WithCertKeyFiles(certFile, keyFile string) ConfigOption

func WithEndpoint

func WithEndpoint(ep *Endpoint) ConfigOption

func WithLogger

func WithLogger(logger Logger) ConfigOption

type Endpoint

type Endpoint struct {
	URL      string `cfg:"url"`
	Username string `cfg:"username"`
	Password string `cfg:"password"`
	CAFile   string `cfg:"ca_file"`
}

func NewEndpoint

func NewEndpoint(url, username, password string, options ...EndpointOption) *Endpoint

type EndpointOption

type EndpointOption func(*Endpoint)

func WithCAFile

func WithCAFile(filename string) EndpointOption

type Logger

type Logger interface {
	Trace(msg string, kv ...interface{})
	Debug(msg string, kv ...interface{})
	Notice(msg string, kv ...interface{})
	Warning(msg string, kv ...interface{})
	Error(msg string, kv ...interface{})
}