slaves

Documentation

Index

• Constants
• func ExtractSlaveEnvVariables(variables map[string]testkube.Variable) map[string]testkube.Variable
• func GetSlavesCount(vars map[string]testkube.Variable) (int, error)
• type Client
  • func NewClient(clientSet kubernetes.Interface, execution testkube.Execution, ...) *Client
  • func (c *Client) CreateSlaves(ctx context.Context, count int) (SlaveMeta, error)
  • func (c *Client) DeleteSlaves(ctx context.Context, meta SlaveMeta) error
• type Interface
• type PodOptions
• type SlaveMeta
  • func (m *SlaveMeta) IPs() []string
  • func (m *SlaveMeta) Names() []string
  • func (m *SlaveMeta) ToIPString() string

Constants

const (
	MasterOverrideJvmArgs      = "MASTER_OVERRIDE_JVM_ARGS"
	MasterAdditionalJvmArgs    = "MASTER_ADDITIONAL_JVM_ARGS"
	SlavesOverrideJvmArgs      = "SLAVES_OVERRIDE_JVM_ARGS"
	SlavesAdditionalJvmArgs    = "SLAVES_ADDITIONAL_JVM_ARGS"
	SlavesAdditionalJmeterArgs = "SLAVES_ADDITIONAL_JMETER_ARGS"
	SlavesCount                = "SLAVES_COUNT"
	MasterPrefix               = "MASTER_"
	SlavesPrefix               = "SLAVES_"
)

Functions

func ExtractSlaveEnvVariables

func ExtractSlaveEnvVariables(variables map[string]testkube.Variable) map[string]testkube.Variable

ExtractSlaveEnvVariables removes slave environment variables from the given map and returns them separately.

func GetSlavesCount

func GetSlavesCount(vars map[string]testkube.Variable) (int, error)

Types

type Client

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

func NewClient

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

NewClient is a method to create new slave client

func (*Client) CreateSlaves

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

CreateSlaves creates slaves as per provided count

func (*Client) DeleteSlaves

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

type Interface

type Interface interface {
	CreateSlaves(ctx context.Context, count int) (SlaveMeta, error)
	DeleteSlaves(ctx context.Context, meta SlaveMeta) error
}

type PodOptions

type PodOptions struct {
	Name                  string
	Namespace             string
	JobName               string
	JobUID                string
	ActiveDeadlineSeconds int
	Registry              string
	InitImage             string
	Image                 string
	Jsn                   string
	CertificateSecret     string
	ServiceAccountName    string
	EnvConfigMaps         []testkube.EnvReference
	EnvSecrets            []testkube.EnvReference
	Ports                 []v1.ContainerPort
	Resources             *testkube.PodResourcesRequest
	ImagePullSecrets      []string
}

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