multibot

type FollowerEvent struct {

	// Types that are assignable to Event:
	//	*FollowerEvent_FinishedPrejob_
	//	*FollowerEvent_Died
	Event isFollowerEvent_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

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

type FollowerEvent_FinishedPrejob struct {
	HostInfo *skylab_local_state.MultiBotHostInfo `protobuf:"bytes,1,opt,name=host_info,json=hostInfo,proto3" json:"host_info,omitempty"`
	// contains filtered or unexported fields
}

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

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 `` /* 191-byte string literal not displayed */
	// Attributes to apply to outgoing messages to address them to the leader
	OutgoingAttributes map[string]string `` /* 203-byte string literal not displayed */
	// Prejob request parameters
	Prejob *phosphorus.PrejobRequest `protobuf:"bytes,4,opt,name=prejob,proto3" json:"prejob,omitempty"`
	// contains filtered or unexported fields
}

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"`
	// contains filtered or unexported fields
}

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"`
	// contains filtered or unexported fields
}

type FollowerStateChange struct {
	NewState FollowerStateChange_FollowerState `` /* 148-byte string literal not displayed */
	// contains filtered or unexported fields
}

type FollowerStateChange_FollowerState int32

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"`
	// contains filtered or unexported fields
}

type HostInfoStore struct {
	HostInfos map[string]*skylab_local_state.AutotestHostInfo `` /* 176-byte string literal not displayed */
	// contains filtered or unexported fields
}

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"`
	// contains filtered or unexported fields
}

type LeaderTransitionMessage struct {
	NewState LeaderTransitionMessage_LeaderState `` /* 150-byte string literal not displayed */
	// 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"`
	// contains filtered or unexported fields
}

type LeaderTransitionMessage_LeaderState int32

type MultiBotConfig struct {

	// Pub/Sub topic name
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// contains filtered or unexported fields
}