slaves

Documentation

Index

• func ValidateAndGetSlavePodName(testName string, executionId string, currentSlaveCount int) string
• type Client
  • func NewClient(execution testkube.Execution, slavesConfigs executor.SlavesConfigs, ...) (*Client, error)
  • func (c *Client) CreateSlaves(ctx context.Context) (SlaveMeta, error)
  • func (c *Client) DeleteSlaves(ctx context.Context, meta SlaveMeta) error
• type Interface
• type SlaveMeta
  • func (m *SlaveMeta) IPs() []string
  • func (m *SlaveMeta) Names() []string
  • func (m *SlaveMeta) ToIPString() string

Functions

func ValidateAndGetSlavePodName

func ValidateAndGetSlavePodName(testName string, executionId string, currentSlaveCount int) string

Types

type Client

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

func NewClient

func NewClient(execution testkube.Execution, slavesConfigs executor.SlavesConfigs, envParams envs.Params, slavesEnvVariables map[string]testkube.Variable) (*Client, error)

NewClient is a method to create new slave client

func (*Client) CreateSlaves

func (c *Client) CreateSlaves(ctx context.Context) (SlaveMeta, error)

CreateSlaves creates slaves as per count provided in the SLAVES_COUNT env variable. Default SLAVES_COUNT would be 1 if not provided in the env variables

func (*Client) DeleteSlaves

func (c *Client) DeleteSlaves(ctx context.Context, meta SlaveMeta) error

type Interface

type Interface interface {
	CreateSlaves(context.Context) (SlaveMeta, error)
	DeleteSlaves(context.Context, SlaveMeta) error
}

type SlaveMeta

type SlaveMeta map[string]string

func (*SlaveMeta) IPs

func (m *SlaveMeta) IPs() []string

func (*SlaveMeta) Names

func (m *SlaveMeta) Names() []string

func (*SlaveMeta) ToIPString

func (m *SlaveMeta) ToIPString() string