client

Documentation

Index

• type JenkinsAccessor
• type Nodes
  • func (n Nodes) ExcludeNode(name string) Nodes
  • func (n Nodes) ExcludeOffline() Nodes
  • func (n Nodes) KeepWithLabel(label string) Nodes
  • func (n Nodes) Len() int64
• type Options
  • func (o *Options) Name() string
• type WrapperClient
  • func New(opt *Options) *WrapperClient
  • func (c *WrapperClient) GetAllNodes(ctx context.Context) (Nodes, error)

Types

type JenkinsAccessor

type JenkinsAccessor interface {
	DeleteNode(ctx context.Context, name string) (bool, error)
	GetAllNodes(ctx context.Context) (Nodes, error)
	GetNode(ctx context.Context, name string) (*gojenkins.Node, error)
}

type Nodes

type Nodes map[string]*gojenkins.Node

func (Nodes) ExcludeNode

func (n Nodes) ExcludeNode(name string) Nodes

func (Nodes) ExcludeOffline

func (n Nodes) ExcludeOffline() Nodes

func (Nodes) KeepWithLabel

func (n Nodes) KeepWithLabel(label string) Nodes

func (Nodes) Len

func (n Nodes) Len() int64

type Options

type Options struct {
	JenkinsURL     string        `config:"jenkins_url" validate:"required"`
	JenkinsUser    string        `config:"jenkins_user" validate:"required"`
	JenkinsToken   string        `config:"jenkins_token" validate:"required"`
	LastErrBackoff time.Duration `config:"last_err_backoff"`
}

func (*Options) Name

func (o *Options) Name() string

type WrapperClient

type WrapperClient struct {
	*gojenkins.Jenkins
	// contains filtered or unexported fields
}

func New

func New(opt *Options) *WrapperClient

New returns a new Client.

func (*WrapperClient) GetAllNodes

func (c *WrapperClient) GetAllNodes(ctx context.Context) (Nodes, error)