blob: 4dd76d55f9cb9f6a8ba31005e9ae305588b60903 [file] [log] [blame]
// Code generated by protoc-gen-go. DO NOT EDIT.
// source: test_platform/multibot/leader_transitions.proto
package test_platform_multibot
import (
fmt "fmt"
proto ""
math "math"
// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf
// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
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
var LeaderTransitionMessage_LeaderState_name = map[int32]string{
var LeaderTransitionMessage_LeaderState_value = map[string]int32{
func (x LeaderTransitionMessage_LeaderState) String() string {
return proto.EnumName(LeaderTransitionMessage_LeaderState_name, int32(x))
func (LeaderTransitionMessage_LeaderState) EnumDescriptor() ([]byte, []int) {
return fileDescriptor_aa5d3a0268305501, []int{0, 0}
// LeaderTransitionMessage is used internally by the leader for all state
// transitions
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:"-"`
func (m *LeaderTransitionMessage) Reset() { *m = LeaderTransitionMessage{} }
func (m *LeaderTransitionMessage) String() string { return proto.CompactTextString(m) }
func (*LeaderTransitionMessage) ProtoMessage() {}
func (*LeaderTransitionMessage) Descriptor() ([]byte, []int) {
return fileDescriptor_aa5d3a0268305501, []int{0}
func (m *LeaderTransitionMessage) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_LeaderTransitionMessage.Unmarshal(m, b)
func (m *LeaderTransitionMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_LeaderTransitionMessage.Marshal(b, m, deterministic)
func (m *LeaderTransitionMessage) XXX_Merge(src proto.Message) {
xxx_messageInfo_LeaderTransitionMessage.Merge(m, src)
func (m *LeaderTransitionMessage) XXX_Size() int {
return xxx_messageInfo_LeaderTransitionMessage.Size(m)
func (m *LeaderTransitionMessage) XXX_DiscardUnknown() {
var xxx_messageInfo_LeaderTransitionMessage proto.InternalMessageInfo
func (m *LeaderTransitionMessage) GetNewState() LeaderTransitionMessage_LeaderState {
if m != nil {
return m.NewState
return LeaderTransitionMessage_STATE_UNDEFINED
func (m *LeaderTransitionMessage) GetFollowerGathering() *FollowersState {
if m != nil {
return m.FollowerGathering
return nil
// State of followers still needed and information about those already retrieved
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:"-"`
func (m *FollowersState) Reset() { *m = FollowersState{} }
func (m *FollowersState) String() string { return proto.CompactTextString(m) }
func (*FollowersState) ProtoMessage() {}
func (*FollowersState) Descriptor() ([]byte, []int) {
return fileDescriptor_aa5d3a0268305501, []int{1}
func (m *FollowersState) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_FollowersState.Unmarshal(m, b)
func (m *FollowersState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_FollowersState.Marshal(b, m, deterministic)
func (m *FollowersState) XXX_Merge(src proto.Message) {
xxx_messageInfo_FollowersState.Merge(m, src)
func (m *FollowersState) XXX_Size() int {
return xxx_messageInfo_FollowersState.Size(m)
func (m *FollowersState) XXX_DiscardUnknown() {
var xxx_messageInfo_FollowersState proto.InternalMessageInfo
func (m *FollowersState) GetWaitingForFollowers() int32 {
if m != nil {
return m.WaitingForFollowers
return 0
func (m *FollowersState) GetFollowersHeard() *HostInfoStore {
if m != nil {
return m.FollowersHeard
return nil
func init() {
proto.RegisterEnum("test_platform.multibot.LeaderTransitionMessage_LeaderState", LeaderTransitionMessage_LeaderState_name, LeaderTransitionMessage_LeaderState_value)
proto.RegisterType((*LeaderTransitionMessage)(nil), "test_platform.multibot.LeaderTransitionMessage")
proto.RegisterType((*FollowersState)(nil), "test_platform.multibot.FollowersState")
func init() {
proto.RegisterFile("test_platform/multibot/leader_transitions.proto", fileDescriptor_aa5d3a0268305501)
var fileDescriptor_aa5d3a0268305501 = []byte{
// 396 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x74, 0x92, 0xdf, 0x6e, 0x94, 0x40,
0x14, 0x87, 0x45, 0xa3, 0xd1, 0x69, 0x42, 0xc7, 0x69, 0xab, 0x5b, 0x8d, 0x71, 0xb3, 0x46, 0xd3,
0x2b, 0xd6, 0xac, 0x97, 0xde, 0x88, 0x05, 0x76, 0x31, 0x38, 0x34, 0xfc, 0x49, 0xed, 0xd5, 0x38,
0xb5, 0x03, 0x25, 0x81, 0x99, 0x66, 0x66, 0x0c, 0x6f, 0xe1, 0x95, 0x2f, 0xe4, 0x9b, 0x19, 0x18,
0x20, 0xd6, 0x94, 0x3b, 0x72, 0x7e, 0xe7, 0xfb, 0x4e, 0xce, 0x61, 0xc0, 0x5a, 0x33, 0xa5, 0xc9,
0x4d, 0x4d, 0x75, 0x21, 0x64, 0xb3, 0x6e, 0x7e, 0xd6, 0xba, 0xba, 0x14, 0x7a, 0x5d, 0x33, 0x7a,
0xc5, 0x24, 0xd1, 0x92, 0x72, 0x55, 0xe9, 0x4a, 0x70, 0xe5, 0xdc, 0x48, 0xa1, 0x05, 0x7a, 0x76,
0x0b, 0x70, 0x46, 0xe0, 0xc5, 0x9b, 0x19, 0xd1, 0x0f, 0xd1, 0x34, 0x82, 0x1b, 0x78, 0xf5, 0xeb,
0x01, 0x78, 0x1e, 0xf5, 0xe6, 0x6c, 0x12, 0x7f, 0x65, 0x4a, 0xd1, 0x92, 0xa1, 0x6f, 0xe0, 0x09,
0x67, 0x2d, 0x51, 0x9a, 0x6a, 0xb6, 0xb0, 0x96, 0xd6, 0x89, 0xbd, 0xf9, 0xe8, 0xdc, 0x3d, 0xcc,
0x99, 0x71, 0x0c, 0xf5, 0xb4, 0x53, 0x24, 0x8f, 0x39, 0x6b, 0xfb, 0x2f, 0x94, 0x03, 0x54, 0x88,
0xba, 0x16, 0x2d, 0x93, 0xa4, 0xa4, 0xfa, 0x9a, 0xc9, 0x8a, 0x97, 0x8b, 0xfb, 0x4b, 0xeb, 0x64,
0x6f, 0xf3, 0x6e, 0x6e, 0x44, 0x30, 0x10, 0xca, 0xd8, 0x9e, 0x8e, 0x86, 0xed, 0x28, 0x58, 0xfd,
0xb1, 0xc0, 0xde, 0x3f, 0x03, 0xd1, 0x01, 0xd8, 0x4f, 0x33, 0x37, 0xf3, 0x49, 0x8e, 0x3d, 0x3f,
0x08, 0xb1, 0xef, 0xc1, 0x7b, 0xe8, 0x10, 0x40, 0x53, 0x4c, 0x4f, 0x77, 0xbe, 0x97, 0x47, 0x21,
0xde, 0x42, 0x88, 0x16, 0xe0, 0xd0, 0x54, 0x93, 0x1c, 0xe3, 0x10, 0x6f, 0xc9, 0x59, 0xe2, 0x7f,
0x89, 0x3f, 0xc3, 0x25, 0x7a, 0x0d, 0x5e, 0x9a, 0xe4, 0xdc, 0x0d, 0xb3, 0x2e, 0x09, 0xe2, 0x84,
0x04, 0x71, 0x14, 0xc5, 0xe7, 0x7e, 0x92, 0xc2, 0xf7, 0xe8, 0x15, 0x38, 0x36, 0x0d, 0x38, 0xce,
0xc2, 0xe0, 0xc2, 0xb4, 0x8c, 0xf1, 0x27, 0x74, 0x0c, 0x8e, 0xfe, 0x33, 0xbb, 0x17, 0x51, 0xec,
0x7a, 0xf0, 0x0c, 0x21, 0x60, 0x9b, 0xe8, 0x34, 0xf2, 0xdd, 0x2e, 0x83, 0xdf, 0x57, 0xbf, 0x2d,
0x60, 0xdf, 0xde, 0x14, 0x6d, 0xc0, 0x51, 0x4b, 0x2b, 0x5d, 0xf1, 0x92, 0x14, 0x42, 0x92, 0x71,
0x6f, 0xd5, 0xff, 0x93, 0x87, 0xc9, 0xc1, 0x10, 0x06, 0x42, 0x4e, 0x20, 0xc2, 0x60, 0x7f, 0xea,
0x23, 0xd7, 0x8c, 0xca, 0xab, 0xe1, 0xbc, 0x6f, 0xe7, 0xce, 0xbb, 0x13, 0x4a, 0x87, 0xbc, 0x10,
0xa9, 0x16, 0x92, 0x25, 0xf6, 0x44, 0xef, 0x3a, 0xf8, 0xf2, 0x51, 0xff, 0x5c, 0x3e, 0xfc, 0x0d,
0x00, 0x00, 0xff, 0xff, 0x01, 0x21, 0x87, 0x78, 0x9e, 0x02, 0x00, 0x00,