IWF-105: Add event logger (#480)

indeedeng · Nov 18, 2024 · cb0d67c · cb0d67c
1 parent aa564e1
commit cb0d67c
Show file tree

Hide file tree

Showing 14 changed files with 989 additions and 25 deletions.
diff --git a/gen/iwfidl/.openapi-generator/FILES b/gen/iwfidl/.openapi-generator/FILES
@@ -17,13 +17,15 @@ docs/DefaultApi.md
 docs/EncodedObject.md
 docs/ErrorResponse.md
 docs/ErrorSubStatus.md
+docs/EventType.md
 docs/ExecuteApiFailurePolicy.md
 docs/ExecutingStateIdMode.md
 docs/HealthInfo.md
 docs/IDReusePolicy.md
 docs/InterStateChannelCommand.md
 docs/InterStateChannelPublishing.md
 docs/InterStateChannelResult.md
+docs/IwfEvent.md
 docs/KeyValue.md
 docs/PersistenceLoadingPolicy.md
 docs/PersistenceLoadingType.md
@@ -99,13 +101,15 @@ model_decider_trigger_type.go
 model_encoded_object.go
 model_error_response.go
 model_error_sub_status.go
+model_event_type.go
 model_execute_api_failure_policy.go
 model_executing_state_id_mode.go
 model_health_info.go
 model_id_reuse_policy.go
 model_inter_state_channel_command.go
 model_inter_state_channel_publishing.go
 model_inter_state_channel_result.go
+model_iwf_event.go
 model_key_value.go
 model_persistence_loading_policy.go
 model_persistence_loading_type.go

diff --git a/gen/iwfidl/README.md b/gen/iwfidl/README.md
@@ -112,13 +112,15 @@ Class | Method | HTTP request | Description
  - [EncodedObject](docs/EncodedObject.md)
  - [ErrorResponse](docs/ErrorResponse.md)
  - [ErrorSubStatus](docs/ErrorSubStatus.md)
+ - [EventType](docs/EventType.md)
  - [ExecuteApiFailurePolicy](docs/ExecuteApiFailurePolicy.md)
  - [ExecutingStateIdMode](docs/ExecutingStateIdMode.md)
  - [HealthInfo](docs/HealthInfo.md)
  - [IDReusePolicy](docs/IDReusePolicy.md)
  - [InterStateChannelCommand](docs/InterStateChannelCommand.md)
  - [InterStateChannelPublishing](docs/InterStateChannelPublishing.md)
  - [InterStateChannelResult](docs/InterStateChannelResult.md)
+ - [IwfEvent](docs/IwfEvent.md)
  - [KeyValue](docs/KeyValue.md)
  - [PersistenceLoadingPolicy](docs/PersistenceLoadingPolicy.md)
  - [PersistenceLoadingType](docs/PersistenceLoadingType.md)

diff --git a/gen/iwfidl/api/openapi.yaml b/gen/iwfidl/api/openapi.yaml
@@ -3303,3 +3303,45 @@ components:
       - workflowRunId
       - workflowStartedTimestamp
       type: object
+    EventType:
+      enum:
+      - STATE_EXECUTE_ATTEMPT_FAIL_EVENT
+      - STATE_EXECUTE_ATTEMPT_SUCC_EVENT
+      - STATE_EXECUTE_EE_COMPLETE_EVENT
+      - STATE_EXECUTE_EE_FAIL_EVENT
+      - STATE_EXECUTE_EE_START_EVENT
+      - STATE_WAIT_UNTIL_ATTEMPT_FAIL_EVENT
+      - STATE_WAIT_UNTIL_ATTEMPT_SUCC_EVENT
+      - STATE_WAIT_UNTIL_EE_COMPLETE_EVENT
+      - STATE_WAIT_UNTIL_EE_FAIL_EVENT
+      - STATE_WAIT_UNTIL_EE_START_EVENT
+      - WORKFLOW_COMPLETE_EVENT
+      - WORKFLOW_FAIL_EVENT
+      - WORKFLOW_START_EVENT
+      type: string
+    IwfEvent:
+      properties:
+        eventType:
+          $ref: '#/components/schemas/EventType'
+        workflowType:
+          type: string
+        workflowId:
+          type: string
+        workflowRunId:
+          type: string
+        stateId:
+          type: string
+        stateExecutionId:
+          type: string
+        startTimestampInMs:
+          format: int64
+          type: integer
+        endTimestampInMs:
+          format: int64
+          type: integer
+      required:
+      - eventType
+      - workflowId
+      - workflowRunId
+      - workflowType
+      type: object
diff --git a/gen/iwfidl/docs/EventType.md b/gen/iwfidl/docs/EventType.md
@@ -0,0 +1,35 @@
+# EventType
+
+## Enum
+
+
+* `STATE_EXECUTE_ATTEMPT_FAIL_EVENT` (value: `"STATE_EXECUTE_ATTEMPT_FAIL_EVENT"`)
+
+* `STATE_EXECUTE_ATTEMPT_SUCC_EVENT` (value: `"STATE_EXECUTE_ATTEMPT_SUCC_EVENT"`)
+
+* `STATE_EXECUTE_EE_COMPLETE_EVENT` (value: `"STATE_EXECUTE_EE_COMPLETE_EVENT"`)
+
+* `STATE_EXECUTE_EE_FAIL_EVENT` (value: `"STATE_EXECUTE_EE_FAIL_EVENT"`)
+
+* `STATE_EXECUTE_EE_START_EVENT` (value: `"STATE_EXECUTE_EE_START_EVENT"`)
+
+* `STATE_WAIT_UNTIL_ATTEMPT_FAIL_EVENT` (value: `"STATE_WAIT_UNTIL_ATTEMPT_FAIL_EVENT"`)
+
+* `STATE_WAIT_UNTIL_ATTEMPT_SUCC_EVENT` (value: `"STATE_WAIT_UNTIL_ATTEMPT_SUCC_EVENT"`)
+
+* `STATE_WAIT_UNTIL_EE_COMPLETE_EVENT` (value: `"STATE_WAIT_UNTIL_EE_COMPLETE_EVENT"`)
+
+* `STATE_WAIT_UNTIL_EE_FAIL_EVENT` (value: `"STATE_WAIT_UNTIL_EE_FAIL_EVENT"`)
+
+* `STATE_WAIT_UNTIL_EE_START_EVENT` (value: `"STATE_WAIT_UNTIL_EE_START_EVENT"`)
+
+* `WORKFLOW_COMPLETE_EVENT` (value: `"WORKFLOW_COMPLETE_EVENT"`)
+
+* `WORKFLOW_FAIL_EVENT` (value: `"WORKFLOW_FAIL_EVENT"`)
+
+* `WORKFLOW_START_EVENT` (value: `"WORKFLOW_START_EVENT"`)
+
+
+[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md)
+
+
diff --git a/gen/iwfidl/docs/IwfEvent.md b/gen/iwfidl/docs/IwfEvent.md
@@ -0,0 +1,218 @@
+# IwfEvent
+
+## Properties
+
+Name | Type | Description | Notes
+------------ | ------------- | ------------- | -------------
+**EventType** | [**EventType**](EventType.md) |  | 
+**WorkflowType** | **string** |  | 
+**WorkflowId** | **string** |  | 
+**WorkflowRunId** | **string** |  | 
+**StateId** | Pointer to **string** |  | [optional] 
+**StateExecutionId** | Pointer to **string** |  | [optional] 
+**StartTimestampInMs** | Pointer to **int64** |  | [optional] 
+**EndTimestampInMs** | Pointer to **int64** |  | [optional] 
+
+## Methods
+
+### NewIwfEvent
+
+`func NewIwfEvent(eventType EventType, workflowType string, workflowId string, workflowRunId string, ) *IwfEvent`
+
+NewIwfEvent instantiates a new IwfEvent object
+This constructor will assign default values to properties that have it defined,
+and makes sure properties required by API are set, but the set of arguments
+will change when the set of required properties is changed
+
+### NewIwfEventWithDefaults
+
+`func NewIwfEventWithDefaults() *IwfEvent`
+
+NewIwfEventWithDefaults instantiates a new IwfEvent object
+This constructor will only assign default values to properties that have it defined,
+but it doesn't guarantee that properties required by API are set
+
+### GetEventType
+
+`func (o *IwfEvent) GetEventType() EventType`
+
+GetEventType returns the EventType field if non-nil, zero value otherwise.
+
+### GetEventTypeOk
+
+`func (o *IwfEvent) GetEventTypeOk() (*EventType, bool)`
+
+GetEventTypeOk returns a tuple with the EventType field if it's non-nil, zero value otherwise
+and a boolean to check if the value has been set.
+
+### SetEventType
+
+`func (o *IwfEvent) SetEventType(v EventType)`
+
+SetEventType sets EventType field to given value.
+
+
+### GetWorkflowType
+
+`func (o *IwfEvent) GetWorkflowType() string`
+
+GetWorkflowType returns the WorkflowType field if non-nil, zero value otherwise.
+
+### GetWorkflowTypeOk
+
+`func (o *IwfEvent) GetWorkflowTypeOk() (*string, bool)`
+
+GetWorkflowTypeOk returns a tuple with the WorkflowType field if it's non-nil, zero value otherwise
+and a boolean to check if the value has been set.
+
+### SetWorkflowType
+
+`func (o *IwfEvent) SetWorkflowType(v string)`
+
+SetWorkflowType sets WorkflowType field to given value.
+
+
+### GetWorkflowId
+
+`func (o *IwfEvent) GetWorkflowId() string`
+
+GetWorkflowId returns the WorkflowId field if non-nil, zero value otherwise.
+
+### GetWorkflowIdOk
+
+`func (o *IwfEvent) GetWorkflowIdOk() (*string, bool)`
+
+GetWorkflowIdOk returns a tuple with the WorkflowId field if it's non-nil, zero value otherwise
+and a boolean to check if the value has been set.
+
+### SetWorkflowId
+
+`func (o *IwfEvent) SetWorkflowId(v string)`
+
+SetWorkflowId sets WorkflowId field to given value.
+
+
+### GetWorkflowRunId
+
+`func (o *IwfEvent) GetWorkflowRunId() string`
+
+GetWorkflowRunId returns the WorkflowRunId field if non-nil, zero value otherwise.
+
+### GetWorkflowRunIdOk
+
+`func (o *IwfEvent) GetWorkflowRunIdOk() (*string, bool)`
+
+GetWorkflowRunIdOk returns a tuple with the WorkflowRunId field if it's non-nil, zero value otherwise
+and a boolean to check if the value has been set.
+
+### SetWorkflowRunId
+
+`func (o *IwfEvent) SetWorkflowRunId(v string)`
+
+SetWorkflowRunId sets WorkflowRunId field to given value.
+
+
+### GetStateId
+
+`func (o *IwfEvent) GetStateId() string`
+
+GetStateId returns the StateId field if non-nil, zero value otherwise.
+
+### GetStateIdOk
+
+`func (o *IwfEvent) GetStateIdOk() (*string, bool)`
+
+GetStateIdOk returns a tuple with the StateId field if it's non-nil, zero value otherwise
+and a boolean to check if the value has been set.
+
+### SetStateId
+
+`func (o *IwfEvent) SetStateId(v string)`
+
+SetStateId sets StateId field to given value.
+
+### HasStateId
+
+`func (o *IwfEvent) HasStateId() bool`
+
+HasStateId returns a boolean if a field has been set.
+
+### GetStateExecutionId
+
+`func (o *IwfEvent) GetStateExecutionId() string`
+
+GetStateExecutionId returns the StateExecutionId field if non-nil, zero value otherwise.
+
+### GetStateExecutionIdOk
+
+`func (o *IwfEvent) GetStateExecutionIdOk() (*string, bool)`
+
+GetStateExecutionIdOk returns a tuple with the StateExecutionId field if it's non-nil, zero value otherwise
+and a boolean to check if the value has been set.
+
+### SetStateExecutionId
+
+`func (o *IwfEvent) SetStateExecutionId(v string)`
+
+SetStateExecutionId sets StateExecutionId field to given value.
+
+### HasStateExecutionId
+
+`func (o *IwfEvent) HasStateExecutionId() bool`
+
+HasStateExecutionId returns a boolean if a field has been set.
+
+### GetStartTimestampInMs
+
+`func (o *IwfEvent) GetStartTimestampInMs() int64`
+
+GetStartTimestampInMs returns the StartTimestampInMs field if non-nil, zero value otherwise.
+
+### GetStartTimestampInMsOk
+
+`func (o *IwfEvent) GetStartTimestampInMsOk() (*int64, bool)`
+
+GetStartTimestampInMsOk returns a tuple with the StartTimestampInMs field if it's non-nil, zero value otherwise
+and a boolean to check if the value has been set.
+
+### SetStartTimestampInMs
+
+`func (o *IwfEvent) SetStartTimestampInMs(v int64)`
+
+SetStartTimestampInMs sets StartTimestampInMs field to given value.
+
+### HasStartTimestampInMs
+
+`func (o *IwfEvent) HasStartTimestampInMs() bool`
+
+HasStartTimestampInMs returns a boolean if a field has been set.
+
+### GetEndTimestampInMs
+
+`func (o *IwfEvent) GetEndTimestampInMs() int64`
+
+GetEndTimestampInMs returns the EndTimestampInMs field if non-nil, zero value otherwise.
+
+### GetEndTimestampInMsOk
+
+`func (o *IwfEvent) GetEndTimestampInMsOk() (*int64, bool)`
+
+GetEndTimestampInMsOk returns a tuple with the EndTimestampInMs field if it's non-nil, zero value otherwise
+and a boolean to check if the value has been set.
+
+### SetEndTimestampInMs
+
+`func (o *IwfEvent) SetEndTimestampInMs(v int64)`
+
+SetEndTimestampInMs sets EndTimestampInMs field to given value.
+
+### HasEndTimestampInMs
+
+`func (o *IwfEvent) HasEndTimestampInMs() bool`
+
+HasEndTimestampInMs returns a boolean if a field has been set.
+
+
+[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md)
+
+