proto: go.chromium.org/chromiumos/infra/proto/go/test_platform/migration/test_runner Index | Files

package test_runner

import "go.chromium.org/chromiumos/infra/proto/go/test_platform/migration/test_runner"

Index

Package Files

config.pb.go

type Config Uses

type Config struct {
    RedirectInstructions []*RedirectInstruction `protobuf:"bytes,1,rep,name=redirect_instructions,json=redirectInstructions,proto3" json:"redirect_instructions,omitempty"`
    XXX_NoUnkeyedLiteral struct{}               `json:"-"`
    XXX_unrecognized     []byte                 `json:"-"`
    XXX_sizecache        int32                  `json:"-"`
}

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 Uses

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

func (*Config) GetRedirectInstructions Uses

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

func (*Config) ProtoMessage Uses

func (*Config) ProtoMessage()

func (*Config) Reset Uses

func (m *Config) Reset()

func (*Config) String Uses

func (m *Config) String() string

func (*Config) XXX_DiscardUnknown Uses

func (m *Config) XXX_DiscardUnknown()

func (*Config) XXX_Marshal Uses

func (m *Config) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Config) XXX_Merge Uses

func (m *Config) XXX_Merge(src proto.Message)

func (*Config) XXX_Size Uses

func (m *Config) XXX_Size() int

func (*Config) XXX_Unmarshal Uses

func (m *Config) XXX_Unmarshal(b []byte) error

type RedirectInstruction Uses

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"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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

func (*RedirectInstruction) Descriptor Uses

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

func (*RedirectInstruction) GetConstraint Uses

func (m *RedirectInstruction) GetConstraint() *TrafficConstraint

func (*RedirectInstruction) GetPercentOfRequests Uses

func (m *RedirectInstruction) GetPercentOfRequests() int32

func (*RedirectInstruction) ProtoMessage Uses

func (*RedirectInstruction) ProtoMessage()

func (*RedirectInstruction) Reset Uses

func (m *RedirectInstruction) Reset()

func (*RedirectInstruction) String Uses

func (m *RedirectInstruction) String() string

func (*RedirectInstruction) XXX_DiscardUnknown Uses

func (m *RedirectInstruction) XXX_DiscardUnknown()

func (*RedirectInstruction) XXX_Marshal Uses

func (m *RedirectInstruction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RedirectInstruction) XXX_Merge Uses

func (m *RedirectInstruction) XXX_Merge(src proto.Message)

func (*RedirectInstruction) XXX_Size Uses

func (m *RedirectInstruction) XXX_Size() int

func (*RedirectInstruction) XXX_Unmarshal Uses

func (m *RedirectInstruction) XXX_Unmarshal(b []byte) error

type TrafficConstraint Uses

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"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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 Uses

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

func (*TrafficConstraint) GetDutPool Uses

func (m *TrafficConstraint) GetDutPool() string

func (*TrafficConstraint) GetQuotaAccount Uses

func (m *TrafficConstraint) GetQuotaAccount() string

func (*TrafficConstraint) ProtoMessage Uses

func (*TrafficConstraint) ProtoMessage()

func (*TrafficConstraint) Reset Uses

func (m *TrafficConstraint) Reset()

func (*TrafficConstraint) String Uses

func (m *TrafficConstraint) String() string

func (*TrafficConstraint) XXX_DiscardUnknown Uses

func (m *TrafficConstraint) XXX_DiscardUnknown()

func (*TrafficConstraint) XXX_Marshal Uses

func (m *TrafficConstraint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TrafficConstraint) XXX_Merge Uses

func (m *TrafficConstraint) XXX_Merge(src proto.Message)

func (*TrafficConstraint) XXX_Size Uses

func (m *TrafficConstraint) XXX_Size() int

func (*TrafficConstraint) XXX_Unmarshal Uses

func (m *TrafficConstraint) XXX_Unmarshal(b []byte) error

Package test_runner imports 3 packages (graph) and is imported by 1 packages. Updated 2020-08-04. Refresh now. Tools for package owners.