pb

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 */
	// 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"`     // active/inactive etc., 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_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"` // active/inactive etc.
	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"`
	// Types that are assignable to Payload:
	//
	//	*Event_EnvironmentEvent
	//	*Event_TaskEvent
	//	*Event_RoleEvent
	//	*Event_CallEvent
	//	*Event_IntegratedServiceEvent
	//	*Event_FrameworkEvent
	//	*Event_MesosHeartbeatEvent
	//	*Event_CoreStartEvent
	Payload isEvent_Payload `protobuf_oneof:"Payload"`
	// contains filtered or unexported fields
}

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 {
	EnvironmentEvent *Ev_EnvironmentEvent `protobuf:"bytes,11,opt,name=environmentEvent,proto3,oneof"`
}

type Event_FrameworkEvent struct {
	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_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
}