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

package test_platform_multibot

import "go.chromium.org/chromiumos/infra/proto/go/test_platform/multibot"

Index

Package Files

common.pb.go follower_transitions.pb.go leader_transitions.pb.go requests.pb.go

Variables

var FollowerStateChange_FollowerState_name = map[int32]string{
    0:  "STATE_UNDEFINED",
    16: "STATE_STARTED",
    32: "STATE_WAITING_TO_RUN_PAYLOAD",
    48: "STATE_RUNNING_PAYLOAD",
    64: "STATE_CLEANING",
}
var FollowerStateChange_FollowerState_value = map[string]int32{
    "STATE_UNDEFINED":              0,
    "STATE_STARTED":                16,
    "STATE_WAITING_TO_RUN_PAYLOAD": 32,
    "STATE_RUNNING_PAYLOAD":        48,
    "STATE_CLEANING":               64,
}
var LeaderTransitionMessage_LeaderState_name = map[int32]string{
    0:  "STATE_UNDEFINED",
    16: "STATE_SCHEDULING",
    32: "STATE_RUNNING_PREJOB",
    48: "STATE_WAITING_FOR_FOLLOWERS",
    64: "STATE_NOTIFYING_FOLLOWERS",
    80: "STATE_RUNNING_PAYLOAD",
    96: "STATE_CLEANING",
}
var LeaderTransitionMessage_LeaderState_value = map[string]int32{
    "STATE_UNDEFINED":             0,
    "STATE_SCHEDULING":            16,
    "STATE_RUNNING_PREJOB":        32,
    "STATE_WAITING_FOR_FOLLOWERS": 48,
    "STATE_NOTIFYING_FOLLOWERS":   64,
    "STATE_RUNNING_PAYLOAD":       80,
    "STATE_CLEANING":              96,
}

type FollowerEvent Uses

type FollowerEvent struct {
    // Types that are valid to be assigned to Event:
    //	*FollowerEvent_FinishedPrejob_
    //	*FollowerEvent_Died
    Event                isFollowerEvent_Event `protobuf_oneof:"event"`
    XXX_NoUnkeyedLiteral struct{}              `json:"-"`
    XXX_unrecognized     []byte                `json:"-"`
    XXX_sizecache        int32                 `json:"-"`
}

FollowerEvent is sent over the multibot Follower->Leader channel, to carry follower event information. The leader may use this to change state, depending on leader-specific logic and its internal state.

func (*FollowerEvent) Descriptor Uses

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

func (*FollowerEvent) GetDied Uses

func (m *FollowerEvent) GetDied() bool

func (*FollowerEvent) GetEvent Uses

func (m *FollowerEvent) GetEvent() isFollowerEvent_Event

func (*FollowerEvent) GetFinishedPrejob Uses

func (m *FollowerEvent) GetFinishedPrejob() *FollowerEvent_FinishedPrejob

func (*FollowerEvent) ProtoMessage Uses

func (*FollowerEvent) ProtoMessage()

func (*FollowerEvent) Reset Uses

func (m *FollowerEvent) Reset()

func (*FollowerEvent) String Uses

func (m *FollowerEvent) String() string

func (*FollowerEvent) XXX_DiscardUnknown Uses

func (m *FollowerEvent) XXX_DiscardUnknown()

func (*FollowerEvent) XXX_Marshal Uses

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

func (*FollowerEvent) XXX_Merge Uses

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

func (*FollowerEvent) XXX_OneofWrappers Uses

func (*FollowerEvent) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*FollowerEvent) XXX_Size Uses

func (m *FollowerEvent) XXX_Size() int

func (*FollowerEvent) XXX_Unmarshal Uses

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

type FollowerEvent_Died Uses

type FollowerEvent_Died struct {
    Died bool `protobuf:"varint,2,opt,name=died,proto3,oneof"`
}

type FollowerEvent_FinishedPrejob Uses

type FollowerEvent_FinishedPrejob struct {
    HostInfo             *skylab_local_state.MultiBotHostInfo `protobuf:"bytes,1,opt,name=host_info,json=hostInfo,proto3" json:"host_info,omitempty"`
    XXX_NoUnkeyedLiteral struct{}                             `json:"-"`
    XXX_unrecognized     []byte                               `json:"-"`
    XXX_sizecache        int32                                `json:"-"`
}

func (*FollowerEvent_FinishedPrejob) Descriptor Uses

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

func (*FollowerEvent_FinishedPrejob) GetHostInfo Uses

func (m *FollowerEvent_FinishedPrejob) GetHostInfo() *skylab_local_state.MultiBotHostInfo

func (*FollowerEvent_FinishedPrejob) ProtoMessage Uses

func (*FollowerEvent_FinishedPrejob) ProtoMessage()

func (*FollowerEvent_FinishedPrejob) Reset Uses

func (m *FollowerEvent_FinishedPrejob) Reset()

func (*FollowerEvent_FinishedPrejob) String Uses

func (m *FollowerEvent_FinishedPrejob) String() string

func (*FollowerEvent_FinishedPrejob) XXX_DiscardUnknown Uses

func (m *FollowerEvent_FinishedPrejob) XXX_DiscardUnknown()

func (*FollowerEvent_FinishedPrejob) XXX_Marshal Uses

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

func (*FollowerEvent_FinishedPrejob) XXX_Merge Uses

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

func (*FollowerEvent_FinishedPrejob) XXX_Size Uses

func (m *FollowerEvent_FinishedPrejob) XXX_Size() int

func (*FollowerEvent_FinishedPrejob) XXX_Unmarshal Uses

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

type FollowerEvent_FinishedPrejob_ Uses

type FollowerEvent_FinishedPrejob_ struct {
    FinishedPrejob *FollowerEvent_FinishedPrejob `protobuf:"bytes,1,opt,name=finished_prejob,json=finishedPrejob,proto3,oneof"`
}

type FollowerRequest Uses

type FollowerRequest struct {
    // Pubsub subscription to use for this follower task (pre-existing)
    SubscriptionName string `protobuf:"bytes,1,opt,name=subscription_name,json=subscriptionName,proto3" json:"subscription_name,omitempty"`
    // Attribute filter to apply to judge whether incoming messages are 'for you'
    IncomingFilter map[string]string `protobuf:"bytes,2,rep,name=incoming_filter,json=incomingFilter,proto3" json:"incoming_filter,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // Attributes to apply to outgoing messages to address them to the leader
    OutgoingAttributes map[string]string `protobuf:"bytes,3,rep,name=outgoing_attributes,json=outgoingAttributes,proto3" json:"outgoing_attributes,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // Prejob request parameters
    Prejob               *phosphorus.PrejobRequest `protobuf:"bytes,4,opt,name=prejob,proto3" json:"prejob,omitempty"`
    XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
    XXX_unrecognized     []byte                    `json:"-"`
    XXX_sizecache        int32                     `json:"-"`
}

Internal per-bot request for follower task

func (*FollowerRequest) Descriptor Uses

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

func (*FollowerRequest) GetIncomingFilter Uses

func (m *FollowerRequest) GetIncomingFilter() map[string]string

func (*FollowerRequest) GetOutgoingAttributes Uses

func (m *FollowerRequest) GetOutgoingAttributes() map[string]string

func (*FollowerRequest) GetPrejob Uses

func (m *FollowerRequest) GetPrejob() *phosphorus.PrejobRequest

func (*FollowerRequest) GetSubscriptionName Uses

func (m *FollowerRequest) GetSubscriptionName() string

func (*FollowerRequest) ProtoMessage Uses

func (*FollowerRequest) ProtoMessage()

func (*FollowerRequest) Reset Uses

func (m *FollowerRequest) Reset()

func (*FollowerRequest) String Uses

func (m *FollowerRequest) String() string

func (*FollowerRequest) XXX_DiscardUnknown Uses

func (m *FollowerRequest) XXX_DiscardUnknown()

func (*FollowerRequest) XXX_Marshal Uses

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

func (*FollowerRequest) XXX_Merge Uses

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

func (*FollowerRequest) XXX_Size Uses

func (m *FollowerRequest) XXX_Size() int

func (*FollowerRequest) XXX_Unmarshal Uses

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

type FollowerSpec Uses

type FollowerSpec struct {
    StaticAttributes *FollowerSpec_StaticAttributes `protobuf:"bytes,1,opt,name=static_attributes,json=staticAttributes,proto3" json:"static_attributes,omitempty"`
    // Prejob work required, primarily provisionable attributes to ensure
    Prejob *skylab_test_runner.Request_Prejob `protobuf:"bytes,2,opt,name=prejob,proto3" json:"prejob,omitempty"`
    // Number of followers with these attributes, default to 1.
    Count                int32    `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

FollowerSpec contains the provisionable and nonprovisionable attributes for a follower swarming task.

func (*FollowerSpec) Descriptor Uses

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

func (*FollowerSpec) GetCount Uses

func (m *FollowerSpec) GetCount() int32

func (*FollowerSpec) GetPrejob Uses

func (m *FollowerSpec) GetPrejob() *skylab_test_runner.Request_Prejob

func (*FollowerSpec) GetStaticAttributes Uses

func (m *FollowerSpec) GetStaticAttributes() *FollowerSpec_StaticAttributes

func (*FollowerSpec) ProtoMessage Uses

func (*FollowerSpec) ProtoMessage()

func (*FollowerSpec) Reset Uses

func (m *FollowerSpec) Reset()

func (*FollowerSpec) String Uses

func (m *FollowerSpec) String() string

func (*FollowerSpec) XXX_DiscardUnknown Uses

func (m *FollowerSpec) XXX_DiscardUnknown()

func (*FollowerSpec) XXX_Marshal Uses

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

func (*FollowerSpec) XXX_Merge Uses

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

func (*FollowerSpec) XXX_Size Uses

func (m *FollowerSpec) XXX_Size() int

func (*FollowerSpec) XXX_Unmarshal Uses

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

type FollowerSpec_StaticAttributes Uses

type FollowerSpec_StaticAttributes struct {
    HardwareAttributes   *test_platform.Request_Params_HardwareAttributes `protobuf:"bytes,1,opt,name=hardware_attributes,json=hardwareAttributes,proto3" json:"hardware_attributes,omitempty"`
    SoftwareAttributes   *test_platform.Request_Params_SoftwareAttributes `protobuf:"bytes,2,opt,name=software_attributes,json=softwareAttributes,proto3" json:"software_attributes,omitempty"`
    XXX_NoUnkeyedLiteral struct{}                                         `json:"-"`
    XXX_unrecognized     []byte                                           `json:"-"`
    XXX_sizecache        int32                                            `json:"-"`
}

Nonprovisionable labels for followers

func (*FollowerSpec_StaticAttributes) Descriptor Uses

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

func (*FollowerSpec_StaticAttributes) GetHardwareAttributes Uses

func (m *FollowerSpec_StaticAttributes) GetHardwareAttributes() *test_platform.Request_Params_HardwareAttributes

func (*FollowerSpec_StaticAttributes) GetSoftwareAttributes Uses

func (m *FollowerSpec_StaticAttributes) GetSoftwareAttributes() *test_platform.Request_Params_SoftwareAttributes

func (*FollowerSpec_StaticAttributes) ProtoMessage Uses

func (*FollowerSpec_StaticAttributes) ProtoMessage()

func (*FollowerSpec_StaticAttributes) Reset Uses

func (m *FollowerSpec_StaticAttributes) Reset()

func (*FollowerSpec_StaticAttributes) String Uses

func (m *FollowerSpec_StaticAttributes) String() string

func (*FollowerSpec_StaticAttributes) XXX_DiscardUnknown Uses

func (m *FollowerSpec_StaticAttributes) XXX_DiscardUnknown()

func (*FollowerSpec_StaticAttributes) XXX_Marshal Uses

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

func (*FollowerSpec_StaticAttributes) XXX_Merge Uses

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

func (*FollowerSpec_StaticAttributes) XXX_Size Uses

func (m *FollowerSpec_StaticAttributes) XXX_Size() int

func (*FollowerSpec_StaticAttributes) XXX_Unmarshal Uses

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

type FollowerStateChange Uses

type FollowerStateChange struct {
    NewState             FollowerStateChange_FollowerState `protobuf:"varint,1,opt,name=new_state,json=newState,proto3,enum=test_platform.multibot.FollowerStateChange_FollowerState" json:"new_state,omitempty"`
    XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
    XXX_unrecognized     []byte                            `json:"-"`
    XXX_sizecache        int32                             `json:"-"`
}

FollowerStateChange is sent over the multibot Leader->Follower channel, to carry state change information. The follower will only respect forward state changes. The same message is used internally between follower states.

func (*FollowerStateChange) Descriptor Uses

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

func (*FollowerStateChange) GetNewState Uses

func (m *FollowerStateChange) GetNewState() FollowerStateChange_FollowerState

func (*FollowerStateChange) ProtoMessage Uses

func (*FollowerStateChange) ProtoMessage()

func (*FollowerStateChange) Reset Uses

func (m *FollowerStateChange) Reset()

func (*FollowerStateChange) String Uses

func (m *FollowerStateChange) String() string

func (*FollowerStateChange) XXX_DiscardUnknown Uses

func (m *FollowerStateChange) XXX_DiscardUnknown()

func (*FollowerStateChange) XXX_Marshal Uses

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

func (*FollowerStateChange) XXX_Merge Uses

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

func (*FollowerStateChange) XXX_Size Uses

func (m *FollowerStateChange) XXX_Size() int

func (*FollowerStateChange) XXX_Unmarshal Uses

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

type FollowerStateChange_FollowerState Uses

type FollowerStateChange_FollowerState int32
const (
    FollowerStateChange_STATE_UNDEFINED FollowerStateChange_FollowerState = 0
    // Follower task has started executing. Note: follower will enter this state
    // automatically once it starts.
    FollowerStateChange_STATE_STARTED FollowerStateChange_FollowerState = 16
    // Follower task is waiting; payload has not started running.
    // Note: follower will enter this state automatically after finishing
    // prejob work and informing leader.
    FollowerStateChange_STATE_WAITING_TO_RUN_PAYLOAD FollowerStateChange_FollowerState = 32
    // Follower task is waiting; payload is running on leader.
    FollowerStateChange_STATE_RUNNING_PAYLOAD FollowerStateChange_FollowerState = 48
    // Follower task is running any necessary cleanup, after which it will
    // terminate.
    FollowerStateChange_STATE_CLEANING FollowerStateChange_FollowerState = 64
)

func (FollowerStateChange_FollowerState) EnumDescriptor Uses

func (FollowerStateChange_FollowerState) EnumDescriptor() ([]byte, []int)

func (FollowerStateChange_FollowerState) String Uses

func (x FollowerStateChange_FollowerState) String() string

type FollowersState Uses

type FollowersState struct {
    // Number of follower tasks the leader is still waiting for
    WaitingForFollowers  int32          `protobuf:"varint,1,opt,name=waiting_for_followers,json=waitingForFollowers,proto3" json:"waiting_for_followers,omitempty"`
    FollowersHeard       *HostInfoStore `protobuf:"bytes,2,opt,name=followers_heard,json=followersHeard,proto3" json:"followers_heard,omitempty"`
    XXX_NoUnkeyedLiteral struct{}       `json:"-"`
    XXX_unrecognized     []byte         `json:"-"`
    XXX_sizecache        int32          `json:"-"`
}

State of followers still needed and information about those already retrieved

func (*FollowersState) Descriptor Uses

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

func (*FollowersState) GetFollowersHeard Uses

func (m *FollowersState) GetFollowersHeard() *HostInfoStore

func (*FollowersState) GetWaitingForFollowers Uses

func (m *FollowersState) GetWaitingForFollowers() int32

func (*FollowersState) ProtoMessage Uses

func (*FollowersState) ProtoMessage()

func (*FollowersState) Reset Uses

func (m *FollowersState) Reset()

func (*FollowersState) String Uses

func (m *FollowersState) String() string

func (*FollowersState) XXX_DiscardUnknown Uses

func (m *FollowersState) XXX_DiscardUnknown()

func (*FollowersState) XXX_Marshal Uses

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

func (*FollowersState) XXX_Merge Uses

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

func (*FollowersState) XXX_Size Uses

func (m *FollowersState) XXX_Size() int

func (*FollowersState) XXX_Unmarshal Uses

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

type HostInfoStore Uses

type HostInfoStore struct {
    HostInfos            map[string]*skylab_local_state.AutotestHostInfo `protobuf:"bytes,1,rep,name=host_infos,json=hostInfos,proto3" json:"host_infos,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    XXX_NoUnkeyedLiteral struct{}                                        `json:"-"`
    XXX_unrecognized     []byte                                          `json:"-"`
    XXX_sizecache        int32                                           `json:"-"`
}

HostInfoStore stores Autotest host info blobs keyed by DUT name

func (*HostInfoStore) Descriptor Uses

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

func (*HostInfoStore) GetHostInfos Uses

func (m *HostInfoStore) GetHostInfos() map[string]*skylab_local_state.AutotestHostInfo

func (*HostInfoStore) ProtoMessage Uses

func (*HostInfoStore) ProtoMessage()

func (*HostInfoStore) Reset Uses

func (m *HostInfoStore) Reset()

func (*HostInfoStore) String Uses

func (m *HostInfoStore) String() string

func (*HostInfoStore) XXX_DiscardUnknown Uses

func (m *HostInfoStore) XXX_DiscardUnknown()

func (*HostInfoStore) XXX_Marshal Uses

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

func (*HostInfoStore) XXX_Merge Uses

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

func (*HostInfoStore) XXX_Size Uses

func (m *HostInfoStore) XXX_Size() int

func (*HostInfoStore) XXX_Unmarshal Uses

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

type LeaderRequest Uses

type LeaderRequest struct {
    // What test to run with the multi-bot task
    Payload *test_platform.Request_Test `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
    // What attributes to require and provision for follower tasks
    FollowerSpecs        []*FollowerSpec `protobuf:"bytes,2,rep,name=follower_specs,json=followerSpecs,proto3" json:"follower_specs,omitempty"`
    XXX_NoUnkeyedLiteral struct{}        `json:"-"`
    XXX_unrecognized     []byte          `json:"-"`
    XXX_sizecache        int32           `json:"-"`
}

External API for requesting a multi-bot job

func (*LeaderRequest) Descriptor Uses

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

func (*LeaderRequest) GetFollowerSpecs Uses

func (m *LeaderRequest) GetFollowerSpecs() []*FollowerSpec

func (*LeaderRequest) GetPayload Uses

func (m *LeaderRequest) GetPayload() *test_platform.Request_Test

func (*LeaderRequest) ProtoMessage Uses

func (*LeaderRequest) ProtoMessage()

func (*LeaderRequest) Reset Uses

func (m *LeaderRequest) Reset()

func (*LeaderRequest) String Uses

func (m *LeaderRequest) String() string

func (*LeaderRequest) XXX_DiscardUnknown Uses

func (m *LeaderRequest) XXX_DiscardUnknown()

func (*LeaderRequest) XXX_Marshal Uses

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

func (*LeaderRequest) XXX_Merge Uses

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

func (*LeaderRequest) XXX_Size Uses

func (m *LeaderRequest) XXX_Size() int

func (*LeaderRequest) XXX_Unmarshal Uses

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

type LeaderTransitionMessage Uses

type LeaderTransitionMessage struct {
    NewState LeaderTransitionMessage_LeaderState `protobuf:"varint,1,opt,name=new_state,json=newState,proto3,enum=test_platform.multibot.LeaderTransitionMessage_LeaderState" json:"new_state,omitempty"`
    // Used only for the Waiting for Followers steps, contains the number of
    // followers still required and all gathered info for the ones already seen
    FollowerGathering    *FollowersState `protobuf:"bytes,2,opt,name=follower_gathering,json=followerGathering,proto3" json:"follower_gathering,omitempty"`
    XXX_NoUnkeyedLiteral struct{}        `json:"-"`
    XXX_unrecognized     []byte          `json:"-"`
    XXX_sizecache        int32           `json:"-"`
}

LeaderTransitionMessage is used internally by the leader for all state transitions

func (*LeaderTransitionMessage) Descriptor Uses

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

func (*LeaderTransitionMessage) GetFollowerGathering Uses

func (m *LeaderTransitionMessage) GetFollowerGathering() *FollowersState

func (*LeaderTransitionMessage) GetNewState Uses

func (m *LeaderTransitionMessage) GetNewState() LeaderTransitionMessage_LeaderState

func (*LeaderTransitionMessage) ProtoMessage Uses

func (*LeaderTransitionMessage) ProtoMessage()

func (*LeaderTransitionMessage) Reset Uses

func (m *LeaderTransitionMessage) Reset()

func (*LeaderTransitionMessage) String Uses

func (m *LeaderTransitionMessage) String() string

func (*LeaderTransitionMessage) XXX_DiscardUnknown Uses

func (m *LeaderTransitionMessage) XXX_DiscardUnknown()

func (*LeaderTransitionMessage) XXX_Marshal Uses

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

func (*LeaderTransitionMessage) XXX_Merge Uses

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

func (*LeaderTransitionMessage) XXX_Size Uses

func (m *LeaderTransitionMessage) XXX_Size() int

func (*LeaderTransitionMessage) XXX_Unmarshal Uses

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

type LeaderTransitionMessage_LeaderState Uses

type LeaderTransitionMessage_LeaderState int32
const (
    LeaderTransitionMessage_STATE_UNDEFINED LeaderTransitionMessage_LeaderState = 0
    // Leader task has started executing and scheduling followers.
    LeaderTransitionMessage_STATE_SCHEDULING LeaderTransitionMessage_LeaderState = 16
    // Leader task is executing prejob work
    LeaderTransitionMessage_STATE_RUNNING_PREJOB LeaderTransitionMessage_LeaderState = 32
    // Leader task is waiting and collection host info from follower tasks
    LeaderTransitionMessage_STATE_WAITING_FOR_FOLLOWERS LeaderTransitionMessage_LeaderState = 48
    // Leader task is sending 'Payload Ready' messages to followers. It will
    // automatically enter this state when it has gathered all host info and
    // automatically exits it after sending the message.
    LeaderTransitionMessage_STATE_NOTIFYING_FOLLOWERS LeaderTransitionMessage_LeaderState = 64
    // Leader task is running payload; followers are waiting.
    LeaderTransitionMessage_STATE_RUNNING_PAYLOAD LeaderTransitionMessage_LeaderState = 80
    // Leader task is running any necessary cleanup, after which it will
    // terminate.
    LeaderTransitionMessage_STATE_CLEANING LeaderTransitionMessage_LeaderState = 96
)

func (LeaderTransitionMessage_LeaderState) EnumDescriptor Uses

func (LeaderTransitionMessage_LeaderState) EnumDescriptor() ([]byte, []int)

func (LeaderTransitionMessage_LeaderState) String Uses

func (x LeaderTransitionMessage_LeaderState) String() string

type MultiBotConfig Uses

type MultiBotConfig struct {
    // Pub/Sub topic name
    Topic                string   `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Stable configuration settings needed for multi-bot tasks, shared by leader and followers

func (*MultiBotConfig) Descriptor Uses

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

func (*MultiBotConfig) GetTopic Uses

func (m *MultiBotConfig) GetTopic() string

func (*MultiBotConfig) ProtoMessage Uses

func (*MultiBotConfig) ProtoMessage()

func (*MultiBotConfig) Reset Uses

func (m *MultiBotConfig) Reset()

func (*MultiBotConfig) String Uses

func (m *MultiBotConfig) String() string

func (*MultiBotConfig) XXX_DiscardUnknown Uses

func (m *MultiBotConfig) XXX_DiscardUnknown()

func (*MultiBotConfig) XXX_Marshal Uses

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

func (*MultiBotConfig) XXX_Merge Uses

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

func (*MultiBotConfig) XXX_Size Uses

func (m *MultiBotConfig) XXX_Size() int

func (*MultiBotConfig) XXX_Unmarshal Uses

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

Package test_platform_multibot imports 7 packages (graph). Updated 2019-11-19. Refresh now. Tools for package owners.