pb

package
v1.23.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 31, 2024 License: GPL-3.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	OpStatus_name = map[int32]string{
		0: "NULL",
		1: "STARTED",
		2: "ONGOING",
		3: "DONE_OK",
		4: "DONE_ERROR",
		5: "DONE_TIMEOUT",
	}
	OpStatus_value = map[string]int32{
		"NULL":         0,
		"STARTED":      1,
		"ONGOING":      2,
		"DONE_OK":      3,
		"DONE_ERROR":   4,
		"DONE_TIMEOUT": 5,
	}
)

Enum value maps for OpStatus.

View Source 
var File_protos_common_proto protoreflect.FileDescriptor
View Source 
var File_protos_events_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Ev_CallEvent 

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
}

func (*Ev_CallEvent) Descriptor deprecated 

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

Deprecated: Use Ev_CallEvent.ProtoReflect.Descriptor instead.

func (*Ev_CallEvent) GetCallStatus 

func (x *Ev_CallEvent) GetCallStatus() OpStatus

func (*Ev_CallEvent) GetEnvironmentId 

func (x *Ev_CallEvent) GetEnvironmentId() string

func (*Ev_CallEvent) GetError 

func (x *Ev_CallEvent) GetError() string

func (*Ev_CallEvent) GetFunc 

func (x *Ev_CallEvent) GetFunc() string

func (*Ev_CallEvent) GetOutput 

func (x *Ev_CallEvent) GetOutput() string

func (*Ev_CallEvent) GetPath 

func (x *Ev_CallEvent) GetPath() string

func (*Ev_CallEvent) GetReturn 

func (x *Ev_CallEvent) GetReturn() string

func (*Ev_CallEvent) GetTraits 

func (x *Ev_CallEvent) GetTraits() *Traits

func (*Ev_CallEvent) ProtoMessage 

func (*Ev_CallEvent) ProtoMessage()

func (*Ev_CallEvent) ProtoReflect 

func (x *Ev_CallEvent) ProtoReflect() protoreflect.Message

func (*Ev_CallEvent) Reset 

func (x *Ev_CallEvent) Reset()

func (*Ev_CallEvent) String 

func (x *Ev_CallEvent) String() string

type Ev_EnvironmentEvent 

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
}

func (*Ev_EnvironmentEvent) Descriptor deprecated 

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

Deprecated: Use Ev_EnvironmentEvent.ProtoReflect.Descriptor instead.

func (*Ev_EnvironmentEvent) GetEnvironmentId 

func (x *Ev_EnvironmentEvent) GetEnvironmentId() string

func (*Ev_EnvironmentEvent) GetError 

func (x *Ev_EnvironmentEvent) GetError() string

func (*Ev_EnvironmentEvent) GetLastRequestUser added in v1.15.0 

func (x *Ev_EnvironmentEvent) GetLastRequestUser() *User

func (*Ev_EnvironmentEvent) GetMessage 

func (x *Ev_EnvironmentEvent) GetMessage() string

func (*Ev_EnvironmentEvent) GetRunNumber 

func (x *Ev_EnvironmentEvent) GetRunNumber() uint32

func (*Ev_EnvironmentEvent) GetState 

func (x *Ev_EnvironmentEvent) GetState() string

func (*Ev_EnvironmentEvent) GetTransition 

func (x *Ev_EnvironmentEvent) GetTransition() string

func (*Ev_EnvironmentEvent) GetTransitionStatus 

func (x *Ev_EnvironmentEvent) GetTransitionStatus() OpStatus

func (*Ev_EnvironmentEvent) GetTransitionStep 

func (x *Ev_EnvironmentEvent) GetTransitionStep() string

func (*Ev_EnvironmentEvent) GetVars 

func (x *Ev_EnvironmentEvent) GetVars() map[string]string

func (*Ev_EnvironmentEvent) GetWorkflowTemplateInfo added in v1.21.0 

func (x *Ev_EnvironmentEvent) GetWorkflowTemplateInfo() *WorkflowTemplateInfo

func (*Ev_EnvironmentEvent) ProtoMessage 

func (*Ev_EnvironmentEvent) ProtoMessage()

func (*Ev_EnvironmentEvent) ProtoReflect 

func (x *Ev_EnvironmentEvent) ProtoReflect() protoreflect.Message

func (*Ev_EnvironmentEvent) Reset 

func (x *Ev_EnvironmentEvent) Reset()

func (*Ev_EnvironmentEvent) String 

func (x *Ev_EnvironmentEvent) String() string

type Ev_IntegratedServiceEvent 

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
}

func (*Ev_IntegratedServiceEvent) Descriptor deprecated 

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

Deprecated: Use Ev_IntegratedServiceEvent.ProtoReflect.Descriptor instead.

func (*Ev_IntegratedServiceEvent) GetEnvironmentId 

func (x *Ev_IntegratedServiceEvent) GetEnvironmentId() string

func (*Ev_IntegratedServiceEvent) GetError 

func (x *Ev_IntegratedServiceEvent) GetError() string

func (*Ev_IntegratedServiceEvent) GetName 

func (x *Ev_IntegratedServiceEvent) GetName() string

func (*Ev_IntegratedServiceEvent) GetOperationName 

func (x *Ev_IntegratedServiceEvent) GetOperationName() string

func (*Ev_IntegratedServiceEvent) GetOperationStatus 

func (x *Ev_IntegratedServiceEvent) GetOperationStatus() OpStatus

func (*Ev_IntegratedServiceEvent) GetOperationStep 

func (x *Ev_IntegratedServiceEvent) GetOperationStep() string

func (*Ev_IntegratedServiceEvent) GetOperationStepStatus 

func (x *Ev_IntegratedServiceEvent) GetOperationStepStatus() OpStatus

func (*Ev_IntegratedServiceEvent) GetPayload 

func (x *Ev_IntegratedServiceEvent) GetPayload() string

func (*Ev_IntegratedServiceEvent) ProtoMessage 

func (*Ev_IntegratedServiceEvent) ProtoMessage()

func (*Ev_IntegratedServiceEvent) ProtoReflect 

func (x *Ev_IntegratedServiceEvent) ProtoReflect() protoreflect.Message

func (*Ev_IntegratedServiceEvent) Reset 

func (x *Ev_IntegratedServiceEvent) Reset()

func (*Ev_IntegratedServiceEvent) String 

func (x *Ev_IntegratedServiceEvent) String() string

type Ev_MetaEvent_CoreStart 

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

func (*Ev_MetaEvent_CoreStart) Descriptor deprecated 

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

Deprecated: Use Ev_MetaEvent_CoreStart.ProtoReflect.Descriptor instead.

func (*Ev_MetaEvent_CoreStart) GetFrameworkId 

func (x *Ev_MetaEvent_CoreStart) GetFrameworkId() string

func (*Ev_MetaEvent_CoreStart) ProtoMessage 

func (*Ev_MetaEvent_CoreStart) ProtoMessage()

func (*Ev_MetaEvent_CoreStart) ProtoReflect 

func (x *Ev_MetaEvent_CoreStart) ProtoReflect() protoreflect.Message

func (*Ev_MetaEvent_CoreStart) Reset 

func (x *Ev_MetaEvent_CoreStart) Reset()

func (*Ev_MetaEvent_CoreStart) String 

func (x *Ev_MetaEvent_CoreStart) String() string

type Ev_MetaEvent_FrameworkEvent 

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
}

func (*Ev_MetaEvent_FrameworkEvent) Descriptor deprecated 

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

Deprecated: Use Ev_MetaEvent_FrameworkEvent.ProtoReflect.Descriptor instead.

func (*Ev_MetaEvent_FrameworkEvent) GetFrameworkId 

func (x *Ev_MetaEvent_FrameworkEvent) GetFrameworkId() string

func (*Ev_MetaEvent_FrameworkEvent) GetMessage 

func (x *Ev_MetaEvent_FrameworkEvent) GetMessage() string

func (*Ev_MetaEvent_FrameworkEvent) ProtoMessage 

func (*Ev_MetaEvent_FrameworkEvent) ProtoMessage()

func (*Ev_MetaEvent_FrameworkEvent) ProtoReflect 

func (x *Ev_MetaEvent_FrameworkEvent) ProtoReflect() protoreflect.Message

func (*Ev_MetaEvent_FrameworkEvent) Reset 

func (x *Ev_MetaEvent_FrameworkEvent) Reset()

func (*Ev_MetaEvent_FrameworkEvent) String 

func (x *Ev_MetaEvent_FrameworkEvent) String() string

type Ev_MetaEvent_MesosHeartbeat 

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

func (*Ev_MetaEvent_MesosHeartbeat) Descriptor deprecated 

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

Deprecated: Use Ev_MetaEvent_MesosHeartbeat.ProtoReflect.Descriptor instead.

func (*Ev_MetaEvent_MesosHeartbeat) ProtoMessage 

func (*Ev_MetaEvent_MesosHeartbeat) ProtoMessage()

func (*Ev_MetaEvent_MesosHeartbeat) ProtoReflect 

func (x *Ev_MetaEvent_MesosHeartbeat) ProtoReflect() protoreflect.Message

func (*Ev_MetaEvent_MesosHeartbeat) Reset 

func (x *Ev_MetaEvent_MesosHeartbeat) Reset()

func (*Ev_MetaEvent_MesosHeartbeat) String 

func (x *Ev_MetaEvent_MesosHeartbeat) String() string

type Ev_RoleEvent 

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
}

func (*Ev_RoleEvent) Descriptor deprecated 

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

Deprecated: Use Ev_RoleEvent.ProtoReflect.Descriptor instead.

func (*Ev_RoleEvent) GetEnvironmentId 

func (x *Ev_RoleEvent) GetEnvironmentId() string

func (*Ev_RoleEvent) GetName 

func (x *Ev_RoleEvent) GetName() string

func (*Ev_RoleEvent) GetRolePath 

func (x *Ev_RoleEvent) GetRolePath() string

func (*Ev_RoleEvent) GetState 

func (x *Ev_RoleEvent) GetState() string

func (*Ev_RoleEvent) GetStatus 

func (x *Ev_RoleEvent) GetStatus() string

func (*Ev_RoleEvent) ProtoMessage 

func (*Ev_RoleEvent) ProtoMessage()

func (*Ev_RoleEvent) ProtoReflect 

func (x *Ev_RoleEvent) ProtoReflect() protoreflect.Message

func (*Ev_RoleEvent) Reset 

func (x *Ev_RoleEvent) Reset()

func (*Ev_RoleEvent) String 

func (x *Ev_RoleEvent) String() string

type Ev_RunEvent added in v1.11.0 

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"`
	Vars             map[string]string `` /* 149-byte string literal not displayed */
	LastRequestUser  *User             `protobuf:"bytes,8,opt,name=lastRequestUser,proto3" json:"lastRequestUser,omitempty"`
	// contains filtered or unexported fields
}

func (*Ev_RunEvent) Descriptor deprecated added in v1.11.0 

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

Deprecated: Use Ev_RunEvent.ProtoReflect.Descriptor instead.

func (*Ev_RunEvent) GetEnvironmentId added in v1.11.0 

func (x *Ev_RunEvent) GetEnvironmentId() string

func (*Ev_RunEvent) GetError added in v1.11.0 

func (x *Ev_RunEvent) GetError() string

func (*Ev_RunEvent) GetLastRequestUser added in v1.15.0 

func (x *Ev_RunEvent) GetLastRequestUser() *User

func (*Ev_RunEvent) GetRunNumber added in v1.11.0 

func (x *Ev_RunEvent) GetRunNumber() uint32

func (*Ev_RunEvent) GetState added in v1.11.0 

func (x *Ev_RunEvent) GetState() string

func (*Ev_RunEvent) GetTransition added in v1.11.0 

func (x *Ev_RunEvent) GetTransition() string

func (*Ev_RunEvent) GetTransitionStatus added in v1.11.0 

func (x *Ev_RunEvent) GetTransitionStatus() OpStatus

func (*Ev_RunEvent) GetVars added in v1.11.0 

func (x *Ev_RunEvent) GetVars() map[string]string

func (*Ev_RunEvent) ProtoMessage added in v1.11.0 

func (*Ev_RunEvent) ProtoMessage()

func (*Ev_RunEvent) ProtoReflect added in v1.11.0 

func (x *Ev_RunEvent) ProtoReflect() protoreflect.Message

func (*Ev_RunEvent) Reset added in v1.11.0 

func (x *Ev_RunEvent) Reset()

func (*Ev_RunEvent) String added in v1.11.0 

func (x *Ev_RunEvent) String() string

type Ev_TaskEvent 

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
}

func (*Ev_TaskEvent) Descriptor deprecated 

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

Deprecated: Use Ev_TaskEvent.ProtoReflect.Descriptor instead.

func (*Ev_TaskEvent) GetClassName 

func (x *Ev_TaskEvent) GetClassName() string

func (*Ev_TaskEvent) GetEnvironmentId 

func (x *Ev_TaskEvent) GetEnvironmentId() string

func (*Ev_TaskEvent) GetHostname 

func (x *Ev_TaskEvent) GetHostname() string

func (*Ev_TaskEvent) GetName 

func (x *Ev_TaskEvent) GetName() string

func (*Ev_TaskEvent) GetPath 

func (x *Ev_TaskEvent) GetPath() string

func (*Ev_TaskEvent) GetState 

func (x *Ev_TaskEvent) GetState() string

func (*Ev_TaskEvent) GetStatus 

func (x *Ev_TaskEvent) GetStatus() string

func (*Ev_TaskEvent) GetTaskid 

func (x *Ev_TaskEvent) GetTaskid() string

func (*Ev_TaskEvent) GetTraits 

func (x *Ev_TaskEvent) GetTraits() *Traits

func (*Ev_TaskEvent) ProtoMessage 

func (*Ev_TaskEvent) ProtoMessage()

func (*Ev_TaskEvent) ProtoReflect 

func (x *Ev_TaskEvent) ProtoReflect() protoreflect.Message

func (*Ev_TaskEvent) Reset 

func (x *Ev_TaskEvent) Reset()

func (*Ev_TaskEvent) String 

func (x *Ev_TaskEvent) String() string

type Event 

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

func WrapEvent 

func WrapEvent(ce isEvent_Payload) *Event

func (*Event) Descriptor deprecated 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetCallEvent 

func (x *Event) GetCallEvent() *Ev_CallEvent

func (*Event) GetCoreStartEvent 

func (x *Event) GetCoreStartEvent() *Ev_MetaEvent_CoreStart

func (*Event) GetEnvironmentEvent 

func (x *Event) GetEnvironmentEvent() *Ev_EnvironmentEvent

func (*Event) GetFrameworkEvent 

func (x *Event) GetFrameworkEvent() *Ev_MetaEvent_FrameworkEvent

func (*Event) GetIntegratedServiceEvent 

func (x *Event) GetIntegratedServiceEvent() *Ev_IntegratedServiceEvent

func (*Event) GetMesosHeartbeatEvent 

func (x *Event) GetMesosHeartbeatEvent() *Ev_MetaEvent_MesosHeartbeat

func (*Event) GetPayload 

func (m *Event) GetPayload() isEvent_Payload

func (*Event) GetRoleEvent 

func (x *Event) GetRoleEvent() *Ev_RoleEvent

func (*Event) GetRunEvent added in v1.11.0 

func (x *Event) GetRunEvent() *Ev_RunEvent

func (*Event) GetTaskEvent 

func (x *Event) GetTaskEvent() *Ev_TaskEvent

func (*Event) GetTimestamp 

func (x *Event) GetTimestamp() int64

func (*Event) GetTimestampNano added in v1.21.0 

func (x *Event) GetTimestampNano() int64

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

func (x *Event) ProtoReflect() protoreflect.Message

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type Event_CallEvent 

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

type Event_CoreStartEvent 

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

type Event_EnvironmentEvent 

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

type Event_FrameworkEvent 

type Event_FrameworkEvent struct {
	FrameworkEvent *Ev_MetaEvent_FrameworkEvent `protobuf:"bytes,101,opt,name=frameworkEvent,proto3,oneof"`
}

type Event_IntegratedServiceEvent 

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

type Event_MesosHeartbeatEvent 

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

type Event_RoleEvent 

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

type Event_RunEvent added in v1.11.0 

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

type Event_TaskEvent 

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

type OpStatus 

type OpStatus int32
const (
	OpStatus_NULL         OpStatus = 0
	OpStatus_STARTED      OpStatus = 1
	OpStatus_ONGOING      OpStatus = 2
	OpStatus_DONE_OK      OpStatus = 3
	OpStatus_DONE_ERROR   OpStatus = 4
	OpStatus_DONE_TIMEOUT OpStatus = 5
)

func (OpStatus) Descriptor 

func (OpStatus) Descriptor() protoreflect.EnumDescriptor

func (OpStatus) Enum 

func (x OpStatus) Enum() *OpStatus

func (OpStatus) EnumDescriptor deprecated 

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

Deprecated: Use OpStatus.Descriptor instead.

func (OpStatus) Number 

func (x OpStatus) Number() protoreflect.EnumNumber

func (OpStatus) String 

func (x OpStatus) String() string

func (OpStatus) Type 

func (OpStatus) Type() protoreflect.EnumType

type Traits 

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
}

func (*Traits) Descriptor deprecated 

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

Deprecated: Use Traits.ProtoReflect.Descriptor instead.

func (*Traits) GetAwait 

func (x *Traits) GetAwait() string

func (*Traits) GetCritical 

func (x *Traits) GetCritical() bool

func (*Traits) GetTimeout 

func (x *Traits) GetTimeout() string

func (*Traits) GetTrigger 

func (x *Traits) GetTrigger() string

func (*Traits) ProtoMessage 

func (*Traits) ProtoMessage()

func (*Traits) ProtoReflect 

func (x *Traits) ProtoReflect() protoreflect.Message

func (*Traits) Reset 

func (x *Traits) Reset()

func (*Traits) String 

func (x *Traits) String() string

type User added in v1.15.0 

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
}

func (*User) Descriptor deprecated added in v1.15.0 

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

Deprecated: Use User.ProtoReflect.Descriptor instead.

func (*User) GetExternalId added in v1.15.0 

func (x *User) GetExternalId() int32

func (*User) GetId added in v1.15.0 

func (x *User) GetId() int32

func (*User) GetName added in v1.15.0 

func (x *User) GetName() string

func (*User) ProtoMessage added in v1.15.0 

func (*User) ProtoMessage()

func (*User) ProtoReflect added in v1.15.0 

func (x *User) ProtoReflect() protoreflect.Message

func (*User) Reset added in v1.15.0 

func (x *User) Reset()

func (*User) String added in v1.15.0 

func (x *User) String() string

type WorkflowTemplateInfo added in v1.21.0 

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
}

func (*WorkflowTemplateInfo) Descriptor deprecated added in v1.21.0 

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

Deprecated: Use WorkflowTemplateInfo.ProtoReflect.Descriptor instead.

func (*WorkflowTemplateInfo) GetDescription added in v1.21.0 

func (x *WorkflowTemplateInfo) GetDescription() string

func (*WorkflowTemplateInfo) GetName added in v1.21.0 

func (x *WorkflowTemplateInfo) GetName() string

func (*WorkflowTemplateInfo) GetPath added in v1.21.0 

func (x *WorkflowTemplateInfo) GetPath() string

func (*WorkflowTemplateInfo) GetPublic added in v1.21.0 

func (x *WorkflowTemplateInfo) GetPublic() bool

func (*WorkflowTemplateInfo) ProtoMessage added in v1.21.0 

func (*WorkflowTemplateInfo) ProtoMessage()

func (*WorkflowTemplateInfo) ProtoReflect added in v1.21.0 

func (x *WorkflowTemplateInfo) ProtoReflect() protoreflect.Message

func (*WorkflowTemplateInfo) Reset added in v1.21.0 

func (x *WorkflowTemplateInfo) Reset()

func (*WorkflowTemplateInfo) String added in v1.21.0 

func (x *WorkflowTemplateInfo) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.