integrations

package
v0.0.0-...-a8a6208 Latest Latest
Warning

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

 Go to latest Published: Jun 10, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	JsonValidationOption_name = map[int32]string{
		0: "JSON_VALIDATION_OPTION_UNSPECIFIED",
		1: "SKIP",
		2: "PRE_EXECUTION",
		3: "POST_EXECUTION",
		4: "PRE_POST_EXECUTION",
	}
	JsonValidationOption_value = map[string]int32{
		"JSON_VALIDATION_OPTION_UNSPECIFIED": 0,
		"SKIP":                               1,
		"PRE_EXECUTION":                      2,
		"POST_EXECUTION":                     3,
		"PRE_POST_EXECUTION":                 4,
	}
)

Enum value maps for JsonValidationOption.

View Source 
var (
	ExecutionInfo_PostMethod_name = map[int32]string{
		0: "POST_METHOD_UNSPECIFIED",
		1: "POST",
		2: "SCHEDULE",
	}
	ExecutionInfo_PostMethod_value = map[string]int32{
		"POST_METHOD_UNSPECIFIED": 0,
		"POST":                    1,
		"SCHEDULE":                2,
	}
)

Enum value maps for ExecutionInfo_PostMethod.

View Source 
var (
	EventExecutionDetails_EventExecutionState_name = map[int32]string{
		0: "EVENT_EXECUTION_STATE_UNSPECIFIED",
		1: "ON_HOLD",
		2: "IN_PROCESS",
		3: "SUCCEEDED",
		4: "FAILED",
		5: "CANCELLED",
		6: "RETRY_ON_HOLD",
		7: "SUSPENDED",
	}
	EventExecutionDetails_EventExecutionState_value = map[string]int32{
		"EVENT_EXECUTION_STATE_UNSPECIFIED": 0,
		"ON_HOLD":                           1,
		"IN_PROCESS":                        2,
		"SUCCEEDED":                         3,
		"FAILED":                            4,
		"CANCELLED":                         5,
		"RETRY_ON_HOLD":                     6,
		"SUSPENDED":                         7,
	}
)

Enum value maps for EventExecutionDetails_EventExecutionState.

View Source 
var (
	TaskExecutionDetails_TaskExecutionState_name = map[int32]string{
		0:  "TASK_EXECUTION_STATE_UNSPECIFIED",
		1:  "PENDING_EXECUTION",
		2:  "IN_PROCESS",
		3:  "SUCCEED",
		4:  "FAILED",
		5:  "FATAL",
		6:  "RETRY_ON_HOLD",
		7:  "SKIPPED",
		8:  "CANCELLED",
		9:  "PENDING_ROLLBACK",
		10: "ROLLBACK_IN_PROCESS",
		11: "ROLLEDBACK",
		12: "SUSPENDED",
	}
	TaskExecutionDetails_TaskExecutionState_value = map[string]int32{
		"TASK_EXECUTION_STATE_UNSPECIFIED": 0,
		"PENDING_EXECUTION":                1,
		"IN_PROCESS":                       2,
		"SUCCEED":                          3,
		"FAILED":                           4,
		"FATAL":                            5,
		"RETRY_ON_HOLD":                    6,
		"SKIPPED":                          7,
		"CANCELLED":                        8,
		"PENDING_ROLLBACK":                 9,
		"ROLLBACK_IN_PROCESS":              10,
		"ROLLEDBACK":                       11,
		"SUSPENDED":                        12,
	}
)

Enum value maps for TaskExecutionDetails_TaskExecutionState.

View Source 
var (
	Product_name = map[int32]string{
		0: "PRODUCT_UNSPECIFIED",
		1: "IP",
		2: "APIGEE",
		3: "SECURITY",
	}
	Product_value = map[string]int32{
		"PRODUCT_UNSPECIFIED": 0,
		"IP":                  1,
		"APIGEE":              2,
		"SECURITY":            3,
	}
)

Enum value maps for Product.

View Source 
var (
	TaskConfig_NextTasksExecutionPolicy_name = map[int32]string{
		0: "NEXT_TASKS_EXECUTION_POLICY_UNSPECIFIED",
		1: "RUN_ALL_MATCH",
		2: "RUN_FIRST_MATCH",
	}
	TaskConfig_NextTasksExecutionPolicy_value = map[string]int32{
		"NEXT_TASKS_EXECUTION_POLICY_UNSPECIFIED": 0,
		"RUN_ALL_MATCH":   1,
		"RUN_FIRST_MATCH": 2,
	}
)

Enum value maps for TaskConfig_NextTasksExecutionPolicy.

View Source 
var (
	TaskConfig_TaskExecutionStrategy_name = map[int32]string{
		0: "TASK_EXECUTION_STRATEGY_UNSPECIFIED",
		1: "WHEN_ALL_SUCCEED",
		2: "WHEN_ANY_SUCCEED",
		3: "WHEN_ALL_TASKS_AND_CONDITIONS_SUCCEED",
	}
	TaskConfig_TaskExecutionStrategy_value = map[string]int32{
		"TASK_EXECUTION_STRATEGY_UNSPECIFIED":   0,
		"WHEN_ALL_SUCCEED":                      1,
		"WHEN_ANY_SUCCEED":                      2,
		"WHEN_ALL_TASKS_AND_CONDITIONS_SUCCEED": 3,
	}
)

Enum value maps for TaskConfig_TaskExecutionStrategy.

View Source 
var (
	SuccessPolicy_FinalState_name = map[int32]string{
		0: "FINAL_STATE_UNSPECIFIED",
		1: "SUCCEEDED",
		2: "SUSPENDED",
	}
	SuccessPolicy_FinalState_value = map[string]int32{
		"FINAL_STATE_UNSPECIFIED": 0,
		"SUCCEEDED":               1,
		"SUSPENDED":               2,
	}
)

Enum value maps for SuccessPolicy_FinalState.

View Source 
var (
	FailurePolicy_RetryStrategy_name = map[int32]string{
		0: "RETRY_STRATEGY_UNSPECIFIED",
		1: "IGNORE",
		2: "NONE",
		3: "FATAL",
		4: "FIXED_INTERVAL",
		5: "LINEAR_BACKOFF",
		6: "EXPONENTIAL_BACKOFF",
		7: "RESTART_INTEGRATION_WITH_BACKOFF",
	}
	FailurePolicy_RetryStrategy_value = map[string]int32{
		"RETRY_STRATEGY_UNSPECIFIED":       0,
		"IGNORE":                           1,
		"NONE":                             2,
		"FATAL":                            3,
		"FIXED_INTERVAL":                   4,
		"LINEAR_BACKOFF":                   5,
		"EXPONENTIAL_BACKOFF":              6,
		"RESTART_INTEGRATION_WITH_BACKOFF": 7,
	}
)

Enum value maps for FailurePolicy_RetryStrategy.

View Source 
var File_google_cloud_integrations_v1alpha_event_parameter_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_integrations_v1alpha_json_validation_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_integrations_v1alpha_log_entries_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_integrations_v1alpha_product_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_integrations_v1alpha_task_config_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_integrations_v1alpha_value_type_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AttemptStats 

type AttemptStats struct {

	// The start time of the event execution for current attempt. This could be
	// in the future if it's been scheduled.
	StartTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// The end time of the event execution for current attempt.
	EndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// contains filtered or unexported fields
}

Status for the execution attempt.

func (*AttemptStats) Descriptor deprecated 

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

Deprecated: Use AttemptStats.ProtoReflect.Descriptor instead.

func (*AttemptStats) GetEndTime 

func (x *AttemptStats) GetEndTime() *timestamppb.Timestamp

func (*AttemptStats) GetStartTime 

func (x *AttemptStats) GetStartTime() *timestamppb.Timestamp

func (*AttemptStats) ProtoMessage 

func (*AttemptStats) ProtoMessage()

func (*AttemptStats) ProtoReflect 

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

func (*AttemptStats) Reset 

func (x *AttemptStats) Reset()

func (*AttemptStats) String 

func (x *AttemptStats) String() string

type BooleanParameterArray 

type BooleanParameterArray struct {

	// Boolean array.
	BooleanValues []bool `protobuf:"varint,1,rep,packed,name=boolean_values,json=booleanValues,proto3" json:"boolean_values,omitempty"`
	// contains filtered or unexported fields
}

This message only contains a field of boolean array.

func (*BooleanParameterArray) Descriptor deprecated 

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

Deprecated: Use BooleanParameterArray.ProtoReflect.Descriptor instead.

func (*BooleanParameterArray) GetBooleanValues 

func (x *BooleanParameterArray) GetBooleanValues() []bool

func (*BooleanParameterArray) ProtoMessage 

func (*BooleanParameterArray) ProtoMessage()

func (*BooleanParameterArray) ProtoReflect 

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

func (*BooleanParameterArray) Reset 

func (x *BooleanParameterArray) Reset()

func (*BooleanParameterArray) String 

func (x *BooleanParameterArray) String() string

type ConditionResult 

type ConditionResult struct {

	// the current task number.
	CurrentTaskNumber string `protobuf:"bytes,1,opt,name=current_task_number,json=currentTaskNumber,proto3" json:"current_task_number,omitempty"`
	// the next task number.
	NextTaskNumber string `protobuf:"bytes,2,opt,name=next_task_number,json=nextTaskNumber,proto3" json:"next_task_number,omitempty"`
	// the result comes out after evaluate the combined condition. True if there's
	// no combined condition specified.
	Result bool `protobuf:"varint,3,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

Contains the combined condition calculation results.

func (*ConditionResult) Descriptor deprecated 

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

Deprecated: Use ConditionResult.ProtoReflect.Descriptor instead.

func (*ConditionResult) GetCurrentTaskNumber 

func (x *ConditionResult) GetCurrentTaskNumber() string

func (*ConditionResult) GetNextTaskNumber 

func (x *ConditionResult) GetNextTaskNumber() string

func (*ConditionResult) GetResult 

func (x *ConditionResult) GetResult() bool

func (*ConditionResult) ProtoMessage 

func (*ConditionResult) ProtoMessage()

func (*ConditionResult) ProtoReflect 

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

func (*ConditionResult) Reset 

func (x *ConditionResult) Reset()

func (*ConditionResult) String 

func (x *ConditionResult) String() string

type DoubleParameterArray 

type DoubleParameterArray struct {

	// Double number array.
	DoubleValues []float64 `protobuf:"fixed64,1,rep,packed,name=double_values,json=doubleValues,proto3" json:"double_values,omitempty"`
	// contains filtered or unexported fields
}

This message only contains a field of double number array.

func (*DoubleParameterArray) Descriptor deprecated 

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

Deprecated: Use DoubleParameterArray.ProtoReflect.Descriptor instead.

func (*DoubleParameterArray) GetDoubleValues 

func (x *DoubleParameterArray) GetDoubleValues() []float64

func (*DoubleParameterArray) ProtoMessage 

func (*DoubleParameterArray) ProtoMessage()

func (*DoubleParameterArray) ProtoReflect 

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

func (*DoubleParameterArray) Reset 

func (x *DoubleParameterArray) Reset()

func (*DoubleParameterArray) String 

func (x *DoubleParameterArray) String() string

type ErrorDetail 

type ErrorDetail struct {

	// The full text of the error message, including any parameters that were
	// thrown along with the exception.
	ErrorMessage string `protobuf:"bytes,1,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// The task try-number, in which, the error occurred.  If zero, the error
	// happened at the event level.
	TaskNumber int32 `protobuf:"varint,2,opt,name=task_number,json=taskNumber,proto3" json:"task_number,omitempty"`
	// contains filtered or unexported fields
}

An error, warning, or information message associated with an integration.

func (*ErrorDetail) Descriptor deprecated 

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

Deprecated: Use ErrorDetail.ProtoReflect.Descriptor instead.

func (*ErrorDetail) GetErrorMessage 

func (x *ErrorDetail) GetErrorMessage() string

func (*ErrorDetail) GetTaskNumber 

func (x *ErrorDetail) GetTaskNumber() int32

func (*ErrorDetail) ProtoMessage 

func (*ErrorDetail) ProtoMessage()

func (*ErrorDetail) ProtoReflect 

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

func (*ErrorDetail) Reset 

func (x *ErrorDetail) Reset()

func (*ErrorDetail) String 

func (x *ErrorDetail) String() string

type EventExecutionDetails 

type EventExecutionDetails struct {

	// The execution state of this event.
	EventExecutionState EventExecutionDetails_EventExecutionState `` /* 202-byte string literal not displayed */
	// After snapshot migration, this field will no longer be populated, but old
	// execution snapshots will still be accessible.
	EventExecutionSnapshot []*EventExecutionSnapshot `` /* 129-byte string literal not displayed */
	// Status for the current event execution attempt.
	EventAttemptStats []*AttemptStats `protobuf:"bytes,3,rep,name=event_attempt_stats,json=eventAttemptStats,proto3" json:"event_attempt_stats,omitempty"`
	// Next scheduled execution time in case the execution status was
	// RETRY_ON_HOLD.
	NextExecutionTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=next_execution_time,json=nextExecutionTime,proto3" json:"next_execution_time,omitempty"`
	// Indicates the number of times the execution has restarted from the
	// beginning.
	EventRetriesCount int32 `protobuf:"varint,5,opt,name=event_retries_count,json=eventRetriesCount,proto3" json:"event_retries_count,omitempty"`
	// contains filtered or unexported fields
}

Contains the details of the execution info of this event: this includes the tasks execution details plus the event execution statistics.

func (*EventExecutionDetails) Descriptor deprecated 

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

Deprecated: Use EventExecutionDetails.ProtoReflect.Descriptor instead.

func (*EventExecutionDetails) GetEventAttemptStats 

func (x *EventExecutionDetails) GetEventAttemptStats() []*AttemptStats

func (*EventExecutionDetails) GetEventExecutionSnapshot 

func (x *EventExecutionDetails) GetEventExecutionSnapshot() []*EventExecutionSnapshot

func (*EventExecutionDetails) GetEventExecutionState 

func (x *EventExecutionDetails) GetEventExecutionState() EventExecutionDetails_EventExecutionState

func (*EventExecutionDetails) GetEventRetriesCount 

func (x *EventExecutionDetails) GetEventRetriesCount() int32

func (*EventExecutionDetails) GetNextExecutionTime 

func (x *EventExecutionDetails) GetNextExecutionTime() *timestamppb.Timestamp

func (*EventExecutionDetails) ProtoMessage 

func (*EventExecutionDetails) ProtoMessage()

func (*EventExecutionDetails) ProtoReflect 

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

func (*EventExecutionDetails) Reset 

func (x *EventExecutionDetails) Reset()

func (*EventExecutionDetails) String 

func (x *EventExecutionDetails) String() string

type EventExecutionDetails_EventExecutionState 

type EventExecutionDetails_EventExecutionState int32

Enum EventExecutionState. 

const (
	// Default value.
	EventExecutionDetails_EVENT_EXECUTION_STATE_UNSPECIFIED EventExecutionDetails_EventExecutionState = 0
	// Event is received and waiting for the execution. This happens when
	// firing the event via "postToQueue" or "schedule".
	EventExecutionDetails_ON_HOLD EventExecutionDetails_EventExecutionState = 1
	// Event is under processing.
	EventExecutionDetails_IN_PROCESS EventExecutionDetails_EventExecutionState = 2
	// Event execution successfully finished. There's no more change after
	// this state.
	EventExecutionDetails_SUCCEEDED EventExecutionDetails_EventExecutionState = 3
	// Event execution failed. There's no more change after this state.
	EventExecutionDetails_FAILED EventExecutionDetails_EventExecutionState = 4
	// Event execution canceled by user. There's no more change after this
	// state.
	EventExecutionDetails_CANCELLED EventExecutionDetails_EventExecutionState = 5
	// Event execution failed and waiting for retry.
	EventExecutionDetails_RETRY_ON_HOLD EventExecutionDetails_EventExecutionState = 6
	// Event execution suspended and waiting for manual intervention.
	EventExecutionDetails_SUSPENDED EventExecutionDetails_EventExecutionState = 7
)

func (EventExecutionDetails_EventExecutionState) Descriptor 

func (EventExecutionDetails_EventExecutionState) Descriptor() protoreflect.EnumDescriptor

func (EventExecutionDetails_EventExecutionState) Enum 

func (x EventExecutionDetails_EventExecutionState) Enum() *EventExecutionDetails_EventExecutionState

func (EventExecutionDetails_EventExecutionState) EnumDescriptor deprecated 

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

Deprecated: Use EventExecutionDetails_EventExecutionState.Descriptor instead.

func (EventExecutionDetails_EventExecutionState) Number 

func (x EventExecutionDetails_EventExecutionState) Number() protoreflect.EnumNumber

func (EventExecutionDetails_EventExecutionState) String 

func (x EventExecutionDetails_EventExecutionState) String() string

func (EventExecutionDetails_EventExecutionState) Type 

func (EventExecutionDetails_EventExecutionState) Type() protoreflect.EnumType

type EventExecutionSnapshot 

type EventExecutionSnapshot struct {

	// Indicates "right after which checkpoint task's execution" this snapshot
	// is taken.
	CheckpointTaskNumber string `protobuf:"bytes,1,opt,name=checkpoint_task_number,json=checkpointTaskNumber,proto3" json:"checkpoint_task_number,omitempty"`
	// Indicates when this snapshot is taken.
	SnapshotTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=snapshot_time,json=snapshotTime,proto3" json:"snapshot_time,omitempty"`
	// Snapshot metadata.
	EventExecutionSnapshotMetadata *EventExecutionSnapshot_EventExecutionSnapshotMetadata `` /* 155-byte string literal not displayed */
	// All of the task execution details at the given point of time.
	TaskExecutionDetails []*TaskExecutionDetails `protobuf:"bytes,4,rep,name=task_execution_details,json=taskExecutionDetails,proto3" json:"task_execution_details,omitempty"`
	// All of the computed conditions that been calculated.
	ConditionResults []*ConditionResult `protobuf:"bytes,5,rep,name=condition_results,json=conditionResults,proto3" json:"condition_results,omitempty"`
	// The parameters in Event object.
	EventParams map[string]*EventParameter `` /* 182-byte string literal not displayed */
	// The parameters in Event object that differs from last snapshot.
	DiffParams map[string]*EventParameter `` /* 179-byte string literal not displayed */
	// contains filtered or unexported fields
}

Contains the snapshot of the event execution for a given checkpoint.

func (*EventExecutionSnapshot) Descriptor deprecated 

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

Deprecated: Use EventExecutionSnapshot.ProtoReflect.Descriptor instead.

func (*EventExecutionSnapshot) GetCheckpointTaskNumber 

func (x *EventExecutionSnapshot) GetCheckpointTaskNumber() string

func (*EventExecutionSnapshot) GetConditionResults 

func (x *EventExecutionSnapshot) GetConditionResults() []*ConditionResult

func (*EventExecutionSnapshot) GetDiffParams 

func (x *EventExecutionSnapshot) GetDiffParams() map[string]*EventParameter

func (*EventExecutionSnapshot) GetEventExecutionSnapshotMetadata 

func (x *EventExecutionSnapshot) GetEventExecutionSnapshotMetadata() *EventExecutionSnapshot_EventExecutionSnapshotMetadata

func (*EventExecutionSnapshot) GetEventParams 

func (x *EventExecutionSnapshot) GetEventParams() map[string]*EventParameter

func (*EventExecutionSnapshot) GetSnapshotTime 

func (x *EventExecutionSnapshot) GetSnapshotTime() *timestamppb.Timestamp

func (*EventExecutionSnapshot) GetTaskExecutionDetails 

func (x *EventExecutionSnapshot) GetTaskExecutionDetails() []*TaskExecutionDetails

func (*EventExecutionSnapshot) ProtoMessage 

func (*EventExecutionSnapshot) ProtoMessage()

func (*EventExecutionSnapshot) ProtoReflect 

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

func (*EventExecutionSnapshot) Reset 

func (x *EventExecutionSnapshot) Reset()

func (*EventExecutionSnapshot) String 

func (x *EventExecutionSnapshot) String() string

type EventExecutionSnapshot_EventExecutionSnapshotMetadata 

type EventExecutionSnapshot_EventExecutionSnapshotMetadata struct {

	// The task number associated with this snapshot. Could be empty.
	TaskNumber string `protobuf:"bytes,1,opt,name=task_number,json=taskNumber,proto3" json:"task_number,omitempty"`
	// the task name associated with this snapshot. Could be empty.
	Task string `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"`
	// the event attempt number this snapshot belongs to.
	EventAttemptNum int32 `protobuf:"varint,3,opt,name=event_attempt_num,json=eventAttemptNum,proto3" json:"event_attempt_num,omitempty"`
	// the task attempt number this snapshot belongs to. Could be empty.
	TaskAttemptNum int32 `protobuf:"varint,4,opt,name=task_attempt_num,json=taskAttemptNum,proto3" json:"task_attempt_num,omitempty"`
	// contains filtered or unexported fields
}

Metadata for the event/task retry.

func (*EventExecutionSnapshot_EventExecutionSnapshotMetadata) Descriptor deprecated 

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

Deprecated: Use EventExecutionSnapshot_EventExecutionSnapshotMetadata.ProtoReflect.Descriptor instead.

func (*EventExecutionSnapshot_EventExecutionSnapshotMetadata) GetEventAttemptNum 

func (x *EventExecutionSnapshot_EventExecutionSnapshotMetadata) GetEventAttemptNum() int32

func (*EventExecutionSnapshot_EventExecutionSnapshotMetadata) GetTask 

func (x *EventExecutionSnapshot_EventExecutionSnapshotMetadata) GetTask() string

func (*EventExecutionSnapshot_EventExecutionSnapshotMetadata) GetTaskAttemptNum 

func (x *EventExecutionSnapshot_EventExecutionSnapshotMetadata) GetTaskAttemptNum() int32

func (*EventExecutionSnapshot_EventExecutionSnapshotMetadata) GetTaskNumber 

func (x *EventExecutionSnapshot_EventExecutionSnapshotMetadata) GetTaskNumber() string

func (*EventExecutionSnapshot_EventExecutionSnapshotMetadata) ProtoMessage 

func (*EventExecutionSnapshot_EventExecutionSnapshotMetadata) ProtoMessage()

func (*EventExecutionSnapshot_EventExecutionSnapshotMetadata) ProtoReflect 

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

func (*EventExecutionSnapshot_EventExecutionSnapshotMetadata) Reset 

func (x *EventExecutionSnapshot_EventExecutionSnapshotMetadata) Reset()

func (*EventExecutionSnapshot_EventExecutionSnapshotMetadata) String 

func (x *EventExecutionSnapshot_EventExecutionSnapshotMetadata) String() string

type EventParameter 

type EventParameter struct {

	// Key is used to retrieve the corresponding parameter value. This should be
	// unique for a given fired event. These parameters must be predefined in the
	// integration definition.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Values for the defined keys. Each value can either be string, int, double
	// or any proto message.
	Value *ValueType `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

This message is used for processing and persisting (when applicable) key value pair parameters for each event in the event bus.

func (*EventParameter) Descriptor deprecated 

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

Deprecated: Use EventParameter.ProtoReflect.Descriptor instead.

func (*EventParameter) GetKey 

func (x *EventParameter) GetKey() string

func (*EventParameter) GetValue 

func (x *EventParameter) GetValue() *ValueType

func (*EventParameter) ProtoMessage 

func (*EventParameter) ProtoMessage()

func (*EventParameter) ProtoReflect 

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

func (*EventParameter) Reset 

func (x *EventParameter) Reset()

func (*EventParameter) String 

func (x *EventParameter) String() string

type ExecutionInfo 

type ExecutionInfo struct {

	// Auto-generated primary key.
	EventExecutionInfoId string `protobuf:"bytes,1,opt,name=event_execution_info_id,json=eventExecutionInfoId,proto3" json:"event_execution_info_id,omitempty"`
	// Name of the integration.
	Integration string `protobuf:"bytes,2,opt,name=integration,proto3" json:"integration,omitempty"`
	// Pointer to the active version it is executing.
	IntegrationVersion string `protobuf:"bytes,3,opt,name=integration_version,json=integrationVersion,proto3" json:"integration_version,omitempty"`
	// The event data user sends as request.
	ProjectId string `protobuf:"bytes,4,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// The trigger id of the integration trigger config. If both trigger_id
	// and client_id is present, the integration is executed from the start tasks
	// provided by the matching trigger config otherwise it is executed from the
	// default start tasks.
	TriggerId string `protobuf:"bytes,5,opt,name=trigger_id,json=triggerId,proto3" json:"trigger_id,omitempty"`
	// Event parameters come in as part of the request.
	RequestParams map[string]*EventParameter `` /* 188-byte string literal not displayed */
	// Event parameters come out as part of the response.
	ResponseParams map[string]*EventParameter `` /* 191-byte string literal not displayed */
	// The ways user posts this event.
	PostMethod ExecutionInfo_PostMethod `` /* 156-byte string literal not displayed */
	// The execution info about this event.
	EventExecutionDetails *EventExecutionDetails `` /* 126-byte string literal not displayed */
	// Errors, warnings, and informationals associated with the workflow/task.
	// The order in which the errors were added by the workflow/task is
	// maintained.
	Errors []*ErrorDetail `protobuf:"bytes,10,rep,name=errors,proto3" json:"errors,omitempty"`
	// Which Google product the execution_info belongs to. If not set, the
	// execution_info belongs to Integration Platform by default.
	Product Product `protobuf:"varint,11,opt,name=product,proto3,enum=google.cloud.integrations.v1alpha.Product" json:"product,omitempty"`
	// This is used to de-dup incoming request.
	RequestId string `protobuf:"bytes,12,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// The configuration details for a task.
	TaskConfigs []*TaskConfig `protobuf:"bytes,13,rep,name=task_configs,json=taskConfigs,proto3" json:"task_configs,omitempty"`
	// contains filtered or unexported fields
}

Log entry to log execution info for the monitored resource `integrations.googleapis.com/IntegrationVersion`.

func (*ExecutionInfo) Descriptor deprecated 

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

Deprecated: Use ExecutionInfo.ProtoReflect.Descriptor instead.

func (*ExecutionInfo) GetErrors 

func (x *ExecutionInfo) GetErrors() []*ErrorDetail

func (*ExecutionInfo) GetEventExecutionDetails 

func (x *ExecutionInfo) GetEventExecutionDetails() *EventExecutionDetails

func (*ExecutionInfo) GetEventExecutionInfoId 

func (x *ExecutionInfo) GetEventExecutionInfoId() string

func (*ExecutionInfo) GetIntegration 

func (x *ExecutionInfo) GetIntegration() string

func (*ExecutionInfo) GetIntegrationVersion 

func (x *ExecutionInfo) GetIntegrationVersion() string

func (*ExecutionInfo) GetPostMethod 

func (x *ExecutionInfo) GetPostMethod() ExecutionInfo_PostMethod

func (*ExecutionInfo) GetProduct 

func (x *ExecutionInfo) GetProduct() Product

func (*ExecutionInfo) GetProjectId 

func (x *ExecutionInfo) GetProjectId() string

func (*ExecutionInfo) GetRequestId 

func (x *ExecutionInfo) GetRequestId() string

func (*ExecutionInfo) GetRequestParams 

func (x *ExecutionInfo) GetRequestParams() map[string]*EventParameter

func (*ExecutionInfo) GetResponseParams 

func (x *ExecutionInfo) GetResponseParams() map[string]*EventParameter

func (*ExecutionInfo) GetTaskConfigs 

func (x *ExecutionInfo) GetTaskConfigs() []*TaskConfig

func (*ExecutionInfo) GetTriggerId 

func (x *ExecutionInfo) GetTriggerId() string

func (*ExecutionInfo) ProtoMessage 

func (*ExecutionInfo) ProtoMessage()

func (*ExecutionInfo) ProtoReflect 

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

func (*ExecutionInfo) Reset 

func (x *ExecutionInfo) Reset()

func (*ExecutionInfo) String 

func (x *ExecutionInfo) String() string

type ExecutionInfo_PostMethod 

type ExecutionInfo_PostMethod int32

PostMethod Enum 

const (
	// Default value.
	ExecutionInfo_POST_METHOD_UNSPECIFIED ExecutionInfo_PostMethod = 0
	// Sync post.
	ExecutionInfo_POST ExecutionInfo_PostMethod = 1
	// Async post with schedule time.
	ExecutionInfo_SCHEDULE ExecutionInfo_PostMethod = 2
)

func (ExecutionInfo_PostMethod) Descriptor 

func (ExecutionInfo_PostMethod) Descriptor() protoreflect.EnumDescriptor

func (ExecutionInfo_PostMethod) Enum 

func (x ExecutionInfo_PostMethod) Enum() *ExecutionInfo_PostMethod

func (ExecutionInfo_PostMethod) EnumDescriptor deprecated 

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

Deprecated: Use ExecutionInfo_PostMethod.Descriptor instead.

func (ExecutionInfo_PostMethod) Number 

func (x ExecutionInfo_PostMethod) Number() protoreflect.EnumNumber

func (ExecutionInfo_PostMethod) String 

func (x ExecutionInfo_PostMethod) String() string

func (ExecutionInfo_PostMethod) Type 

func (ExecutionInfo_PostMethod) Type() protoreflect.EnumType

type FailurePolicy 

type FailurePolicy struct {

	// Defines what happens to the task upon failure.
	RetryStrategy FailurePolicy_RetryStrategy `` /* 168-byte string literal not displayed */
	// Required if retry_strategy is FIXED_INTERVAL or
	// LINEAR/EXPONENTIAL_BACKOFF/RESTART_INTEGRATION_WITH_BACKOFF. Defines the
	// number of times the task will be retried if failed.
	MaxRetries int32 `protobuf:"varint,2,opt,name=max_retries,json=maxRetries,proto3" json:"max_retries,omitempty"`
	// Required if retry_strategy is FIXED_INTERVAL or
	// LINEAR/EXPONENTIAL_BACKOFF/RESTART_INTEGRATION_WITH_BACKOFF. Defines the
	// initial interval in seconds for backoff.
	IntervalTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=interval_time,json=intervalTime,proto3" json:"interval_time,omitempty"`
	// contains filtered or unexported fields
}

Policy that defines the task retry logic and failure type. If no FailurePolicy is defined for a task, all its dependent tasks will not be executed (i.e, a `retry_strategy` of NONE will be applied).

func (*FailurePolicy) Descriptor deprecated 

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

Deprecated: Use FailurePolicy.ProtoReflect.Descriptor instead.

func (*FailurePolicy) GetIntervalTime 

func (x *FailurePolicy) GetIntervalTime() *timestamppb.Timestamp

func (*FailurePolicy) GetMaxRetries 

func (x *FailurePolicy) GetMaxRetries() int32

func (*FailurePolicy) GetRetryStrategy 

func (x *FailurePolicy) GetRetryStrategy() FailurePolicy_RetryStrategy

func (*FailurePolicy) ProtoMessage 

func (*FailurePolicy) ProtoMessage()

func (*FailurePolicy) ProtoReflect 

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

func (*FailurePolicy) Reset 

func (x *FailurePolicy) Reset()

func (*FailurePolicy) String 

func (x *FailurePolicy) String() string

type FailurePolicy_RetryStrategy 

type FailurePolicy_RetryStrategy int32

The behavior when the taks failed. 

const (
	// UNSPECIFIED.
	FailurePolicy_RETRY_STRATEGY_UNSPECIFIED FailurePolicy_RetryStrategy = 0
	// Ignores the failure of this task. The rest of the integration will be
	// executed Assuming this task succeeded.
	FailurePolicy_IGNORE FailurePolicy_RetryStrategy = 1
	// Causes a permanent failure of the task. However, if the last task(s)
	// of event was successfully completed despite the failure of this task,
	// it has no impact on the integration.
	FailurePolicy_NONE FailurePolicy_RetryStrategy = 2
	// Causes a permanent failure of the event. It is different from NONE
	// because this will mark the event as FAILED by shutting down the
	// event execution.
	FailurePolicy_FATAL FailurePolicy_RetryStrategy = 3
	// The task will be retried from the failed task onwards after a fixed
	// delay. A max-retry count is required to be specified with this
	// strategy. A jitter is added to each exponential interval so that
	// concurrently failing tasks of the same type do not end up retrying
	// after the exact same exponential interval. max_retries and
	// interval_in_seconds must be specified.
	FailurePolicy_FIXED_INTERVAL FailurePolicy_RetryStrategy = 4
	// The task will be retried from the failed task onwards after a fixed
	// delay that linearly increases with each retry attempt. A jitter is
	// added to each exponential interval so that concurrently failing tasks
	// of the same type do not end up retrying after the exact same
	// exponential interval. A max-retry count is required to be specified
	// with this strategy. max_retries and interval_in_seconds must be
	// specified.
	FailurePolicy_LINEAR_BACKOFF FailurePolicy_RetryStrategy = 5
	// The task will be retried after an exponentially increasing period of
	// time with each failure. A jitter is added to each exponential interval
	// so that concurrently failing tasks of the same type do not end up
	// retrying after the exact same exponential interval. A max-retry count
	// is required to be specified with this strategy. `max_retries` and
	// `interval_in_seconds` must be specified.
	FailurePolicy_EXPONENTIAL_BACKOFF FailurePolicy_RetryStrategy = 6
	// The entire integration will be restarted with the initial parameters that
	// were set when the event was fired. A max-retry count is required to be
	// specified with this strategy. `max_retries` and `interval_in_seconds`
	// must be specified.
	FailurePolicy_RESTART_INTEGRATION_WITH_BACKOFF FailurePolicy_RetryStrategy = 7
)

func (FailurePolicy_RetryStrategy) Descriptor 

func (FailurePolicy_RetryStrategy) Descriptor() protoreflect.EnumDescriptor

func (FailurePolicy_RetryStrategy) Enum 

func (x FailurePolicy_RetryStrategy) Enum() *FailurePolicy_RetryStrategy

func (FailurePolicy_RetryStrategy) EnumDescriptor deprecated 

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

Deprecated: Use FailurePolicy_RetryStrategy.Descriptor instead.

func (FailurePolicy_RetryStrategy) Number 

func (x FailurePolicy_RetryStrategy) Number() protoreflect.EnumNumber

func (FailurePolicy_RetryStrategy) String 

func (x FailurePolicy_RetryStrategy) String() string

func (FailurePolicy_RetryStrategy) Type 

func (FailurePolicy_RetryStrategy) Type() protoreflect.EnumType

type IntParameterArray 

type IntParameterArray struct {

	// Integer array.
	IntValues []int64 `protobuf:"varint,1,rep,packed,name=int_values,json=intValues,proto3" json:"int_values,omitempty"`
	// contains filtered or unexported fields
}

This message only contains a field of integer array.

func (*IntParameterArray) Descriptor deprecated 

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

Deprecated: Use IntParameterArray.ProtoReflect.Descriptor instead.

func (*IntParameterArray) GetIntValues 

func (x *IntParameterArray) GetIntValues() []int64

func (*IntParameterArray) ProtoMessage 

func (*IntParameterArray) ProtoMessage()

func (*IntParameterArray) ProtoReflect 

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

func (*IntParameterArray) Reset 

func (x *IntParameterArray) Reset()

func (*IntParameterArray) String 

func (x *IntParameterArray) String() string

type JsonValidationOption 

type JsonValidationOption int32

Options for how to validate json schemas. 

const (
	// As per the default behavior, no validation will be run. Will not override
	// any option set in a Task.
	JsonValidationOption_JSON_VALIDATION_OPTION_UNSPECIFIED JsonValidationOption = 0
	// Do not run any validation against JSON schemas.
	JsonValidationOption_SKIP JsonValidationOption = 1
	// Validate all potential input JSON parameters against schemas specified in
	// IntegrationParameter.
	JsonValidationOption_PRE_EXECUTION JsonValidationOption = 2
	// Validate all potential output JSON parameters against schemas specified in
	// IntegrationParameter.
	JsonValidationOption_POST_EXECUTION JsonValidationOption = 3
	// Perform both PRE_EXECUTION and POST_EXECUTION validations.
	JsonValidationOption_PRE_POST_EXECUTION JsonValidationOption = 4
)

func (JsonValidationOption) Descriptor 

func (JsonValidationOption) Descriptor() protoreflect.EnumDescriptor

func (JsonValidationOption) Enum 

func (x JsonValidationOption) Enum() *JsonValidationOption

func (JsonValidationOption) EnumDescriptor deprecated 

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

Deprecated: Use JsonValidationOption.Descriptor instead.

func (JsonValidationOption) Number 

func (x JsonValidationOption) Number() protoreflect.EnumNumber

func (JsonValidationOption) String 

func (x JsonValidationOption) String() string

func (JsonValidationOption) Type 

func (JsonValidationOption) Type() protoreflect.EnumType

type NextTask 

type NextTask struct {

	// ID of the next task.
	TaskConfigId string `protobuf:"bytes,1,opt,name=task_config_id,json=taskConfigId,proto3" json:"task_config_id,omitempty"`
	// Task number of the next task.
	TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Standard filter expression for this task to become an eligible next task.
	Condition string `protobuf:"bytes,3,opt,name=condition,proto3" json:"condition,omitempty"`
	// User-provided label that is attached to this edge in the UI.
	DisplayName string `protobuf:"bytes,4,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// contains filtered or unexported fields
}

The task that is next in line to be executed, if the condition specified evaluated to true.

func (*NextTask) Descriptor deprecated 

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

Deprecated: Use NextTask.ProtoReflect.Descriptor instead.

func (*NextTask) GetCondition 

func (x *NextTask) GetCondition() string

func (*NextTask) GetDisplayName 

func (x *NextTask) GetDisplayName() string

func (*NextTask) GetTaskConfigId 

func (x *NextTask) GetTaskConfigId() string

func (*NextTask) GetTaskId 

func (x *NextTask) GetTaskId() string

func (*NextTask) ProtoMessage 

func (*NextTask) ProtoMessage()

func (*NextTask) ProtoReflect 

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

func (*NextTask) Reset 

func (x *NextTask) Reset()

func (*NextTask) String 

func (x *NextTask) String() string

type Product 

type Product int32

Enum Product. 

const (
	// Default value.
	Product_PRODUCT_UNSPECIFIED Product = 0
	// Integration Platform.
	Product_IP Product = 1
	// Apigee.
	Product_APIGEE Product = 2
	// Security Command Center.
	Product_SECURITY Product = 3
)

func (Product) Descriptor 

func (Product) Descriptor() protoreflect.EnumDescriptor

func (Product) Enum 

func (x Product) Enum() *Product

func (Product) EnumDescriptor deprecated 

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

Deprecated: Use Product.Descriptor instead.

func (Product) Number 

func (x Product) Number() protoreflect.EnumNumber

func (Product) String 

func (x Product) String() string

func (Product) Type 

func (Product) Type() protoreflect.EnumType

type StringParameterArray 

type StringParameterArray struct {

	// String array.
	StringValues []string `protobuf:"bytes,1,rep,name=string_values,json=stringValues,proto3" json:"string_values,omitempty"`
	// contains filtered or unexported fields
}

This message only contains a field of string array.

func (*StringParameterArray) Descriptor deprecated 

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

Deprecated: Use StringParameterArray.ProtoReflect.Descriptor instead.

func (*StringParameterArray) GetStringValues 

func (x *StringParameterArray) GetStringValues() []string

func (*StringParameterArray) ProtoMessage 

func (*StringParameterArray) ProtoMessage()

func (*StringParameterArray) ProtoReflect 

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

func (*StringParameterArray) Reset 

func (x *StringParameterArray) Reset()

func (*StringParameterArray) String 

func (x *StringParameterArray) String() string

type SuccessPolicy 

type SuccessPolicy struct {

	// State to which the execution snapshot status will be set if the task
	// succeeds.
	FinalState SuccessPolicy_FinalState `` /* 156-byte string literal not displayed */
	// contains filtered or unexported fields
}

Policy that dictates the behavior for the task after it completes successfully.

func (*SuccessPolicy) Descriptor deprecated 

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

Deprecated: Use SuccessPolicy.ProtoReflect.Descriptor instead.

func (*SuccessPolicy) GetFinalState 

func (x *SuccessPolicy) GetFinalState() SuccessPolicy_FinalState

func (*SuccessPolicy) ProtoMessage 

func (*SuccessPolicy) ProtoMessage()

func (*SuccessPolicy) ProtoReflect 

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

func (*SuccessPolicy) Reset 

func (x *SuccessPolicy) Reset()

func (*SuccessPolicy) String 

func (x *SuccessPolicy) String() string

type SuccessPolicy_FinalState 

type SuccessPolicy_FinalState int32

The state of execution. 

const (
	// UNSPECIFIED.
	SuccessPolicy_FINAL_STATE_UNSPECIFIED SuccessPolicy_FinalState = 0
	// The default behavior, where successful tasks will be marked as SUCCEEDED.
	SuccessPolicy_SUCCEEDED SuccessPolicy_FinalState = 1
	// Sets the state to SUSPENDED after executing.  This is required for
	// SuspensionTask; event execution will continue once the user calls
	// ResolveSuspensions with the event_execution_info_id and the task number.
	SuccessPolicy_SUSPENDED SuccessPolicy_FinalState = 2
)

func (SuccessPolicy_FinalState) Descriptor 

func (SuccessPolicy_FinalState) Descriptor() protoreflect.EnumDescriptor

func (SuccessPolicy_FinalState) Enum 

func (x SuccessPolicy_FinalState) Enum() *SuccessPolicy_FinalState

func (SuccessPolicy_FinalState) EnumDescriptor deprecated 

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

Deprecated: Use SuccessPolicy_FinalState.Descriptor instead.

func (SuccessPolicy_FinalState) Number 

func (x SuccessPolicy_FinalState) Number() protoreflect.EnumNumber

func (SuccessPolicy_FinalState) String 

func (x SuccessPolicy_FinalState) String() string

func (SuccessPolicy_FinalState) Type 

func (SuccessPolicy_FinalState) Type() protoreflect.EnumType

type TaskConfig 

type TaskConfig struct {

	// Optional. The name for the task.
	Task string `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	// Required. The identifier of this task within its parent event config,
	// specified by the client. This should be unique among all the tasks belong
	// to the same event config. We use this field as the identifier to
	// find next tasks (via field `next_tasks.task_id`).
	TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Optional. The customized parameters the user can pass to this task.
	Parameters map[string]*EventParameter `` /* 161-byte string literal not displayed */
	// Optional. Determines the number of times the
	// task will be retried on failure and with what retry strategy.
	// This is applicable for asynchronous calls to Eventbus alone (Post To
	// Queue, Schedule etc.).
	FailurePolicy *FailurePolicy `protobuf:"bytes,4,opt,name=failure_policy,json=failurePolicy,proto3" json:"failure_policy,omitempty"`
	// Optional. Determines the number of times the
	// task will be retried on failure and with what retry strategy.
	// This is applicable for synchronous calls to Eventbus alone (Post).
	SynchronousCallFailurePolicy *FailurePolicy `` /* 149-byte string literal not displayed */
	// Optional. The set of tasks that are next in line to be executed as per the
	// execution graph defined for the parent event, specified by
	// `event_config_id`. Each of these next tasks are executed
	// only if the condition associated with them evaluates to true.
	NextTasks []*NextTask `protobuf:"bytes,6,rep,name=next_tasks,json=nextTasks,proto3" json:"next_tasks,omitempty"`
	// Optional. The policy dictating the execution of the next set of tasks for the current
	// task.
	NextTasksExecutionPolicy TaskConfig_NextTasksExecutionPolicy `` /* 213-byte string literal not displayed */
	// Optional. The policy dictating the execution strategy of this task.
	TaskExecutionStrategy TaskConfig_TaskExecutionStrategy `` /* 199-byte string literal not displayed */
	// Optional. User-provided label that is attached to this TaskConfig in the UI.
	DisplayName string `protobuf:"bytes,9,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// Optional. Determines what action to take upon successful task completion.
	SuccessPolicy *SuccessPolicy `protobuf:"bytes,10,opt,name=success_policy,json=successPolicy,proto3" json:"success_policy,omitempty"`
	// Optional. If set, overrides the option configured in the Task implementation class.
	JsonValidationOption JsonValidationOption `` /* 185-byte string literal not displayed */
	// contains filtered or unexported fields
}

The task configuration details. This is not the implementation of Task. There might be multiple TaskConfigs for the same Task. (-- Next available id: 12 --)

func (*TaskConfig) Descriptor deprecated 

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

Deprecated: Use TaskConfig.ProtoReflect.Descriptor instead.

func (*TaskConfig) GetDisplayName 

func (x *TaskConfig) GetDisplayName() string

func (*TaskConfig) GetFailurePolicy 

func (x *TaskConfig) GetFailurePolicy() *FailurePolicy

func (*TaskConfig) GetJsonValidationOption 

func (x *TaskConfig) GetJsonValidationOption() JsonValidationOption

func (*TaskConfig) GetNextTasks 

func (x *TaskConfig) GetNextTasks() []*NextTask

func (*TaskConfig) GetNextTasksExecutionPolicy 

func (x *TaskConfig) GetNextTasksExecutionPolicy() TaskConfig_NextTasksExecutionPolicy

func (*TaskConfig) GetParameters 

func (x *TaskConfig) GetParameters() map[string]*EventParameter

func (*TaskConfig) GetSuccessPolicy 

func (x *TaskConfig) GetSuccessPolicy() *SuccessPolicy

func (*TaskConfig) GetSynchronousCallFailurePolicy 

func (x *TaskConfig) GetSynchronousCallFailurePolicy() *FailurePolicy

func (*TaskConfig) GetTask 

func (x *TaskConfig) GetTask() string

func (*TaskConfig) GetTaskExecutionStrategy 

func (x *TaskConfig) GetTaskExecutionStrategy() TaskConfig_TaskExecutionStrategy

func (*TaskConfig) GetTaskId 

func (x *TaskConfig) GetTaskId() string

func (*TaskConfig) ProtoMessage 

func (*TaskConfig) ProtoMessage()

func (*TaskConfig) ProtoReflect 

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

func (*TaskConfig) Reset 

func (x *TaskConfig) Reset()

func (*TaskConfig) String 

func (x *TaskConfig) String() string

type TaskConfig_NextTasksExecutionPolicy 

type TaskConfig_NextTasksExecutionPolicy int32

Various policies for executing the next set of tasks. 

const (
	// Default.
	TaskConfig_NEXT_TASKS_EXECUTION_POLICY_UNSPECIFIED TaskConfig_NextTasksExecutionPolicy = 0
	// Execute all the tasks that satisfy their associated condition.
	TaskConfig_RUN_ALL_MATCH TaskConfig_NextTasksExecutionPolicy = 1
	// Execute the first task that satisfies the associated condition.
	TaskConfig_RUN_FIRST_MATCH TaskConfig_NextTasksExecutionPolicy = 2
)

func (TaskConfig_NextTasksExecutionPolicy) Descriptor 

func (TaskConfig_NextTasksExecutionPolicy) Descriptor() protoreflect.EnumDescriptor

func (TaskConfig_NextTasksExecutionPolicy) Enum 

func (x TaskConfig_NextTasksExecutionPolicy) Enum() *TaskConfig_NextTasksExecutionPolicy

func (TaskConfig_NextTasksExecutionPolicy) EnumDescriptor deprecated 

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

Deprecated: Use TaskConfig_NextTasksExecutionPolicy.Descriptor instead.

func (TaskConfig_NextTasksExecutionPolicy) Number 

func (x TaskConfig_NextTasksExecutionPolicy) Number() protoreflect.EnumNumber

func (TaskConfig_NextTasksExecutionPolicy) String 

func (x TaskConfig_NextTasksExecutionPolicy) String() string

func (TaskConfig_NextTasksExecutionPolicy) Type 

func (TaskConfig_NextTasksExecutionPolicy) Type() protoreflect.EnumType

type TaskConfig_TaskExecutionStrategy 

type TaskConfig_TaskExecutionStrategy int32

Various policies to trigger the execution of this task. 

const (
	// Default. If the strategy is not set explicitly, it will default to
	// `WHEN_ALL_SUCCEED`.
	TaskConfig_TASK_EXECUTION_STRATEGY_UNSPECIFIED TaskConfig_TaskExecutionStrategy = 0
	// Wait until all of its previous tasks finished execution, then verify at
	// least one of the edge conditions is met, and execute if possible. This
	// should be considered as WHEN_ALL_TASKS_SUCCEED.
	TaskConfig_WHEN_ALL_SUCCEED TaskConfig_TaskExecutionStrategy = 1
	// Start execution as long as any of its previous tasks finished execution
	// and the corresponding edge condition is met (since we will execute if
	// only that succeeding edge condition is met).
	TaskConfig_WHEN_ANY_SUCCEED TaskConfig_TaskExecutionStrategy = 2
	// Wait until all of its previous tasks finished execution, then verify
	// the all edge conditions are met and execute if possible.
	TaskConfig_WHEN_ALL_TASKS_AND_CONDITIONS_SUCCEED TaskConfig_TaskExecutionStrategy = 3
)

func (TaskConfig_TaskExecutionStrategy) Descriptor 

func (TaskConfig_TaskExecutionStrategy) Descriptor() protoreflect.EnumDescriptor

func (TaskConfig_TaskExecutionStrategy) Enum 

func (x TaskConfig_TaskExecutionStrategy) Enum() *TaskConfig_TaskExecutionStrategy

func (TaskConfig_TaskExecutionStrategy) EnumDescriptor deprecated 

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

Deprecated: Use TaskConfig_TaskExecutionStrategy.Descriptor instead.

func (TaskConfig_TaskExecutionStrategy) Number 

func (x TaskConfig_TaskExecutionStrategy) Number() protoreflect.EnumNumber

func (TaskConfig_TaskExecutionStrategy) String 

func (x TaskConfig_TaskExecutionStrategy) String() string

func (TaskConfig_TaskExecutionStrategy) Type 

func (TaskConfig_TaskExecutionStrategy) Type() protoreflect.EnumType

type TaskExecutionDetails 

type TaskExecutionDetails struct {

	// Pointer to the task config it used for execution.
	TaskNumber string `protobuf:"bytes,1,opt,name=task_number,json=taskNumber,proto3" json:"task_number,omitempty"`
	// The execution state of this task.
	TaskExecutionState TaskExecutionDetails_TaskExecutionState `` /* 197-byte string literal not displayed */
	// Status for the current task execution attempt.
	TaskAttemptStats []*AttemptStats `protobuf:"bytes,3,rep,name=task_attempt_stats,json=taskAttemptStats,proto3" json:"task_attempt_stats,omitempty"`
	// contains filtered or unexported fields
}

Contains the details of the execution of this task.

func (*TaskExecutionDetails) Descriptor deprecated 

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

Deprecated: Use TaskExecutionDetails.ProtoReflect.Descriptor instead.

func (*TaskExecutionDetails) GetTaskAttemptStats 

func (x *TaskExecutionDetails) GetTaskAttemptStats() []*AttemptStats

func (*TaskExecutionDetails) GetTaskExecutionState 

func (x *TaskExecutionDetails) GetTaskExecutionState() TaskExecutionDetails_TaskExecutionState

func (*TaskExecutionDetails) GetTaskNumber 

func (x *TaskExecutionDetails) GetTaskNumber() string

func (*TaskExecutionDetails) ProtoMessage 

func (*TaskExecutionDetails) ProtoMessage()

func (*TaskExecutionDetails) ProtoReflect 

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

func (*TaskExecutionDetails) Reset 

func (x *TaskExecutionDetails) Reset()

func (*TaskExecutionDetails) String 

func (x *TaskExecutionDetails) String() string

type TaskExecutionDetails_TaskExecutionState 

type TaskExecutionDetails_TaskExecutionState int32

Enum TaskExecutionState. 

const (
	// Default value.
	TaskExecutionDetails_TASK_EXECUTION_STATE_UNSPECIFIED TaskExecutionDetails_TaskExecutionState = 0
	// Task is waiting for its precondition tasks to finish to start the
	// execution.
	TaskExecutionDetails_PENDING_EXECUTION TaskExecutionDetails_TaskExecutionState = 1
	// Task is under processing.
	TaskExecutionDetails_IN_PROCESS TaskExecutionDetails_TaskExecutionState = 2
	// Task execution successfully finished. There's no more change after
	// this state.
	TaskExecutionDetails_SUCCEED TaskExecutionDetails_TaskExecutionState = 3
	// Task execution failed. There's no more change after this state.
	TaskExecutionDetails_FAILED TaskExecutionDetails_TaskExecutionState = 4
	// Task execution failed and cause the whole event execution to fail
	// immediately. There's no more change after this state.
	TaskExecutionDetails_FATAL TaskExecutionDetails_TaskExecutionState = 5
	// Task execution failed and waiting for retry.
	TaskExecutionDetails_RETRY_ON_HOLD TaskExecutionDetails_TaskExecutionState = 6
	// Task execution skipped. This happens when its precondition wasn't met,
	// or the event execution been canceled before reach to the task.
	// There's no more changes after this state.
	TaskExecutionDetails_SKIPPED TaskExecutionDetails_TaskExecutionState = 7
	// Task execution canceled when in progress. This happens when event
	// execution been canceled or any other task fall in fatal state.
	TaskExecutionDetails_CANCELLED TaskExecutionDetails_TaskExecutionState = 8
	// Task is waiting for its dependency tasks' rollback to finish to start
	// its rollback.
	TaskExecutionDetails_PENDING_ROLLBACK TaskExecutionDetails_TaskExecutionState = 9
	// Task is rolling back.
	TaskExecutionDetails_ROLLBACK_IN_PROCESS TaskExecutionDetails_TaskExecutionState = 10
	// Task is rolled back. This is the state we will set regardless of
	// rollback succeeding or failing.
	TaskExecutionDetails_ROLLEDBACK TaskExecutionDetails_TaskExecutionState = 11
	// Task is a SuspensionTask which has executed once, creating a pending
	// suspension.
	TaskExecutionDetails_SUSPENDED TaskExecutionDetails_TaskExecutionState = 12
)

func (TaskExecutionDetails_TaskExecutionState) Descriptor 

func (TaskExecutionDetails_TaskExecutionState) Descriptor() protoreflect.EnumDescriptor

func (TaskExecutionDetails_TaskExecutionState) Enum 

func (x TaskExecutionDetails_TaskExecutionState) Enum() *TaskExecutionDetails_TaskExecutionState

func (TaskExecutionDetails_TaskExecutionState) EnumDescriptor deprecated 

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

Deprecated: Use TaskExecutionDetails_TaskExecutionState.Descriptor instead.

func (TaskExecutionDetails_TaskExecutionState) Number 

func (x TaskExecutionDetails_TaskExecutionState) Number() protoreflect.EnumNumber

func (TaskExecutionDetails_TaskExecutionState) String 

func (x TaskExecutionDetails_TaskExecutionState) String() string

func (TaskExecutionDetails_TaskExecutionState) Type 

func (TaskExecutionDetails_TaskExecutionState) Type() protoreflect.EnumType

type ValueType 

type ValueType struct {

	// Types that are assignable to Value:
	//	*ValueType_StringValue
	//	*ValueType_IntValue
	//	*ValueType_DoubleValue
	//	*ValueType_BooleanValue
	//	*ValueType_StringArray
	//	*ValueType_IntArray
	//	*ValueType_DoubleArray
	//	*ValueType_BooleanArray
	//	*ValueType_JsonValue
	Value isValueType_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

The type of the parameter.

func (*ValueType) Descriptor deprecated 

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

Deprecated: Use ValueType.ProtoReflect.Descriptor instead.

func (*ValueType) GetBooleanArray 

func (x *ValueType) GetBooleanArray() *BooleanParameterArray

func (*ValueType) GetBooleanValue 

func (x *ValueType) GetBooleanValue() bool

func (*ValueType) GetDoubleArray 

func (x *ValueType) GetDoubleArray() *DoubleParameterArray

func (*ValueType) GetDoubleValue 

func (x *ValueType) GetDoubleValue() float64

func (*ValueType) GetIntArray 

func (x *ValueType) GetIntArray() *IntParameterArray

func (*ValueType) GetIntValue 

func (x *ValueType) GetIntValue() int64

func (*ValueType) GetJsonValue 

func (x *ValueType) GetJsonValue() string

func (*ValueType) GetStringArray 

func (x *ValueType) GetStringArray() *StringParameterArray

func (*ValueType) GetStringValue 

func (x *ValueType) GetStringValue() string

func (*ValueType) GetValue 

func (m *ValueType) GetValue() isValueType_Value

func (*ValueType) ProtoMessage 

func (*ValueType) ProtoMessage()

func (*ValueType) ProtoReflect 

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

func (*ValueType) Reset 

func (x *ValueType) Reset()

func (*ValueType) String 

func (x *ValueType) String() string

type ValueType_BooleanArray 

type ValueType_BooleanArray struct {
	// Boolean Array.
	BooleanArray *BooleanParameterArray `protobuf:"bytes,8,opt,name=boolean_array,json=booleanArray,proto3,oneof"`
}

type ValueType_BooleanValue 

type ValueType_BooleanValue struct {
	// Boolean.
	BooleanValue bool `protobuf:"varint,4,opt,name=boolean_value,json=booleanValue,proto3,oneof"`
}

type ValueType_DoubleArray 

type ValueType_DoubleArray struct {
	// Double Number Array.
	DoubleArray *DoubleParameterArray `protobuf:"bytes,7,opt,name=double_array,json=doubleArray,proto3,oneof"`
}

type ValueType_DoubleValue 

type ValueType_DoubleValue struct {
	// Double Number.
	DoubleValue float64 `protobuf:"fixed64,3,opt,name=double_value,json=doubleValue,proto3,oneof"`
}

type ValueType_IntArray 

type ValueType_IntArray struct {
	// Integer Array.
	IntArray *IntParameterArray `protobuf:"bytes,6,opt,name=int_array,json=intArray,proto3,oneof"`
}

type ValueType_IntValue 

type ValueType_IntValue struct {
	// Integer.
	IntValue int64 `protobuf:"varint,2,opt,name=int_value,json=intValue,proto3,oneof"`
}

type ValueType_JsonValue 

type ValueType_JsonValue struct {
	// Json.
	JsonValue string `protobuf:"bytes,9,opt,name=json_value,json=jsonValue,proto3,oneof"`
}

type ValueType_StringArray 

type ValueType_StringArray struct {
	// String Array.
	StringArray *StringParameterArray `protobuf:"bytes,5,opt,name=string_array,json=stringArray,proto3,oneof"`
}

type ValueType_StringValue 

type ValueType_StringValue struct {
	// String.
	StringValue string `protobuf:"bytes,1,opt,name=string_value,json=stringValue,proto3,oneof"`
}

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.