test_runner

Documentation

Index

• Variables
• type Config
  • func (*Config) Descriptor() ([]byte, []int)
  • func (x *Config) GetRedirectInstructions() []*RedirectInstruction
  • func (*Config) ProtoMessage()
  • func (x *Config) ProtoReflect() protoreflect.Message
  • func (x *Config) Reset()
  • func (x *Config) String() string
• type RedirectInstruction
  • func (*RedirectInstruction) Descriptor() ([]byte, []int)
  • func (x *RedirectInstruction) GetConstraint() *TrafficConstraint
  • func (x *RedirectInstruction) GetPercentOfRequests() int32
  • func (*RedirectInstruction) ProtoMessage()
  • func (x *RedirectInstruction) ProtoReflect() protoreflect.Message
  • func (x *RedirectInstruction) Reset()
  • func (x *RedirectInstruction) String() string
• type TrafficConstraint
  • func (*TrafficConstraint) Descriptor() ([]byte, []int)
  • func (x *TrafficConstraint) GetDutPool() string
  • func (x *TrafficConstraint) GetQuotaAccount() string
  • func (*TrafficConstraint) ProtoMessage()
  • func (x *TrafficConstraint) ProtoReflect() protoreflect.Message
  • func (x *TrafficConstraint) Reset()
  • func (x *TrafficConstraint) String() string

Variables

var File_test_platform_migration_test_runner_config_proto protoreflect.FileDescriptor

Types

type Config

type Config struct {
	RedirectInstructions []*RedirectInstruction `protobuf:"bytes,1,rep,name=redirect_instructions,json=redirectInstructions,proto3" json:"redirect_instructions,omitempty"`
	// contains filtered or unexported fields
}

Config describes how to split the entire traffic coming into CTP between test_runner and skylab_swarming_worker. The CTP requests directed to test_runner via request.migrations.use_test_runner are not affected by this config.

func (*Config) Descriptor

func (*Config) Descriptor() ([]byte, []int)

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) GetRedirectInstructions

func (x *Config) GetRedirectInstructions() []*RedirectInstruction

func (*Config) ProtoMessage

func (*Config) ProtoMessage()

func (*Config) ProtoReflect

func (x *Config) ProtoReflect() protoreflect.Message

func (*Config) Reset

func (x *Config) Reset()

func (*Config) String

func (x *Config) String() string

type RedirectInstruction

type RedirectInstruction struct {

	// Redirect a fraction of traffic that satisfies the constraint.
	Constraint *TrafficConstraint `protobuf:"bytes,1,opt,name=constraint,proto3" json:"constraint,omitempty"`
	// The probability of sending a given CTP request to test_runner as a
	// percentage. Should be in (0, 100].
	PercentOfRequests int32 `protobuf:"varint,2,opt,name=percent_of_requests,json=percentOfRequests,proto3" json:"percent_of_requests,omitempty"`
	// contains filtered or unexported fields
}

RedirectInstruction describes the fraction and the type of traffic to send to test_runner.

func (*RedirectInstruction) Descriptor

func (*RedirectInstruction) Descriptor() ([]byte, []int)

Deprecated: Use RedirectInstruction.ProtoReflect.Descriptor instead.

func (*RedirectInstruction) GetConstraint

func (x *RedirectInstruction) GetConstraint() *TrafficConstraint

func (*RedirectInstruction) GetPercentOfRequests

func (x *RedirectInstruction) GetPercentOfRequests() int32

func (*RedirectInstruction) ProtoMessage

func (*RedirectInstruction) ProtoMessage()

func (*RedirectInstruction) ProtoReflect

func (x *RedirectInstruction) ProtoReflect() protoreflect.Message

func (*RedirectInstruction) Reset

func (x *RedirectInstruction) Reset()

func (*RedirectInstruction) String

func (x *RedirectInstruction) String() string

type TrafficConstraint

type TrafficConstraint struct {

	// The DUT pool as it would appear in a Skylab request, e.g
	// "DUT_POOL_QUOTA", "DUT_POOL_CTS", "wificell".
	DutPool string `protobuf:"bytes,1,opt,name=dut_pool,json=dutPool,proto3" json:"dut_pool,omitempty"`
	// The quota account as it would appear in a Skylab request, e.g. "pcq".
	// Ignored if empty.
	QuotaAccount string `protobuf:"bytes,2,opt,name=quota_account,json=quotaAccount,proto3" json:"quota_account,omitempty"`
	// contains filtered or unexported fields
}

TrafficConstraint describes a way to filter CTP requests. The constraints are evaluated right before the execute step. Thus, the predecing steps (e.g. traffic splitter) may modify the inputs into the contraints before evaluation.

func (*TrafficConstraint) Descriptor

func (*TrafficConstraint) Descriptor() ([]byte, []int)

Deprecated: Use TrafficConstraint.ProtoReflect.Descriptor instead.

func (*TrafficConstraint) GetDutPool

func (x *TrafficConstraint) GetDutPool() string

func (*TrafficConstraint) GetQuotaAccount

func (x *TrafficConstraint) GetQuotaAccount() string

func (*TrafficConstraint) ProtoMessage

func (*TrafficConstraint) ProtoMessage()

func (*TrafficConstraint) ProtoReflect

func (x *TrafficConstraint) ProtoReflect() protoreflect.Message

func (*TrafficConstraint) Reset

func (x *TrafficConstraint) Reset()

func (*TrafficConstraint) String

func (x *TrafficConstraint) String() string