client

Documentation

Index

• type JenkinsAccessor
• type Nodes
  • func (n Nodes) ExcludeNode(name string) Nodes
  • func (n Nodes) ExcludeOffline() Nodes
  • func (n Nodes) IsExist(name string) (*gojenkins.Node, bool)
  • 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)
  • func (c *WrapperClient) GetCurrentUsage(ctx context.Context) (int64, error)

Types

type JenkinsAccessor

type JenkinsAccessor interface {
	GetCurrentUsage(ctx context.Context) (int64, error)
	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) IsExist

func (n Nodes) IsExist(name string) (*gojenkins.Node, bool)

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"`
	ControllerNodeName string `config:"controller_node_name"`
	NodeNumExecutors   int64  `config:"node_num_executors"`
}

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)

func (*WrapperClient) GetCurrentUsage

func (c *WrapperClient) GetCurrentUsage(ctx context.Context) (int64, error)

GetCurrentUsage return the current usage of jenkins nodes.