pb

type BeamInfo struct {
	StableBeamsStart  int64    `protobuf:"varint,1,opt,name=stableBeamsStart,proto3" json:"stableBeamsStart,omitempty"`  // milliseconds since epoch when stable beams started
	StableBeamsEnd    int64    `protobuf:"varint,2,opt,name=stableBeamsEnd,proto3" json:"stableBeamsEnd,omitempty"`      // milliseconds since epoch when stable beams ended
	FillNumber        int32    `protobuf:"varint,3,opt,name=fillNumber,proto3" json:"fillNumber,omitempty"`              // LHC fill number
	FillingSchemeName string   `protobuf:"bytes,4,opt,name=fillingSchemeName,proto3" json:"fillingSchemeName,omitempty"` // LHC filling scheme name e.g. 25ns_2460b_2448_2089_2227_144bpi_20inj
	BeamType          string   `protobuf:"bytes,5,opt,name=beamType,proto3" json:"beamType,omitempty"`                   // e.g. PROTON-PROTON, O8-O8, Pb-Pb, p-Pb, Pb-p
	BeamMode          BeamMode `protobuf:"varint,6,opt,name=beamMode,proto3,enum=common.BeamMode" json:"beamMode,omitempty"`
	// contains filtered or unexported fields
}

type BeamMode int32

type Ev_BeamModeEvent struct {
	Timestamp int64     `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // milliseconds since epoch when the beam mode change happened
	BeamInfo  *BeamInfo `protobuf:"bytes,2,opt,name=beamInfo,proto3" json:"beamInfo,omitempty"`
	// contains filtered or unexported fields
}

type Ev_CallEvent struct {
	Func          string   `protobuf:"bytes,1,opt,name=func,proto3" json:"func,omitempty"`                                   // name of the function being called, within the workflow template context
	CallStatus    OpStatus `protobuf:"varint,2,opt,name=callStatus,proto3,enum=events.OpStatus" json:"callStatus,omitempty"` // progress or success/failure state of the call
	Return        string   `protobuf:"bytes,3,opt,name=return,proto3" json:"return,omitempty"`                               // return value of the function
	Traits        *Traits  `protobuf:"bytes,4,opt,name=traits,proto3" json:"traits,omitempty"`
	Output        string   `protobuf:"bytes,5,opt,name=output,proto3" json:"output,omitempty"` // any additional output of the function
	Error         string   `protobuf:"bytes,6,opt,name=error,proto3" json:"error,omitempty"`   // error value, if returned
	EnvironmentId string   `protobuf:"bytes,7,opt,name=environmentId,proto3" json:"environmentId,omitempty"`
	Path          string   `protobuf:"bytes,8,opt,name=path,proto3" json:"path,omitempty"` // path to the parent callRole of this call within the environment
	// contains filtered or unexported fields
}

type Ev_EnvironmentEvent struct {
	EnvironmentId    string            `protobuf:"bytes,1,opt,name=environmentId,proto3" json:"environmentId,omitempty"`
	State            string            `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
	RunNumber        uint32            `protobuf:"varint,3,opt,name=runNumber,proto3" json:"runNumber,omitempty"` // only when the environment is in the running state
	Error            string            `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	Message          string            `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"` // any additional message concerning the current state or transition
	Transition       string            `protobuf:"bytes,6,opt,name=transition,proto3" json:"transition,omitempty"`
	TransitionStep   string            `protobuf:"bytes,7,opt,name=transitionStep,proto3" json:"transitionStep,omitempty"`
	TransitionStatus OpStatus          `protobuf:"varint,8,opt,name=transitionStatus,proto3,enum=events.OpStatus" json:"transitionStatus,omitempty"`
	Vars             map[string]string `` // consolidated environment variables at the root role of the environment
	/* 149-byte string literal not displayed */
	LastRequestUser      *User                 `protobuf:"bytes,10,opt,name=lastRequestUser,proto3" json:"lastRequestUser,omitempty"`
	WorkflowTemplateInfo *WorkflowTemplateInfo `protobuf:"bytes,11,opt,name=workflowTemplateInfo,proto3" json:"workflowTemplateInfo,omitempty"`
	// contains filtered or unexported fields
}

type Ev_IntegratedServiceEvent struct {
	Name                string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`                                                     // name of the context, usually the path of the callRole that calls a given integrated service function e.g. readout-dataflow.dd-scheduler.terminate
	Error               string   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`                                                   // error message, if any
	OperationName       string   `protobuf:"bytes,3,opt,name=operationName,proto3" json:"operationName,omitempty"`                                   // name of the operation, usually the name of the integrated service function being called e.g. ddsched.PartitionTerminate()"
	OperationStatus     OpStatus `protobuf:"varint,4,opt,name=operationStatus,proto3,enum=events.OpStatus" json:"operationStatus,omitempty"`         // progress or success/failure state of the operation
	OperationStep       string   `protobuf:"bytes,5,opt,name=operationStep,proto3" json:"operationStep,omitempty"`                                   // if the operation has substeps, this is the name of the current substep, like an API call or polling phase
	OperationStepStatus OpStatus `protobuf:"varint,6,opt,name=operationStepStatus,proto3,enum=events.OpStatus" json:"operationStepStatus,omitempty"` // progress or success/failure state of the current substep
	EnvironmentId       string   `protobuf:"bytes,7,opt,name=environmentId,proto3" json:"environmentId,omitempty"`
	Payload             string   `protobuf:"bytes,8,opt,name=payload,proto3" json:"payload,omitempty"` // any additional payload, depending on the integrated service; there is no schema, it can even be the raw return structure of a remote API call
	// contains filtered or unexported fields
}

type Ev_MetaEvent_CoreStart struct {
	FrameworkId string `protobuf:"bytes,1,opt,name=frameworkId,proto3" json:"frameworkId,omitempty"`
	// contains filtered or unexported fields
}

type Ev_MetaEvent_FrameworkEvent struct {
	FrameworkId string `protobuf:"bytes,1,opt,name=frameworkId,proto3" json:"frameworkId,omitempty"`
	Message     string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type Ev_MetaEvent_MesosHeartbeat struct {
	// contains filtered or unexported fields
}

type Ev_RoleEvent struct {
	Name          string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`         // role name
	Status        string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`     // posible values: ACTIVE/INACTIVE/PARTIAL/UNDEFINED/UNDEPLOYABLE as defined in status.go. Derived from the state of child tasks, calls or other roles
	State         string `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`       // state machine state for this role
	RolePath      string `protobuf:"bytes,4,opt,name=rolePath,proto3" json:"rolePath,omitempty"` // path to this role within the environment
	EnvironmentId string `protobuf:"bytes,5,opt,name=environmentId,proto3" json:"environmentId,omitempty"`
	// contains filtered or unexported fields
}

type Ev_RunEvent struct {
	EnvironmentId    string   `protobuf:"bytes,1,opt,name=environmentId,proto3" json:"environmentId,omitempty"`
	RunNumber        uint32   `protobuf:"varint,2,opt,name=runNumber,proto3" json:"runNumber,omitempty"`
	State            string   `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`
	Error            string   `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	Transition       string   `protobuf:"bytes,5,opt,name=transition,proto3" json:"transition,omitempty"`
	TransitionStatus OpStatus `protobuf:"varint,6,opt,name=transitionStatus,proto3,enum=events.OpStatus" json:"transitionStatus,omitempty"`
	LastRequestUser  *User    `protobuf:"bytes,8,opt,name=lastRequestUser,proto3" json:"lastRequestUser,omitempty"`
	// contains filtered or unexported fields
}

type Ev_TaskEvent struct {
	Name          string  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`     // task name, based on the name of the task class
	Taskid        string  `protobuf:"bytes,2,opt,name=taskid,proto3" json:"taskid,omitempty"` // task id, unique
	State         string  `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`   // state machine state for this task
	Status        string  `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"` // posible values: ACTIVE/INACTIVE/PARTIAL/UNDEFINED/UNDEPLOYABLE as defined in status.go.
	Hostname      string  `protobuf:"bytes,5,opt,name=hostname,proto3" json:"hostname,omitempty"`
	ClassName     string  `protobuf:"bytes,6,opt,name=className,proto3" json:"className,omitempty"` // name of the task class from which this task was spawned
	Traits        *Traits `protobuf:"bytes,7,opt,name=traits,proto3" json:"traits,omitempty"`
	EnvironmentId string  `protobuf:"bytes,8,opt,name=environmentId,proto3" json:"environmentId,omitempty"`
	Path          string  `protobuf:"bytes,9,opt,name=path,proto3" json:"path,omitempty"` // path to the parent taskRole of this task within the environment
	// contains filtered or unexported fields
}

type Event struct {
	Timestamp     int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	TimestampNano int64 `protobuf:"varint,2,opt,name=timestampNano,proto3" json:"timestampNano,omitempty"`
	// Types that are assignable to Payload:
	//
	//	*Event_EnvironmentEvent
	//	*Event_TaskEvent
	//	*Event_RoleEvent
	//	*Event_CallEvent
	//	*Event_IntegratedServiceEvent
	//	*Event_RunEvent
	//	*Event_FrameworkEvent
	//	*Event_MesosHeartbeatEvent
	//	*Event_CoreStartEvent
	//	*Event_BeamModeEvent
	Payload isEvent_Payload `protobuf_oneof:"Payload"`
	// contains filtered or unexported fields
}

type Event_BeamModeEvent struct {
	// Events produced by other systems, but natively supported and defined by AliECS
	BeamModeEvent *Ev_BeamModeEvent `protobuf:"bytes,200,opt,name=beamModeEvent,proto3,oneof"`
}

type Event_CallEvent struct {
	CallEvent *Ev_CallEvent `protobuf:"bytes,14,opt,name=callEvent,proto3,oneof"`
}

type Event_CoreStartEvent struct {
	CoreStartEvent *Ev_MetaEvent_CoreStart `protobuf:"bytes,103,opt,name=coreStartEvent,proto3,oneof"`
}

type Event_EnvironmentEvent struct {
	// Events produced by AliECS
	EnvironmentEvent *Ev_EnvironmentEvent `protobuf:"bytes,11,opt,name=environmentEvent,proto3,oneof"`
}

type Event_FrameworkEvent struct {
	// Meta events produced by AliECS or its components
	FrameworkEvent *Ev_MetaEvent_FrameworkEvent `protobuf:"bytes,101,opt,name=frameworkEvent,proto3,oneof"`
}

type Event_IntegratedServiceEvent struct {
	IntegratedServiceEvent *Ev_IntegratedServiceEvent `protobuf:"bytes,15,opt,name=integratedServiceEvent,proto3,oneof"`
}

type Event_MesosHeartbeatEvent struct {
	MesosHeartbeatEvent *Ev_MetaEvent_MesosHeartbeat `protobuf:"bytes,102,opt,name=mesosHeartbeatEvent,proto3,oneof"`
}

type Event_RoleEvent struct {
	RoleEvent *Ev_RoleEvent `protobuf:"bytes,13,opt,name=roleEvent,proto3,oneof"`
}

type Event_RunEvent struct {
	RunEvent *Ev_RunEvent `protobuf:"bytes,16,opt,name=runEvent,proto3,oneof"`
}

type Event_TaskEvent struct {
	TaskEvent *Ev_TaskEvent `protobuf:"bytes,12,opt,name=taskEvent,proto3,oneof"`
}

type OpStatus int32

type Traits struct {
	Trigger  string `protobuf:"bytes,1,opt,name=trigger,proto3" json:"trigger,omitempty"`
	Await    string `protobuf:"bytes,2,opt,name=await,proto3" json:"await,omitempty"`
	Timeout  string `protobuf:"bytes,3,opt,name=timeout,proto3" json:"timeout,omitempty"`
	Critical bool   `protobuf:"varint,4,opt,name=critical,proto3" json:"critical,omitempty"`
	// contains filtered or unexported fields
}

type User struct {

	// The unique CERN identifier of this user.
	ExternalId *int32 `protobuf:"varint,1,opt,name=externalId,proto3,oneof" json:"externalId,omitempty"`
	// The unique identifier of this entity.
	Id *int32 `protobuf:"varint,2,opt,name=id,proto3,oneof" json:"id,omitempty"`
	// Name of the user.
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type WorkflowTemplateInfo struct {
	Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Path        string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	Public      bool   `protobuf:"varint,4,opt,name=public,proto3" json:"public,omitempty"` // whether the environment is public or not
	// contains filtered or unexported fields
}