Enum value maps for JsonValidationOption.
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 ExecutionInfo_PostMethod.
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 EventExecutionDetails_EventExecutionState.
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 TaskExecutionDetails_TaskExecutionState.
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 Product.
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 TaskConfig_NextTasksExecutionPolicy.
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_TaskExecutionStrategy.
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 SuccessPolicy_FinalState.
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 FailurePolicy_RetryStrategy.
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,
}
)
var File_google_cloud_integrations_v1alpha_event_parameter_proto protoreflect.FileDescriptor
var File_google_cloud_integrations_v1alpha_json_validation_proto protoreflect.FileDescriptor
var File_google_cloud_integrations_v1alpha_log_entries_proto protoreflect.FileDescriptor
var File_google_cloud_integrations_v1alpha_product_proto protoreflect.FileDescriptor
var File_google_cloud_integrations_v1alpha_task_config_proto protoreflect.FileDescriptor
var File_google_cloud_integrations_v1alpha_value_type_proto protoreflect.FileDescriptor
Status for the execution attempt.
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
}
func (*AttemptStats) Descriptor() ([]byte, []int)
Deprecated: Use AttemptStats.ProtoReflect.Descriptor instead.
func (x *AttemptStats) GetEndTime() *timestamppb.Timestamp
func (x *AttemptStats) GetStartTime() *timestamppb.Timestamp
func (*AttemptStats) ProtoMessage()
func (x *AttemptStats) ProtoReflect() protoreflect.Message
func (x *AttemptStats) Reset()
func (x *AttemptStats) String() string
This message only contains a field of boolean array.
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
}
func (*BooleanParameterArray) Descriptor() ([]byte, []int)
Deprecated: Use BooleanParameterArray.ProtoReflect.Descriptor instead.
func (x *BooleanParameterArray) GetBooleanValues() []bool
func (*BooleanParameterArray) ProtoMessage()
func (x *BooleanParameterArray) ProtoReflect() protoreflect.Message
func (x *BooleanParameterArray) Reset()
func (x *BooleanParameterArray) String() string
Contains the combined condition calculation results.
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
}
func (*ConditionResult) Descriptor() ([]byte, []int)
Deprecated: Use ConditionResult.ProtoReflect.Descriptor instead.
func (x *ConditionResult) GetCurrentTaskNumber() string
func (x *ConditionResult) GetNextTaskNumber() string
func (x *ConditionResult) GetResult() bool
func (*ConditionResult) ProtoMessage()
func (x *ConditionResult) ProtoReflect() protoreflect.Message
func (x *ConditionResult) Reset()
func (x *ConditionResult) String() string
This message only contains a field of double number array.
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
}
func (*DoubleParameterArray) Descriptor() ([]byte, []int)
Deprecated: Use DoubleParameterArray.ProtoReflect.Descriptor instead.
func (x *DoubleParameterArray) GetDoubleValues() []float64
func (*DoubleParameterArray) ProtoMessage()
func (x *DoubleParameterArray) ProtoReflect() protoreflect.Message
func (x *DoubleParameterArray) Reset()
func (x *DoubleParameterArray) String() string
An error, warning, or information message associated with an integration.
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
}
func (*ErrorDetail) Descriptor() ([]byte, []int)
Deprecated: Use ErrorDetail.ProtoReflect.Descriptor instead.
func (x *ErrorDetail) GetErrorMessage() string
func (x *ErrorDetail) GetTaskNumber() int32
func (*ErrorDetail) ProtoMessage()
func (x *ErrorDetail) ProtoReflect() protoreflect.Message
func (x *ErrorDetail) Reset()
func (x *ErrorDetail) String() string
Contains the details of the execution info of this event: this includes the tasks execution details plus the event execution statistics.
type EventExecutionDetails struct {
// The execution state of this event.
EventExecutionState EventExecutionDetails_EventExecutionState `protobuf:"varint,1,opt,name=event_execution_state,json=eventExecutionState,proto3,enum=google.cloud.integrations.v1alpha.EventExecutionDetails_EventExecutionState" json:"event_execution_state,omitempty"`
// After snapshot migration, this field will no longer be populated, but old
// execution snapshots will still be accessible.
EventExecutionSnapshot []*EventExecutionSnapshot `protobuf:"bytes,2,rep,name=event_execution_snapshot,json=eventExecutionSnapshot,proto3" json:"event_execution_snapshot,omitempty"`
// 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
}
func (*EventExecutionDetails) Descriptor() ([]byte, []int)
Deprecated: Use EventExecutionDetails.ProtoReflect.Descriptor instead.
func (x *EventExecutionDetails) GetEventAttemptStats() []*AttemptStats
func (x *EventExecutionDetails) GetEventExecutionSnapshot() []*EventExecutionSnapshot
func (x *EventExecutionDetails) GetEventExecutionState() EventExecutionDetails_EventExecutionState
func (x *EventExecutionDetails) GetEventRetriesCount() int32
func (x *EventExecutionDetails) GetNextExecutionTime() *timestamppb.Timestamp
func (*EventExecutionDetails) ProtoMessage()
func (x *EventExecutionDetails) ProtoReflect() protoreflect.Message
func (x *EventExecutionDetails) Reset()
func (x *EventExecutionDetails) String() string
Enum EventExecutionState.
type EventExecutionDetails_EventExecutionState int32
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() protoreflect.EnumDescriptor
func (x EventExecutionDetails_EventExecutionState) Enum() *EventExecutionDetails_EventExecutionState
func (EventExecutionDetails_EventExecutionState) EnumDescriptor() ([]byte, []int)
Deprecated: Use EventExecutionDetails_EventExecutionState.Descriptor instead.
func (x EventExecutionDetails_EventExecutionState) Number() protoreflect.EnumNumber
func (x EventExecutionDetails_EventExecutionState) String() string
func (EventExecutionDetails_EventExecutionState) Type() protoreflect.EnumType
Contains the snapshot of the event execution for a given checkpoint.
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 `protobuf:"bytes,3,opt,name=event_execution_snapshot_metadata,json=eventExecutionSnapshotMetadata,proto3" json:"event_execution_snapshot_metadata,omitempty"`
// 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 `protobuf:"bytes,6,rep,name=event_params,json=eventParams,proto3" json:"event_params,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
// The parameters in Event object that differs from last snapshot.
DiffParams map[string]*EventParameter `protobuf:"bytes,7,rep,name=diff_params,json=diffParams,proto3" json:"diff_params,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
// contains filtered or unexported fields
}
func (*EventExecutionSnapshot) Descriptor() ([]byte, []int)
Deprecated: Use EventExecutionSnapshot.ProtoReflect.Descriptor instead.
func (x *EventExecutionSnapshot) GetCheckpointTaskNumber() string
func (x *EventExecutionSnapshot) GetConditionResults() []*ConditionResult
func (x *EventExecutionSnapshot) GetDiffParams() map[string]*EventParameter
func (x *EventExecutionSnapshot) GetEventExecutionSnapshotMetadata() *EventExecutionSnapshot_EventExecutionSnapshotMetadata
func (x *EventExecutionSnapshot) GetEventParams() map[string]*EventParameter
func (x *EventExecutionSnapshot) GetSnapshotTime() *timestamppb.Timestamp
func (x *EventExecutionSnapshot) GetTaskExecutionDetails() []*TaskExecutionDetails
func (*EventExecutionSnapshot) ProtoMessage()
func (x *EventExecutionSnapshot) ProtoReflect() protoreflect.Message
func (x *EventExecutionSnapshot) Reset()
func (x *EventExecutionSnapshot) String() string
Metadata for the event/task retry.
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
}
func (*EventExecutionSnapshot_EventExecutionSnapshotMetadata) Descriptor() ([]byte, []int)
Deprecated: Use EventExecutionSnapshot_EventExecutionSnapshotMetadata.ProtoReflect.Descriptor instead.
func (x *EventExecutionSnapshot_EventExecutionSnapshotMetadata) GetEventAttemptNum() int32
func (x *EventExecutionSnapshot_EventExecutionSnapshotMetadata) GetTask() string
func (x *EventExecutionSnapshot_EventExecutionSnapshotMetadata) GetTaskAttemptNum() int32
func (x *EventExecutionSnapshot_EventExecutionSnapshotMetadata) GetTaskNumber() string
func (*EventExecutionSnapshot_EventExecutionSnapshotMetadata) ProtoMessage()
func (x *EventExecutionSnapshot_EventExecutionSnapshotMetadata) ProtoReflect() protoreflect.Message
func (x *EventExecutionSnapshot_EventExecutionSnapshotMetadata) Reset()
func (x *EventExecutionSnapshot_EventExecutionSnapshotMetadata) String() string
This message is used for processing and persisting (when applicable) key value pair parameters for each event in the event bus.
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
}
func (*EventParameter) Descriptor() ([]byte, []int)
Deprecated: Use EventParameter.ProtoReflect.Descriptor instead.
func (x *EventParameter) GetKey() string
func (x *EventParameter) GetValue() *ValueType
func (*EventParameter) ProtoMessage()
func (x *EventParameter) ProtoReflect() protoreflect.Message
func (x *EventParameter) Reset()
func (x *EventParameter) String() string
Log entry to log execution info for the monitored resource `integrations.googleapis.com/IntegrationVersion`.
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 `protobuf:"bytes,6,rep,name=request_params,json=requestParams,proto3" json:"request_params,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
// Event parameters come out as part of the response.
ResponseParams map[string]*EventParameter `protobuf:"bytes,7,rep,name=response_params,json=responseParams,proto3" json:"response_params,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
// The ways user posts this event.
PostMethod ExecutionInfo_PostMethod `protobuf:"varint,8,opt,name=post_method,json=postMethod,proto3,enum=google.cloud.integrations.v1alpha.ExecutionInfo_PostMethod" json:"post_method,omitempty"`
// The execution info about this event.
EventExecutionDetails *EventExecutionDetails `protobuf:"bytes,9,opt,name=event_execution_details,json=eventExecutionDetails,proto3" json:"event_execution_details,omitempty"`
// 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
}
func (*ExecutionInfo) Descriptor() ([]byte, []int)
Deprecated: Use ExecutionInfo.ProtoReflect.Descriptor instead.
func (x *ExecutionInfo) GetErrors() []*ErrorDetail
func (x *ExecutionInfo) GetEventExecutionDetails() *EventExecutionDetails
func (x *ExecutionInfo) GetEventExecutionInfoId() string
func (x *ExecutionInfo) GetIntegration() string
func (x *ExecutionInfo) GetIntegrationVersion() string
func (x *ExecutionInfo) GetPostMethod() ExecutionInfo_PostMethod
func (x *ExecutionInfo) GetProduct() Product
func (x *ExecutionInfo) GetProjectId() string
func (x *ExecutionInfo) GetRequestId() string
func (x *ExecutionInfo) GetRequestParams() map[string]*EventParameter
func (x *ExecutionInfo) GetResponseParams() map[string]*EventParameter
func (x *ExecutionInfo) GetTaskConfigs() []*TaskConfig
func (x *ExecutionInfo) GetTriggerId() string
func (*ExecutionInfo) ProtoMessage()
func (x *ExecutionInfo) ProtoReflect() protoreflect.Message
func (x *ExecutionInfo) Reset()
func (x *ExecutionInfo) String() string
PostMethod Enum
type ExecutionInfo_PostMethod int32
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() protoreflect.EnumDescriptor
func (x ExecutionInfo_PostMethod) Enum() *ExecutionInfo_PostMethod
func (ExecutionInfo_PostMethod) EnumDescriptor() ([]byte, []int)
Deprecated: Use ExecutionInfo_PostMethod.Descriptor instead.
func (x ExecutionInfo_PostMethod) Number() protoreflect.EnumNumber
func (x ExecutionInfo_PostMethod) String() string
func (ExecutionInfo_PostMethod) Type() protoreflect.EnumType
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).
type FailurePolicy struct {
// Defines what happens to the task upon failure.
RetryStrategy FailurePolicy_RetryStrategy `protobuf:"varint,1,opt,name=retry_strategy,json=retryStrategy,proto3,enum=google.cloud.integrations.v1alpha.FailurePolicy_RetryStrategy" json:"retry_strategy,omitempty"`
// 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
}
func (*FailurePolicy) Descriptor() ([]byte, []int)
Deprecated: Use FailurePolicy.ProtoReflect.Descriptor instead.
func (x *FailurePolicy) GetIntervalTime() *timestamppb.Timestamp
func (x *FailurePolicy) GetMaxRetries() int32
func (x *FailurePolicy) GetRetryStrategy() FailurePolicy_RetryStrategy
func (*FailurePolicy) ProtoMessage()
func (x *FailurePolicy) ProtoReflect() protoreflect.Message
func (x *FailurePolicy) Reset()
func (x *FailurePolicy) String() string
The behavior when the taks failed.
type FailurePolicy_RetryStrategy int32
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() protoreflect.EnumDescriptor
func (x FailurePolicy_RetryStrategy) Enum() *FailurePolicy_RetryStrategy
func (FailurePolicy_RetryStrategy) EnumDescriptor() ([]byte, []int)
Deprecated: Use FailurePolicy_RetryStrategy.Descriptor instead.
func (x FailurePolicy_RetryStrategy) Number() protoreflect.EnumNumber
func (x FailurePolicy_RetryStrategy) String() string
func (FailurePolicy_RetryStrategy) Type() protoreflect.EnumType
This message only contains a field of integer array.
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
}
func (*IntParameterArray) Descriptor() ([]byte, []int)
Deprecated: Use IntParameterArray.ProtoReflect.Descriptor instead.
func (x *IntParameterArray) GetIntValues() []int64
func (*IntParameterArray) ProtoMessage()
func (x *IntParameterArray) ProtoReflect() protoreflect.Message
func (x *IntParameterArray) Reset()
func (x *IntParameterArray) String() string
Options for how to validate json schemas.
type JsonValidationOption int32
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() protoreflect.EnumDescriptor
func (x JsonValidationOption) Enum() *JsonValidationOption
func (JsonValidationOption) EnumDescriptor() ([]byte, []int)
Deprecated: Use JsonValidationOption.Descriptor instead.
func (x JsonValidationOption) Number() protoreflect.EnumNumber
func (x JsonValidationOption) String() string
func (JsonValidationOption) Type() protoreflect.EnumType
The task that is next in line to be executed, if the condition specified evaluated to true.
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
}
func (*NextTask) Descriptor() ([]byte, []int)
Deprecated: Use NextTask.ProtoReflect.Descriptor instead.
func (x *NextTask) GetCondition() string
func (x *NextTask) GetDisplayName() string
func (x *NextTask) GetTaskConfigId() string
func (x *NextTask) GetTaskId() string
func (*NextTask) ProtoMessage()
func (x *NextTask) ProtoReflect() protoreflect.Message
func (x *NextTask) Reset()
func (x *NextTask) String() string
Enum Product.
type Product int32
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() protoreflect.EnumDescriptor
func (x Product) Enum() *Product
func (Product) EnumDescriptor() ([]byte, []int)
Deprecated: Use Product.Descriptor instead.
func (x Product) Number() protoreflect.EnumNumber
func (x Product) String() string
func (Product) Type() protoreflect.EnumType
This message only contains a field of string array.
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
}
func (*StringParameterArray) Descriptor() ([]byte, []int)
Deprecated: Use StringParameterArray.ProtoReflect.Descriptor instead.
func (x *StringParameterArray) GetStringValues() []string
func (*StringParameterArray) ProtoMessage()
func (x *StringParameterArray) ProtoReflect() protoreflect.Message
func (x *StringParameterArray) Reset()
func (x *StringParameterArray) String() string
Policy that dictates the behavior for the task after it completes successfully.
type SuccessPolicy struct {
// State to which the execution snapshot status will be set if the task
// succeeds.
FinalState SuccessPolicy_FinalState `protobuf:"varint,1,opt,name=final_state,json=finalState,proto3,enum=google.cloud.integrations.v1alpha.SuccessPolicy_FinalState" json:"final_state,omitempty"`
// contains filtered or unexported fields
}
func (*SuccessPolicy) Descriptor() ([]byte, []int)
Deprecated: Use SuccessPolicy.ProtoReflect.Descriptor instead.
func (x *SuccessPolicy) GetFinalState() SuccessPolicy_FinalState
func (*SuccessPolicy) ProtoMessage()
func (x *SuccessPolicy) ProtoReflect() protoreflect.Message
func (x *SuccessPolicy) Reset()
func (x *SuccessPolicy) String() string
The state of execution.
type SuccessPolicy_FinalState int32
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() protoreflect.EnumDescriptor
func (x SuccessPolicy_FinalState) Enum() *SuccessPolicy_FinalState
func (SuccessPolicy_FinalState) EnumDescriptor() ([]byte, []int)
Deprecated: Use SuccessPolicy_FinalState.Descriptor instead.
func (x SuccessPolicy_FinalState) Number() protoreflect.EnumNumber
func (x SuccessPolicy_FinalState) String() string
func (SuccessPolicy_FinalState) Type() protoreflect.EnumType
The task configuration details. This is not the implementation of Task. There might be multiple TaskConfigs for the same Task. (-- Next available id: 12 --)
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 `protobuf:"bytes,3,rep,name=parameters,proto3" json:"parameters,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
// 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 `protobuf:"bytes,5,opt,name=synchronous_call_failure_policy,json=synchronousCallFailurePolicy,proto3" json:"synchronous_call_failure_policy,omitempty"`
// 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 `protobuf:"varint,7,opt,name=next_tasks_execution_policy,json=nextTasksExecutionPolicy,proto3,enum=google.cloud.integrations.v1alpha.TaskConfig_NextTasksExecutionPolicy" json:"next_tasks_execution_policy,omitempty"`
// Optional. The policy dictating the execution strategy of this task.
TaskExecutionStrategy TaskConfig_TaskExecutionStrategy `protobuf:"varint,8,opt,name=task_execution_strategy,json=taskExecutionStrategy,proto3,enum=google.cloud.integrations.v1alpha.TaskConfig_TaskExecutionStrategy" json:"task_execution_strategy,omitempty"`
// 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 `protobuf:"varint,11,opt,name=json_validation_option,json=jsonValidationOption,proto3,enum=google.cloud.integrations.v1alpha.JsonValidationOption" json:"json_validation_option,omitempty"`
// contains filtered or unexported fields
}
func (*TaskConfig) Descriptor() ([]byte, []int)
Deprecated: Use TaskConfig.ProtoReflect.Descriptor instead.
func (x *TaskConfig) GetDisplayName() string
func (x *TaskConfig) GetFailurePolicy() *FailurePolicy
func (x *TaskConfig) GetJsonValidationOption() JsonValidationOption
func (x *TaskConfig) GetNextTasks() []*NextTask
func (x *TaskConfig) GetNextTasksExecutionPolicy() TaskConfig_NextTasksExecutionPolicy
func (x *TaskConfig) GetParameters() map[string]*EventParameter
func (x *TaskConfig) GetSuccessPolicy() *SuccessPolicy
func (x *TaskConfig) GetSynchronousCallFailurePolicy() *FailurePolicy
func (x *TaskConfig) GetTask() string
func (x *TaskConfig) GetTaskExecutionStrategy() TaskConfig_TaskExecutionStrategy
func (x *TaskConfig) GetTaskId() string
func (*TaskConfig) ProtoMessage()
func (x *TaskConfig) ProtoReflect() protoreflect.Message
func (x *TaskConfig) Reset()
func (x *TaskConfig) String() string
Various policies for executing the next set of tasks.
type TaskConfig_NextTasksExecutionPolicy int32
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() protoreflect.EnumDescriptor
func (x TaskConfig_NextTasksExecutionPolicy) Enum() *TaskConfig_NextTasksExecutionPolicy
func (TaskConfig_NextTasksExecutionPolicy) EnumDescriptor() ([]byte, []int)
Deprecated: Use TaskConfig_NextTasksExecutionPolicy.Descriptor instead.
func (x TaskConfig_NextTasksExecutionPolicy) Number() protoreflect.EnumNumber
func (x TaskConfig_NextTasksExecutionPolicy) String() string
func (TaskConfig_NextTasksExecutionPolicy) Type() protoreflect.EnumType
Various policies to trigger the execution of this task.
type TaskConfig_TaskExecutionStrategy int32
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() protoreflect.EnumDescriptor
func (x TaskConfig_TaskExecutionStrategy) Enum() *TaskConfig_TaskExecutionStrategy
func (TaskConfig_TaskExecutionStrategy) EnumDescriptor() ([]byte, []int)
Deprecated: Use TaskConfig_TaskExecutionStrategy.Descriptor instead.
func (x TaskConfig_TaskExecutionStrategy) Number() protoreflect.EnumNumber
func (x TaskConfig_TaskExecutionStrategy) String() string
func (TaskConfig_TaskExecutionStrategy) Type() protoreflect.EnumType
Contains the details of the execution of this task.
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 `protobuf:"varint,2,opt,name=task_execution_state,json=taskExecutionState,proto3,enum=google.cloud.integrations.v1alpha.TaskExecutionDetails_TaskExecutionState" json:"task_execution_state,omitempty"`
// 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
}
func (*TaskExecutionDetails) Descriptor() ([]byte, []int)
Deprecated: Use TaskExecutionDetails.ProtoReflect.Descriptor instead.
func (x *TaskExecutionDetails) GetTaskAttemptStats() []*AttemptStats
func (x *TaskExecutionDetails) GetTaskExecutionState() TaskExecutionDetails_TaskExecutionState
func (x *TaskExecutionDetails) GetTaskNumber() string
func (*TaskExecutionDetails) ProtoMessage()
func (x *TaskExecutionDetails) ProtoReflect() protoreflect.Message
func (x *TaskExecutionDetails) Reset()
func (x *TaskExecutionDetails) String() string
Enum TaskExecutionState.
type TaskExecutionDetails_TaskExecutionState int32
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() protoreflect.EnumDescriptor
func (x TaskExecutionDetails_TaskExecutionState) Enum() *TaskExecutionDetails_TaskExecutionState
func (TaskExecutionDetails_TaskExecutionState) EnumDescriptor() ([]byte, []int)
Deprecated: Use TaskExecutionDetails_TaskExecutionState.Descriptor instead.
func (x TaskExecutionDetails_TaskExecutionState) Number() protoreflect.EnumNumber
func (x TaskExecutionDetails_TaskExecutionState) String() string
func (TaskExecutionDetails_TaskExecutionState) Type() protoreflect.EnumType
The type of the parameter.
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
}
func (*ValueType) Descriptor() ([]byte, []int)
Deprecated: Use ValueType.ProtoReflect.Descriptor instead.
func (x *ValueType) GetBooleanArray() *BooleanParameterArray
func (x *ValueType) GetBooleanValue() bool
func (x *ValueType) GetDoubleArray() *DoubleParameterArray
func (x *ValueType) GetDoubleValue() float64
func (x *ValueType) GetIntArray() *IntParameterArray
func (x *ValueType) GetIntValue() int64
func (x *ValueType) GetJsonValue() string
func (x *ValueType) GetStringArray() *StringParameterArray
func (x *ValueType) GetStringValue() string
func (m *ValueType) GetValue() isValueType_Value
func (*ValueType) ProtoMessage()
func (x *ValueType) ProtoReflect() protoreflect.Message
func (x *ValueType) Reset()
func (x *ValueType) String() string
type ValueType_BooleanArray struct {
// Boolean Array.
BooleanArray *BooleanParameterArray `protobuf:"bytes,8,opt,name=boolean_array,json=booleanArray,proto3,oneof"`
}
type ValueType_BooleanValue struct {
// Boolean.
BooleanValue bool `protobuf:"varint,4,opt,name=boolean_value,json=booleanValue,proto3,oneof"`
}
type ValueType_DoubleArray struct {
// Double Number Array.
DoubleArray *DoubleParameterArray `protobuf:"bytes,7,opt,name=double_array,json=doubleArray,proto3,oneof"`
}
type ValueType_DoubleValue struct {
// Double Number.
DoubleValue float64 `protobuf:"fixed64,3,opt,name=double_value,json=doubleValue,proto3,oneof"`
}
type ValueType_IntArray struct {
// Integer Array.
IntArray *IntParameterArray `protobuf:"bytes,6,opt,name=int_array,json=intArray,proto3,oneof"`
}
type ValueType_IntValue struct {
// Integer.
IntValue int64 `protobuf:"varint,2,opt,name=int_value,json=intValue,proto3,oneof"`
}
type ValueType_JsonValue struct {
// Json.
JsonValue string `protobuf:"bytes,9,opt,name=json_value,json=jsonValue,proto3,oneof"`
}
type ValueType_StringArray struct {
// String Array.
StringArray *StringParameterArray `protobuf:"bytes,5,opt,name=string_array,json=stringArray,proto3,oneof"`
}
type ValueType_StringValue struct {
// String.
StringValue string `protobuf:"bytes,1,opt,name=string_value,json=stringValue,proto3,oneof"`
}