slaves

package
v1.16.12-beta058 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 12, 2023 License: MIT, MIT Imports: 24 Imported by: 0

Documentation

Index

Constants

View Source
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_"
)

Variables

This section is empty.

Functions

func ExtractSlaveEnvVariables added in v1.16.11

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 added in v1.16.11

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 added in v1.16.11

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL