Versions in this module Expand all Collapse all v0 v0.0.2 Nov 20, 2023 Changes in this version + var AllowedAttributeWriteConflictModeEnumValues = []AttributeWriteConflictMode + var AllowedCommandStatusEnumValues = []CommandStatus + var AllowedCommandWaitingTypeEnumValues = []CommandWaitingType + var AllowedProcessExecutionStopTypeEnumValues = []ProcessExecutionStopType + var AllowedProcessIdReusePolicyEnumValues = []ProcessIdReusePolicy + var AllowedProcessStatusEnumValues = []ProcessStatus + var AllowedStateApiTypeEnumValues = []StateApiType + var AllowedStateFailureRecoveryPolicyEnumValues = []StateFailureRecoveryPolicy + var AllowedTableReadLockingPolicyEnumValues = []TableReadLockingPolicy + var AllowedThreadCloseTypeEnumValues = []ThreadCloseType + var ContextOperationServerIndices = contextKey("serverOperationIndices") + var ContextOperationServerVariables = contextKey("serverOperationVariables") + var ContextServerIndex = contextKey("serverIndex") + var ContextServerVariables = contextKey("serverVariables") + var JsonCheck = regexp.MustCompile(`(?i:(?:application|text)/(?:[^;]+\+)?json)`) + var XmlCheck = regexp.MustCompile(`(?i:(?:application|text)/(?:[^;]+\+)?xml)`) + func CacheExpires(r *http.Response) time.Time + func IsNil(i interface{}) bool + func PtrBool(v bool) *bool + func PtrFloat32(v float32) *float32 + func PtrFloat64(v float64) *float64 + func PtrInt(v int) *int + func PtrInt32(v int32) *int32 + func PtrInt64(v int64) *int64 + func PtrString(v string) *string + func PtrTime(v time.Time) *time.Time + type APIClient struct + DefaultAPI DefaultAPI + func NewAPIClient(cfg *Configuration) *APIClient + func (c *APIClient) GetConfig() *Configuration + type APIKey struct + Key string + Prefix string + type APIResponse struct + Message string + Method string + Operation string + Payload []byte + RequestURL string + func NewAPIResponse(r *http.Response) *APIResponse + func NewAPIResponseWithError(errorMessage string) *APIResponse + type ApiApiV1XcherryServiceProcessExecutionDescribePostRequest struct + ApiService DefaultAPI + func (r ApiApiV1XcherryServiceProcessExecutionDescribePostRequest) Execute() (*ProcessExecutionDescribeResponse, *http.Response, error) + func (r ApiApiV1XcherryServiceProcessExecutionDescribePostRequest) ProcessExecutionDescribeRequest(processExecutionDescribeRequest ProcessExecutionDescribeRequest) ApiApiV1XcherryServiceProcessExecutionDescribePostRequest + type ApiApiV1XcherryServiceProcessExecutionPublishToLocalQueuePostRequest struct + ApiService DefaultAPI + func (r ApiApiV1XcherryServiceProcessExecutionPublishToLocalQueuePostRequest) Execute() (*http.Response, error) + func (r ApiApiV1XcherryServiceProcessExecutionPublishToLocalQueuePostRequest) PublishToLocalQueueRequest(publishToLocalQueueRequest PublishToLocalQueueRequest) ApiApiV1XcherryServiceProcessExecutionPublishToLocalQueuePostRequest + type ApiApiV1XcherryServiceProcessExecutionRpcPostRequest struct + ApiService DefaultAPI + func (r ApiApiV1XcherryServiceProcessExecutionRpcPostRequest) Execute() (*ProcessExecutionRpcResponse, *http.Response, error) + func (r ApiApiV1XcherryServiceProcessExecutionRpcPostRequest) ProcessExecutionRpcRequest(processExecutionRpcRequest ProcessExecutionRpcRequest) ApiApiV1XcherryServiceProcessExecutionRpcPostRequest + type ApiApiV1XcherryServiceProcessExecutionStartPostRequest struct + ApiService DefaultAPI + func (r ApiApiV1XcherryServiceProcessExecutionStartPostRequest) Execute() (*ProcessExecutionStartResponse, *http.Response, error) + func (r ApiApiV1XcherryServiceProcessExecutionStartPostRequest) ProcessExecutionStartRequest(processExecutionStartRequest ProcessExecutionStartRequest) ApiApiV1XcherryServiceProcessExecutionStartPostRequest + type ApiApiV1XcherryServiceProcessExecutionStopPostRequest struct + ApiService DefaultAPI + func (r ApiApiV1XcherryServiceProcessExecutionStopPostRequest) Execute() (*http.Response, error) + func (r ApiApiV1XcherryServiceProcessExecutionStopPostRequest) ProcessExecutionStopRequest(processExecutionStopRequest ProcessExecutionStopRequest) ApiApiV1XcherryServiceProcessExecutionStopPostRequest + type ApiApiV1XcherryWorkerAsyncStateExecutePostRequest struct + ApiService DefaultAPI + func (r ApiApiV1XcherryWorkerAsyncStateExecutePostRequest) AsyncStateExecuteRequest(asyncStateExecuteRequest AsyncStateExecuteRequest) ApiApiV1XcherryWorkerAsyncStateExecutePostRequest + func (r ApiApiV1XcherryWorkerAsyncStateExecutePostRequest) Execute() (*AsyncStateExecuteResponse, *http.Response, error) + type ApiApiV1XcherryWorkerAsyncStateWaitUntilPostRequest struct + ApiService DefaultAPI + func (r ApiApiV1XcherryWorkerAsyncStateWaitUntilPostRequest) AsyncStateWaitUntilRequest(asyncStateWaitUntilRequest AsyncStateWaitUntilRequest) ApiApiV1XcherryWorkerAsyncStateWaitUntilPostRequest + func (r ApiApiV1XcherryWorkerAsyncStateWaitUntilPostRequest) Execute() (*AsyncStateWaitUntilResponse, *http.Response, error) + type ApiApiV1XcherryWorkerProcessRpcPostRequest struct + ApiService DefaultAPI + func (r ApiApiV1XcherryWorkerProcessRpcPostRequest) Execute() (*ProcessRpcWorkerResponse, *http.Response, error) + func (r ApiApiV1XcherryWorkerProcessRpcPostRequest) ProcessRpcWorkerRequest(processRpcWorkerRequest ProcessRpcWorkerRequest) ApiApiV1XcherryWorkerProcessRpcPostRequest + type ApiErrorResponse struct + Detail *string + OriginalWorkerErrorDetail *string + OriginalWorkerErrorStatus *int32 + OriginalWorkerErrorType *string + func NewApiErrorResponse() *ApiErrorResponse + func NewApiErrorResponseWithDefaults() *ApiErrorResponse + func (o *ApiErrorResponse) GetDetail() string + func (o *ApiErrorResponse) GetDetailOk() (*string, bool) + func (o *ApiErrorResponse) GetOriginalWorkerErrorDetail() string + func (o *ApiErrorResponse) GetOriginalWorkerErrorDetailOk() (*string, bool) + func (o *ApiErrorResponse) GetOriginalWorkerErrorStatus() int32 + func (o *ApiErrorResponse) GetOriginalWorkerErrorStatusOk() (*int32, bool) + func (o *ApiErrorResponse) GetOriginalWorkerErrorType() string + func (o *ApiErrorResponse) GetOriginalWorkerErrorTypeOk() (*string, bool) + func (o *ApiErrorResponse) HasDetail() bool + func (o *ApiErrorResponse) HasOriginalWorkerErrorDetail() bool + func (o *ApiErrorResponse) HasOriginalWorkerErrorStatus() bool + func (o *ApiErrorResponse) HasOriginalWorkerErrorType() bool + func (o *ApiErrorResponse) SetDetail(v string) + func (o *ApiErrorResponse) SetOriginalWorkerErrorDetail(v string) + func (o *ApiErrorResponse) SetOriginalWorkerErrorStatus(v int32) + func (o *ApiErrorResponse) SetOriginalWorkerErrorType(v string) + func (o ApiErrorResponse) MarshalJSON() ([]byte, error) + func (o ApiErrorResponse) ToMap() (map[string]interface{}, error) + type ApiInternalApiV1XcherryNotifyImmediateTasksPostRequest struct + ApiService DefaultAPI + func (r ApiInternalApiV1XcherryNotifyImmediateTasksPostRequest) Execute() (*http.Response, error) + func (r ApiInternalApiV1XcherryNotifyImmediateTasksPostRequest) NotifyImmediateTasksRequest(notifyImmediateTasksRequest NotifyImmediateTasksRequest) ApiInternalApiV1XcherryNotifyImmediateTasksPostRequest + type ApiInternalApiV1XcherryNotifyTimerTasksPostRequest struct + ApiService DefaultAPI + func (r ApiInternalApiV1XcherryNotifyTimerTasksPostRequest) Execute() (*http.Response, error) + func (r ApiInternalApiV1XcherryNotifyTimerTasksPostRequest) NotifyTimerTasksRequest(notifyTimerTasksRequest NotifyTimerTasksRequest) ApiInternalApiV1XcherryNotifyTimerTasksPostRequest + type AsyncStateConfig struct + ExecuteApiRetryPolicy *RetryPolicy + ExecuteApiTimeoutSeconds *int32 + LoadGlobalAttributesRequest *LoadGlobalAttributesRequest + LoadLocalAttributesRequest *LoadLocalAttributesRequest + SkipWaitUntil *bool + StateFailureRecoveryOptions *StateFailureRecoveryOptions + WaitUntilApiRetryPolicy *RetryPolicy + WaitUntilApiTimeoutSeconds *int32 + func NewAsyncStateConfig() *AsyncStateConfig + func NewAsyncStateConfigWithDefaults() *AsyncStateConfig + func (o *AsyncStateConfig) GetExecuteApiRetryPolicy() RetryPolicy + func (o *AsyncStateConfig) GetExecuteApiRetryPolicyOk() (*RetryPolicy, bool) + func (o *AsyncStateConfig) GetExecuteApiTimeoutSeconds() int32 + func (o *AsyncStateConfig) GetExecuteApiTimeoutSecondsOk() (*int32, bool) + func (o *AsyncStateConfig) GetLoadGlobalAttributesRequest() LoadGlobalAttributesRequest + func (o *AsyncStateConfig) GetLoadGlobalAttributesRequestOk() (*LoadGlobalAttributesRequest, bool) + func (o *AsyncStateConfig) GetLoadLocalAttributesRequest() LoadLocalAttributesRequest + func (o *AsyncStateConfig) GetLoadLocalAttributesRequestOk() (*LoadLocalAttributesRequest, bool) + func (o *AsyncStateConfig) GetSkipWaitUntil() bool + func (o *AsyncStateConfig) GetSkipWaitUntilOk() (*bool, bool) + func (o *AsyncStateConfig) GetStateFailureRecoveryOptions() StateFailureRecoveryOptions + func (o *AsyncStateConfig) GetStateFailureRecoveryOptionsOk() (*StateFailureRecoveryOptions, bool) + func (o *AsyncStateConfig) GetWaitUntilApiRetryPolicy() RetryPolicy + func (o *AsyncStateConfig) GetWaitUntilApiRetryPolicyOk() (*RetryPolicy, bool) + func (o *AsyncStateConfig) GetWaitUntilApiTimeoutSeconds() int32 + func (o *AsyncStateConfig) GetWaitUntilApiTimeoutSecondsOk() (*int32, bool) + func (o *AsyncStateConfig) HasExecuteApiRetryPolicy() bool + func (o *AsyncStateConfig) HasExecuteApiTimeoutSeconds() bool + func (o *AsyncStateConfig) HasLoadGlobalAttributesRequest() bool + func (o *AsyncStateConfig) HasLoadLocalAttributesRequest() bool + func (o *AsyncStateConfig) HasSkipWaitUntil() bool + func (o *AsyncStateConfig) HasStateFailureRecoveryOptions() bool + func (o *AsyncStateConfig) HasWaitUntilApiRetryPolicy() bool + func (o *AsyncStateConfig) HasWaitUntilApiTimeoutSeconds() bool + func (o *AsyncStateConfig) SetExecuteApiRetryPolicy(v RetryPolicy) + func (o *AsyncStateConfig) SetExecuteApiTimeoutSeconds(v int32) + func (o *AsyncStateConfig) SetLoadGlobalAttributesRequest(v LoadGlobalAttributesRequest) + func (o *AsyncStateConfig) SetLoadLocalAttributesRequest(v LoadLocalAttributesRequest) + func (o *AsyncStateConfig) SetSkipWaitUntil(v bool) + func (o *AsyncStateConfig) SetStateFailureRecoveryOptions(v StateFailureRecoveryOptions) + func (o *AsyncStateConfig) SetWaitUntilApiRetryPolicy(v RetryPolicy) + func (o *AsyncStateConfig) SetWaitUntilApiTimeoutSeconds(v int32) + func (o AsyncStateConfig) MarshalJSON() ([]byte, error) + func (o AsyncStateConfig) ToMap() (map[string]interface{}, error) + type AsyncStateExecuteRequest struct + CommandResults *CommandResults + Context Context + LoadedGlobalAttributes *LoadGlobalAttributeResponse + LoadedLocalAttributes *LoadLocalAttributesResponse + ProcessType string + StateId string + StateInput *EncodedObject + func NewAsyncStateExecuteRequest(context Context, processType string, stateId string) *AsyncStateExecuteRequest + func NewAsyncStateExecuteRequestWithDefaults() *AsyncStateExecuteRequest + func (o *AsyncStateExecuteRequest) GetCommandResults() CommandResults + func (o *AsyncStateExecuteRequest) GetCommandResultsOk() (*CommandResults, bool) + func (o *AsyncStateExecuteRequest) GetContext() Context + func (o *AsyncStateExecuteRequest) GetContextOk() (*Context, bool) + func (o *AsyncStateExecuteRequest) GetLoadedGlobalAttributes() LoadGlobalAttributeResponse + func (o *AsyncStateExecuteRequest) GetLoadedGlobalAttributesOk() (*LoadGlobalAttributeResponse, bool) + func (o *AsyncStateExecuteRequest) GetLoadedLocalAttributes() LoadLocalAttributesResponse + func (o *AsyncStateExecuteRequest) GetLoadedLocalAttributesOk() (*LoadLocalAttributesResponse, bool) + func (o *AsyncStateExecuteRequest) GetProcessType() string + func (o *AsyncStateExecuteRequest) GetProcessTypeOk() (*string, bool) + func (o *AsyncStateExecuteRequest) GetStateId() string + func (o *AsyncStateExecuteRequest) GetStateIdOk() (*string, bool) + func (o *AsyncStateExecuteRequest) GetStateInput() EncodedObject + func (o *AsyncStateExecuteRequest) GetStateInputOk() (*EncodedObject, bool) + func (o *AsyncStateExecuteRequest) HasCommandResults() bool + func (o *AsyncStateExecuteRequest) HasLoadedGlobalAttributes() bool + func (o *AsyncStateExecuteRequest) HasLoadedLocalAttributes() bool + func (o *AsyncStateExecuteRequest) HasStateInput() bool + func (o *AsyncStateExecuteRequest) SetCommandResults(v CommandResults) + func (o *AsyncStateExecuteRequest) SetContext(v Context) + func (o *AsyncStateExecuteRequest) SetLoadedGlobalAttributes(v LoadGlobalAttributeResponse) + func (o *AsyncStateExecuteRequest) SetLoadedLocalAttributes(v LoadLocalAttributesResponse) + func (o *AsyncStateExecuteRequest) SetProcessType(v string) + func (o *AsyncStateExecuteRequest) SetStateId(v string) + func (o *AsyncStateExecuteRequest) SetStateInput(v EncodedObject) + func (o *AsyncStateExecuteRequest) UnmarshalJSON(bytes []byte) (err error) + func (o AsyncStateExecuteRequest) MarshalJSON() ([]byte, error) + func (o AsyncStateExecuteRequest) ToMap() (map[string]interface{}, error) + type AsyncStateExecuteResponse struct + PublishToLocalQueue []LocalQueueMessage + StateDecision StateDecision + WriteToGlobalAttributes []GlobalAttributeTableRowUpdate + WriteToLocalAttributes []KeyValue + func NewAsyncStateExecuteResponse(stateDecision StateDecision) *AsyncStateExecuteResponse + func NewAsyncStateExecuteResponseWithDefaults() *AsyncStateExecuteResponse + func (o *AsyncStateExecuteResponse) GetPublishToLocalQueue() []LocalQueueMessage + func (o *AsyncStateExecuteResponse) GetPublishToLocalQueueOk() ([]LocalQueueMessage, bool) + func (o *AsyncStateExecuteResponse) GetStateDecision() StateDecision + func (o *AsyncStateExecuteResponse) GetStateDecisionOk() (*StateDecision, bool) + func (o *AsyncStateExecuteResponse) GetWriteToGlobalAttributes() []GlobalAttributeTableRowUpdate + func (o *AsyncStateExecuteResponse) GetWriteToGlobalAttributesOk() ([]GlobalAttributeTableRowUpdate, bool) + func (o *AsyncStateExecuteResponse) GetWriteToLocalAttributes() []KeyValue + func (o *AsyncStateExecuteResponse) GetWriteToLocalAttributesOk() ([]KeyValue, bool) + func (o *AsyncStateExecuteResponse) HasPublishToLocalQueue() bool + func (o *AsyncStateExecuteResponse) HasWriteToGlobalAttributes() bool + func (o *AsyncStateExecuteResponse) HasWriteToLocalAttributes() bool + func (o *AsyncStateExecuteResponse) SetPublishToLocalQueue(v []LocalQueueMessage) + func (o *AsyncStateExecuteResponse) SetStateDecision(v StateDecision) + func (o *AsyncStateExecuteResponse) SetWriteToGlobalAttributes(v []GlobalAttributeTableRowUpdate) + func (o *AsyncStateExecuteResponse) SetWriteToLocalAttributes(v []KeyValue) + func (o *AsyncStateExecuteResponse) UnmarshalJSON(bytes []byte) (err error) + func (o AsyncStateExecuteResponse) MarshalJSON() ([]byte, error) + func (o AsyncStateExecuteResponse) ToMap() (map[string]interface{}, error) + type AsyncStateWaitUntilRequest struct + Context Context + ProcessType string + StateId string + StateInput *EncodedObject + func NewAsyncStateWaitUntilRequest(context Context, processType string, stateId string) *AsyncStateWaitUntilRequest + func NewAsyncStateWaitUntilRequestWithDefaults() *AsyncStateWaitUntilRequest + func (o *AsyncStateWaitUntilRequest) GetContext() Context + func (o *AsyncStateWaitUntilRequest) GetContextOk() (*Context, bool) + func (o *AsyncStateWaitUntilRequest) GetProcessType() string + func (o *AsyncStateWaitUntilRequest) GetProcessTypeOk() (*string, bool) + func (o *AsyncStateWaitUntilRequest) GetStateId() string + func (o *AsyncStateWaitUntilRequest) GetStateIdOk() (*string, bool) + func (o *AsyncStateWaitUntilRequest) GetStateInput() EncodedObject + func (o *AsyncStateWaitUntilRequest) GetStateInputOk() (*EncodedObject, bool) + func (o *AsyncStateWaitUntilRequest) HasStateInput() bool + func (o *AsyncStateWaitUntilRequest) SetContext(v Context) + func (o *AsyncStateWaitUntilRequest) SetProcessType(v string) + func (o *AsyncStateWaitUntilRequest) SetStateId(v string) + func (o *AsyncStateWaitUntilRequest) SetStateInput(v EncodedObject) + func (o *AsyncStateWaitUntilRequest) UnmarshalJSON(bytes []byte) (err error) + func (o AsyncStateWaitUntilRequest) MarshalJSON() ([]byte, error) + func (o AsyncStateWaitUntilRequest) ToMap() (map[string]interface{}, error) + type AsyncStateWaitUntilResponse struct + CommandRequest CommandRequest + PublishToLocalQueue []LocalQueueMessage + func NewAsyncStateWaitUntilResponse(commandRequest CommandRequest) *AsyncStateWaitUntilResponse + func NewAsyncStateWaitUntilResponseWithDefaults() *AsyncStateWaitUntilResponse + func (o *AsyncStateWaitUntilResponse) GetCommandRequest() CommandRequest + func (o *AsyncStateWaitUntilResponse) GetCommandRequestOk() (*CommandRequest, bool) + func (o *AsyncStateWaitUntilResponse) GetPublishToLocalQueue() []LocalQueueMessage + func (o *AsyncStateWaitUntilResponse) GetPublishToLocalQueueOk() ([]LocalQueueMessage, bool) + func (o *AsyncStateWaitUntilResponse) HasPublishToLocalQueue() bool + func (o *AsyncStateWaitUntilResponse) SetCommandRequest(v CommandRequest) + func (o *AsyncStateWaitUntilResponse) SetPublishToLocalQueue(v []LocalQueueMessage) + func (o *AsyncStateWaitUntilResponse) UnmarshalJSON(bytes []byte) (err error) + func (o AsyncStateWaitUntilResponse) MarshalJSON() ([]byte, error) + func (o AsyncStateWaitUntilResponse) ToMap() (map[string]interface{}, error) + type AttributeWriteConflictMode string + const IGNORE_CONFLICT + const OVERRIDE_ON_CONFLICT + const RETURN_ERROR_ON_CONFLICT + func NewAttributeWriteConflictModeFromValue(v string) (*AttributeWriteConflictMode, error) + func (v *AttributeWriteConflictMode) UnmarshalJSON(src []byte) error + func (v AttributeWriteConflictMode) IsValid() bool + func (v AttributeWriteConflictMode) Ptr() *AttributeWriteConflictMode + type BasicAuth struct + Password string + UserName string + type CommandRequest struct + LocalQueueCommands []LocalQueueCommand + TimerCommands []TimerCommand + WaitingType CommandWaitingType + func NewCommandRequest(waitingType CommandWaitingType) *CommandRequest + func NewCommandRequestWithDefaults() *CommandRequest + func (o *CommandRequest) GetLocalQueueCommands() []LocalQueueCommand + func (o *CommandRequest) GetLocalQueueCommandsOk() ([]LocalQueueCommand, bool) + func (o *CommandRequest) GetTimerCommands() []TimerCommand + func (o *CommandRequest) GetTimerCommandsOk() ([]TimerCommand, bool) + func (o *CommandRequest) GetWaitingType() CommandWaitingType + func (o *CommandRequest) GetWaitingTypeOk() (*CommandWaitingType, bool) + func (o *CommandRequest) HasLocalQueueCommands() bool + func (o *CommandRequest) HasTimerCommands() bool + func (o *CommandRequest) SetLocalQueueCommands(v []LocalQueueCommand) + func (o *CommandRequest) SetTimerCommands(v []TimerCommand) + func (o *CommandRequest) SetWaitingType(v CommandWaitingType) + func (o *CommandRequest) UnmarshalJSON(bytes []byte) (err error) + func (o CommandRequest) MarshalJSON() ([]byte, error) + func (o CommandRequest) ToMap() (map[string]interface{}, error) + type CommandResults struct + LocalQueueResults []LocalQueueResult + TimerResults []TimerResult + func NewCommandResults() *CommandResults + func NewCommandResultsWithDefaults() *CommandResults + func (o *CommandResults) GetLocalQueueResults() []LocalQueueResult + func (o *CommandResults) GetLocalQueueResultsOk() ([]LocalQueueResult, bool) + func (o *CommandResults) GetTimerResults() []TimerResult + func (o *CommandResults) GetTimerResultsOk() ([]TimerResult, bool) + func (o *CommandResults) HasLocalQueueResults() bool + func (o *CommandResults) HasTimerResults() bool + func (o *CommandResults) SetLocalQueueResults(v []LocalQueueResult) + func (o *CommandResults) SetTimerResults(v []TimerResult) + func (o CommandResults) MarshalJSON() ([]byte, error) + func (o CommandResults) ToMap() (map[string]interface{}, error) + type CommandStatus string + const COMPLETED_COMMAND + const SKIPPED_COMMAND + const WAITING_COMMAND + func NewCommandStatusFromValue(v string) (*CommandStatus, error) + func (v *CommandStatus) UnmarshalJSON(src []byte) error + func (v CommandStatus) IsValid() bool + func (v CommandStatus) Ptr() *CommandStatus + type CommandWaitingType string + const ALL_OF_COMPLETION + const ANY_OF_COMPLETION + const EMPTY_COMMAND + func NewCommandWaitingTypeFromValue(v string) (*CommandWaitingType, error) + func (v *CommandWaitingType) UnmarshalJSON(src []byte) error + func (v CommandWaitingType) IsValid() bool + func (v CommandWaitingType) Ptr() *CommandWaitingType + type Configuration struct + Debug bool + DefaultHeader map[string]string + HTTPClient *http.Client + Host string + OperationServers map[string]ServerConfigurations + Scheme string + Servers ServerConfigurations + UserAgent string + func NewConfiguration() *Configuration + func (c *Configuration) AddDefaultHeader(key string, value string) + func (c *Configuration) ServerURL(index int, variables map[string]string) (string, error) + func (c *Configuration) ServerURLWithContext(ctx context.Context, endpoint string) (string, error) + type Context struct + Attempt *int32 + FirstAttemptTimestamp *int64 + ProcessExecutionId string + ProcessId string + ProcessStartedTimestamp int64 + RecoverFromApi *StateApiType + RecoverFromStateExecutionId *string + StateExecutionId *string + func NewContext(processId string, processExecutionId string, processStartedTimestamp int64) *Context + func NewContextWithDefaults() *Context + func (o *Context) GetAttempt() int32 + func (o *Context) GetAttemptOk() (*int32, bool) + func (o *Context) GetFirstAttemptTimestamp() int64 + func (o *Context) GetFirstAttemptTimestampOk() (*int64, bool) + func (o *Context) GetProcessExecutionId() string + func (o *Context) GetProcessExecutionIdOk() (*string, bool) + func (o *Context) GetProcessId() string + func (o *Context) GetProcessIdOk() (*string, bool) + func (o *Context) GetProcessStartedTimestamp() int64 + func (o *Context) GetProcessStartedTimestampOk() (*int64, bool) + func (o *Context) GetRecoverFromApi() StateApiType + func (o *Context) GetRecoverFromApiOk() (*StateApiType, bool) + func (o *Context) GetRecoverFromStateExecutionId() string + func (o *Context) GetRecoverFromStateExecutionIdOk() (*string, bool) + func (o *Context) GetStateExecutionId() string + func (o *Context) GetStateExecutionIdOk() (*string, bool) + func (o *Context) HasAttempt() bool + func (o *Context) HasFirstAttemptTimestamp() bool + func (o *Context) HasRecoverFromApi() bool + func (o *Context) HasRecoverFromStateExecutionId() bool + func (o *Context) HasStateExecutionId() bool + func (o *Context) SetAttempt(v int32) + func (o *Context) SetFirstAttemptTimestamp(v int64) + func (o *Context) SetProcessExecutionId(v string) + func (o *Context) SetProcessId(v string) + func (o *Context) SetProcessStartedTimestamp(v int64) + func (o *Context) SetRecoverFromApi(v StateApiType) + func (o *Context) SetRecoverFromStateExecutionId(v string) + func (o *Context) SetStateExecutionId(v string) + func (o *Context) UnmarshalJSON(bytes []byte) (err error) + func (o Context) MarshalJSON() ([]byte, error) + func (o Context) ToMap() (map[string]interface{}, error) + type DefaultAPI interface + ApiV1XcherryServiceProcessExecutionDescribePost func(ctx context.Context) ApiApiV1XcherryServiceProcessExecutionDescribePostRequest + ApiV1XcherryServiceProcessExecutionDescribePostExecute func(r ApiApiV1XcherryServiceProcessExecutionDescribePostRequest) (*ProcessExecutionDescribeResponse, *http.Response, error) + ApiV1XcherryServiceProcessExecutionPublishToLocalQueuePost func(ctx context.Context) ApiApiV1XcherryServiceProcessExecutionPublishToLocalQueuePostRequest + ApiV1XcherryServiceProcessExecutionPublishToLocalQueuePostExecute func(r ApiApiV1XcherryServiceProcessExecutionPublishToLocalQueuePostRequest) (*http.Response, error) + ApiV1XcherryServiceProcessExecutionRpcPost func(ctx context.Context) ApiApiV1XcherryServiceProcessExecutionRpcPostRequest + ApiV1XcherryServiceProcessExecutionRpcPostExecute func(r ApiApiV1XcherryServiceProcessExecutionRpcPostRequest) (*ProcessExecutionRpcResponse, *http.Response, error) + ApiV1XcherryServiceProcessExecutionStartPost func(ctx context.Context) ApiApiV1XcherryServiceProcessExecutionStartPostRequest + ApiV1XcherryServiceProcessExecutionStartPostExecute func(r ApiApiV1XcherryServiceProcessExecutionStartPostRequest) (*ProcessExecutionStartResponse, *http.Response, error) + ApiV1XcherryServiceProcessExecutionStopPost func(ctx context.Context) ApiApiV1XcherryServiceProcessExecutionStopPostRequest + ApiV1XcherryServiceProcessExecutionStopPostExecute func(r ApiApiV1XcherryServiceProcessExecutionStopPostRequest) (*http.Response, error) + ApiV1XcherryWorkerAsyncStateExecutePost func(ctx context.Context) ApiApiV1XcherryWorkerAsyncStateExecutePostRequest + ApiV1XcherryWorkerAsyncStateExecutePostExecute func(r ApiApiV1XcherryWorkerAsyncStateExecutePostRequest) (*AsyncStateExecuteResponse, *http.Response, error) + ApiV1XcherryWorkerAsyncStateWaitUntilPost func(ctx context.Context) ApiApiV1XcherryWorkerAsyncStateWaitUntilPostRequest + ApiV1XcherryWorkerAsyncStateWaitUntilPostExecute func(r ApiApiV1XcherryWorkerAsyncStateWaitUntilPostRequest) (*AsyncStateWaitUntilResponse, *http.Response, error) + ApiV1XcherryWorkerProcessRpcPost func(ctx context.Context) ApiApiV1XcherryWorkerProcessRpcPostRequest + ApiV1XcherryWorkerProcessRpcPostExecute func(r ApiApiV1XcherryWorkerProcessRpcPostRequest) (*ProcessRpcWorkerResponse, *http.Response, error) + InternalApiV1XcherryNotifyImmediateTasksPost func(ctx context.Context) ApiInternalApiV1XcherryNotifyImmediateTasksPostRequest + InternalApiV1XcherryNotifyImmediateTasksPostExecute func(r ApiInternalApiV1XcherryNotifyImmediateTasksPostRequest) (*http.Response, error) + InternalApiV1XcherryNotifyTimerTasksPost func(ctx context.Context) ApiInternalApiV1XcherryNotifyTimerTasksPostRequest + InternalApiV1XcherryNotifyTimerTasksPostExecute func(r ApiInternalApiV1XcherryNotifyTimerTasksPostRequest) (*http.Response, error) + type DefaultAPIService service + func (a *DefaultAPIService) ApiV1XcherryServiceProcessExecutionDescribePost(ctx context.Context) ApiApiV1XcherryServiceProcessExecutionDescribePostRequest + func (a *DefaultAPIService) ApiV1XcherryServiceProcessExecutionDescribePostExecute(r ApiApiV1XcherryServiceProcessExecutionDescribePostRequest) (*ProcessExecutionDescribeResponse, *http.Response, error) + func (a *DefaultAPIService) ApiV1XcherryServiceProcessExecutionPublishToLocalQueuePost(ctx context.Context) ApiApiV1XcherryServiceProcessExecutionPublishToLocalQueuePostRequest + func (a *DefaultAPIService) ApiV1XcherryServiceProcessExecutionPublishToLocalQueuePostExecute(r ApiApiV1XcherryServiceProcessExecutionPublishToLocalQueuePostRequest) (*http.Response, error) + func (a *DefaultAPIService) ApiV1XcherryServiceProcessExecutionRpcPost(ctx context.Context) ApiApiV1XcherryServiceProcessExecutionRpcPostRequest + func (a *DefaultAPIService) ApiV1XcherryServiceProcessExecutionRpcPostExecute(r ApiApiV1XcherryServiceProcessExecutionRpcPostRequest) (*ProcessExecutionRpcResponse, *http.Response, error) + func (a *DefaultAPIService) ApiV1XcherryServiceProcessExecutionStartPost(ctx context.Context) ApiApiV1XcherryServiceProcessExecutionStartPostRequest + func (a *DefaultAPIService) ApiV1XcherryServiceProcessExecutionStartPostExecute(r ApiApiV1XcherryServiceProcessExecutionStartPostRequest) (*ProcessExecutionStartResponse, *http.Response, error) + func (a *DefaultAPIService) ApiV1XcherryServiceProcessExecutionStopPost(ctx context.Context) ApiApiV1XcherryServiceProcessExecutionStopPostRequest + func (a *DefaultAPIService) ApiV1XcherryServiceProcessExecutionStopPostExecute(r ApiApiV1XcherryServiceProcessExecutionStopPostRequest) (*http.Response, error) + func (a *DefaultAPIService) ApiV1XcherryWorkerAsyncStateExecutePost(ctx context.Context) ApiApiV1XcherryWorkerAsyncStateExecutePostRequest + func (a *DefaultAPIService) ApiV1XcherryWorkerAsyncStateExecutePostExecute(r ApiApiV1XcherryWorkerAsyncStateExecutePostRequest) (*AsyncStateExecuteResponse, *http.Response, error) + func (a *DefaultAPIService) ApiV1XcherryWorkerAsyncStateWaitUntilPost(ctx context.Context) ApiApiV1XcherryWorkerAsyncStateWaitUntilPostRequest + func (a *DefaultAPIService) ApiV1XcherryWorkerAsyncStateWaitUntilPostExecute(r ApiApiV1XcherryWorkerAsyncStateWaitUntilPostRequest) (*AsyncStateWaitUntilResponse, *http.Response, error) + func (a *DefaultAPIService) ApiV1XcherryWorkerProcessRpcPost(ctx context.Context) ApiApiV1XcherryWorkerProcessRpcPostRequest + func (a *DefaultAPIService) ApiV1XcherryWorkerProcessRpcPostExecute(r ApiApiV1XcherryWorkerProcessRpcPostRequest) (*ProcessRpcWorkerResponse, *http.Response, error) + func (a *DefaultAPIService) InternalApiV1XcherryNotifyImmediateTasksPost(ctx context.Context) ApiInternalApiV1XcherryNotifyImmediateTasksPostRequest + func (a *DefaultAPIService) InternalApiV1XcherryNotifyImmediateTasksPostExecute(r ApiInternalApiV1XcherryNotifyImmediateTasksPostRequest) (*http.Response, error) + func (a *DefaultAPIService) InternalApiV1XcherryNotifyTimerTasksPost(ctx context.Context) ApiInternalApiV1XcherryNotifyTimerTasksPostRequest + func (a *DefaultAPIService) InternalApiV1XcherryNotifyTimerTasksPostExecute(r ApiInternalApiV1XcherryNotifyTimerTasksPostRequest) (*http.Response, error) + type EncodedObject struct + Data string + Encoding string + func NewEncodedObject(encoding string, data string) *EncodedObject + func NewEncodedObjectWithDefaults() *EncodedObject + func (o *EncodedObject) GetData() string + func (o *EncodedObject) GetDataOk() (*string, bool) + func (o *EncodedObject) GetEncoding() string + func (o *EncodedObject) GetEncodingOk() (*string, bool) + func (o *EncodedObject) SetData(v string) + func (o *EncodedObject) SetEncoding(v string) + func (o *EncodedObject) UnmarshalJSON(bytes []byte) (err error) + func (o EncodedObject) MarshalJSON() ([]byte, error) + func (o EncodedObject) ToMap() (map[string]interface{}, error) + type GenericOpenAPIError struct + func (e GenericOpenAPIError) Body() []byte + func (e GenericOpenAPIError) Error() string + func (e GenericOpenAPIError) Model() interface{} + type GlobalAttributeConfig struct + TableConfigs []GlobalAttributeTableConfig + func NewGlobalAttributeConfig() *GlobalAttributeConfig + func NewGlobalAttributeConfigWithDefaults() *GlobalAttributeConfig + func (o *GlobalAttributeConfig) GetTableConfigs() []GlobalAttributeTableConfig + func (o *GlobalAttributeConfig) GetTableConfigsOk() ([]GlobalAttributeTableConfig, bool) + func (o *GlobalAttributeConfig) HasTableConfigs() bool + func (o *GlobalAttributeConfig) SetTableConfigs(v []GlobalAttributeTableConfig) + func (o GlobalAttributeConfig) MarshalJSON() ([]byte, error) + func (o GlobalAttributeConfig) ToMap() (map[string]interface{}, error) + type GlobalAttributeTableConfig struct + InitialWrite []TableColumnValue + InitialWriteMode *AttributeWriteConflictMode + PrimaryKey TableColumnValue + TableName string + func NewGlobalAttributeTableConfig(tableName string, primaryKey TableColumnValue) *GlobalAttributeTableConfig + func NewGlobalAttributeTableConfigWithDefaults() *GlobalAttributeTableConfig + func (o *GlobalAttributeTableConfig) GetInitialWrite() []TableColumnValue + func (o *GlobalAttributeTableConfig) GetInitialWriteMode() AttributeWriteConflictMode + func (o *GlobalAttributeTableConfig) GetInitialWriteModeOk() (*AttributeWriteConflictMode, bool) + func (o *GlobalAttributeTableConfig) GetInitialWriteOk() ([]TableColumnValue, bool) + func (o *GlobalAttributeTableConfig) GetPrimaryKey() TableColumnValue + func (o *GlobalAttributeTableConfig) GetPrimaryKeyOk() (*TableColumnValue, bool) + func (o *GlobalAttributeTableConfig) GetTableName() string + func (o *GlobalAttributeTableConfig) GetTableNameOk() (*string, bool) + func (o *GlobalAttributeTableConfig) HasInitialWrite() bool + func (o *GlobalAttributeTableConfig) HasInitialWriteMode() bool + func (o *GlobalAttributeTableConfig) SetInitialWrite(v []TableColumnValue) + func (o *GlobalAttributeTableConfig) SetInitialWriteMode(v AttributeWriteConflictMode) + func (o *GlobalAttributeTableConfig) SetPrimaryKey(v TableColumnValue) + func (o *GlobalAttributeTableConfig) SetTableName(v string) + func (o *GlobalAttributeTableConfig) UnmarshalJSON(bytes []byte) (err error) + func (o GlobalAttributeTableConfig) MarshalJSON() ([]byte, error) + func (o GlobalAttributeTableConfig) ToMap() (map[string]interface{}, error) + type GlobalAttributeTableRowUpdate struct + TableName string + UpdateColumns []TableColumnValue + func NewGlobalAttributeTableRowUpdate(tableName string) *GlobalAttributeTableRowUpdate + func NewGlobalAttributeTableRowUpdateWithDefaults() *GlobalAttributeTableRowUpdate + func (o *GlobalAttributeTableRowUpdate) GetTableName() string + func (o *GlobalAttributeTableRowUpdate) GetTableNameOk() (*string, bool) + func (o *GlobalAttributeTableRowUpdate) GetUpdateColumns() []TableColumnValue + func (o *GlobalAttributeTableRowUpdate) GetUpdateColumnsOk() ([]TableColumnValue, bool) + func (o *GlobalAttributeTableRowUpdate) HasUpdateColumns() bool + func (o *GlobalAttributeTableRowUpdate) SetTableName(v string) + func (o *GlobalAttributeTableRowUpdate) SetUpdateColumns(v []TableColumnValue) + func (o *GlobalAttributeTableRowUpdate) UnmarshalJSON(bytes []byte) (err error) + func (o GlobalAttributeTableRowUpdate) MarshalJSON() ([]byte, error) + func (o GlobalAttributeTableRowUpdate) ToMap() (map[string]interface{}, error) + type KeyValue struct + Key string + Value EncodedObject + func NewKeyValue(key string, value EncodedObject) *KeyValue + func NewKeyValueWithDefaults() *KeyValue + func (o *KeyValue) GetKey() string + func (o *KeyValue) GetKeyOk() (*string, bool) + func (o *KeyValue) GetValue() EncodedObject + func (o *KeyValue) GetValueOk() (*EncodedObject, bool) + func (o *KeyValue) SetKey(v string) + func (o *KeyValue) SetValue(v EncodedObject) + func (o *KeyValue) UnmarshalJSON(bytes []byte) (err error) + func (o KeyValue) MarshalJSON() ([]byte, error) + func (o KeyValue) ToMap() (map[string]interface{}, error) + type LoadGlobalAttributeResponse struct + TableResponses []TableReadResponse + func NewLoadGlobalAttributeResponse() *LoadGlobalAttributeResponse + func NewLoadGlobalAttributeResponseWithDefaults() *LoadGlobalAttributeResponse + func (o *LoadGlobalAttributeResponse) GetTableResponses() []TableReadResponse + func (o *LoadGlobalAttributeResponse) GetTableResponsesOk() ([]TableReadResponse, bool) + func (o *LoadGlobalAttributeResponse) HasTableResponses() bool + func (o *LoadGlobalAttributeResponse) SetTableResponses(v []TableReadResponse) + func (o LoadGlobalAttributeResponse) MarshalJSON() ([]byte, error) + func (o LoadGlobalAttributeResponse) ToMap() (map[string]interface{}, error) + type LoadGlobalAttributesRequest struct + TableRequests []TableReadRequest + func NewLoadGlobalAttributesRequest() *LoadGlobalAttributesRequest + func NewLoadGlobalAttributesRequestWithDefaults() *LoadGlobalAttributesRequest + func (o *LoadGlobalAttributesRequest) GetTableRequests() []TableReadRequest + func (o *LoadGlobalAttributesRequest) GetTableRequestsOk() ([]TableReadRequest, bool) + func (o *LoadGlobalAttributesRequest) HasTableRequests() bool + func (o *LoadGlobalAttributesRequest) SetTableRequests(v []TableReadRequest) + func (o LoadGlobalAttributesRequest) MarshalJSON() ([]byte, error) + func (o LoadGlobalAttributesRequest) ToMap() (map[string]interface{}, error) + type LoadLocalAttributesRequest struct + KeysToLoadNoLock []string + KeysToLoadWithLock []string + LockingPolicy *TableReadLockingPolicy + func NewLoadLocalAttributesRequest() *LoadLocalAttributesRequest + func NewLoadLocalAttributesRequestWithDefaults() *LoadLocalAttributesRequest + func (o *LoadLocalAttributesRequest) GetKeysToLoadNoLock() []string + func (o *LoadLocalAttributesRequest) GetKeysToLoadNoLockOk() ([]string, bool) + func (o *LoadLocalAttributesRequest) GetKeysToLoadWithLock() []string + func (o *LoadLocalAttributesRequest) GetKeysToLoadWithLockOk() ([]string, bool) + func (o *LoadLocalAttributesRequest) GetLockingPolicy() TableReadLockingPolicy + func (o *LoadLocalAttributesRequest) GetLockingPolicyOk() (*TableReadLockingPolicy, bool) + func (o *LoadLocalAttributesRequest) HasKeysToLoadNoLock() bool + func (o *LoadLocalAttributesRequest) HasKeysToLoadWithLock() bool + func (o *LoadLocalAttributesRequest) HasLockingPolicy() bool + func (o *LoadLocalAttributesRequest) SetKeysToLoadNoLock(v []string) + func (o *LoadLocalAttributesRequest) SetKeysToLoadWithLock(v []string) + func (o *LoadLocalAttributesRequest) SetLockingPolicy(v TableReadLockingPolicy) + func (o LoadLocalAttributesRequest) MarshalJSON() ([]byte, error) + func (o LoadLocalAttributesRequest) ToMap() (map[string]interface{}, error) + type LoadLocalAttributesResponse struct + Attributes []KeyValue + func NewLoadLocalAttributesResponse() *LoadLocalAttributesResponse + func NewLoadLocalAttributesResponseWithDefaults() *LoadLocalAttributesResponse + func (o *LoadLocalAttributesResponse) GetAttributes() []KeyValue + func (o *LoadLocalAttributesResponse) GetAttributesOk() ([]KeyValue, bool) + func (o *LoadLocalAttributesResponse) HasAttributes() bool + func (o *LoadLocalAttributesResponse) SetAttributes(v []KeyValue) + func (o LoadLocalAttributesResponse) MarshalJSON() ([]byte, error) + func (o LoadLocalAttributesResponse) ToMap() (map[string]interface{}, error) + type LocalAttributeConfig struct + InitialWrite []KeyValue + func NewLocalAttributeConfig() *LocalAttributeConfig + func NewLocalAttributeConfigWithDefaults() *LocalAttributeConfig + func (o *LocalAttributeConfig) GetInitialWrite() []KeyValue + func (o *LocalAttributeConfig) GetInitialWriteOk() ([]KeyValue, bool) + func (o *LocalAttributeConfig) HasInitialWrite() bool + func (o *LocalAttributeConfig) SetInitialWrite(v []KeyValue) + func (o LocalAttributeConfig) MarshalJSON() ([]byte, error) + func (o LocalAttributeConfig) ToMap() (map[string]interface{}, error) + type LocalQueueCommand struct + Count *int32 + QueueName string + func NewLocalQueueCommand(queueName string) *LocalQueueCommand + func NewLocalQueueCommandWithDefaults() *LocalQueueCommand + func (o *LocalQueueCommand) GetCount() int32 + func (o *LocalQueueCommand) GetCountOk() (*int32, bool) + func (o *LocalQueueCommand) GetQueueName() string + func (o *LocalQueueCommand) GetQueueNameOk() (*string, bool) + func (o *LocalQueueCommand) HasCount() bool + func (o *LocalQueueCommand) SetCount(v int32) + func (o *LocalQueueCommand) SetQueueName(v string) + func (o *LocalQueueCommand) UnmarshalJSON(bytes []byte) (err error) + func (o LocalQueueCommand) MarshalJSON() ([]byte, error) + func (o LocalQueueCommand) ToMap() (map[string]interface{}, error) + type LocalQueueMessage struct + DedupId *string + Payload *EncodedObject + QueueName string + func NewLocalQueueMessage(queueName string) *LocalQueueMessage + func NewLocalQueueMessageWithDefaults() *LocalQueueMessage + func (o *LocalQueueMessage) GetDedupId() string + func (o *LocalQueueMessage) GetDedupIdOk() (*string, bool) + func (o *LocalQueueMessage) GetPayload() EncodedObject + func (o *LocalQueueMessage) GetPayloadOk() (*EncodedObject, bool) + func (o *LocalQueueMessage) GetQueueName() string + func (o *LocalQueueMessage) GetQueueNameOk() (*string, bool) + func (o *LocalQueueMessage) HasDedupId() bool + func (o *LocalQueueMessage) HasPayload() bool + func (o *LocalQueueMessage) SetDedupId(v string) + func (o *LocalQueueMessage) SetPayload(v EncodedObject) + func (o *LocalQueueMessage) SetQueueName(v string) + func (o *LocalQueueMessage) UnmarshalJSON(bytes []byte) (err error) + func (o LocalQueueMessage) MarshalJSON() ([]byte, error) + func (o LocalQueueMessage) ToMap() (map[string]interface{}, error) + type LocalQueueMessageResult struct + DedupId string + Payload *EncodedObject + func NewLocalQueueMessageResult(dedupId string) *LocalQueueMessageResult + func NewLocalQueueMessageResultWithDefaults() *LocalQueueMessageResult + func (o *LocalQueueMessageResult) GetDedupId() string + func (o *LocalQueueMessageResult) GetDedupIdOk() (*string, bool) + func (o *LocalQueueMessageResult) GetPayload() EncodedObject + func (o *LocalQueueMessageResult) GetPayloadOk() (*EncodedObject, bool) + func (o *LocalQueueMessageResult) HasPayload() bool + func (o *LocalQueueMessageResult) SetDedupId(v string) + func (o *LocalQueueMessageResult) SetPayload(v EncodedObject) + func (o *LocalQueueMessageResult) UnmarshalJSON(bytes []byte) (err error) + func (o LocalQueueMessageResult) MarshalJSON() ([]byte, error) + func (o LocalQueueMessageResult) ToMap() (map[string]interface{}, error) + type LocalQueueResult struct + Messages []LocalQueueMessageResult + QueueName string + Status CommandStatus + func NewLocalQueueResult(status CommandStatus, queueName string) *LocalQueueResult + func NewLocalQueueResultWithDefaults() *LocalQueueResult + func (o *LocalQueueResult) GetMessages() []LocalQueueMessageResult + func (o *LocalQueueResult) GetMessagesOk() ([]LocalQueueMessageResult, bool) + func (o *LocalQueueResult) GetQueueName() string + func (o *LocalQueueResult) GetQueueNameOk() (*string, bool) + func (o *LocalQueueResult) GetStatus() CommandStatus + func (o *LocalQueueResult) GetStatusOk() (*CommandStatus, bool) + func (o *LocalQueueResult) HasMessages() bool + func (o *LocalQueueResult) SetMessages(v []LocalQueueMessageResult) + func (o *LocalQueueResult) SetQueueName(v string) + func (o *LocalQueueResult) SetStatus(v CommandStatus) + func (o *LocalQueueResult) UnmarshalJSON(bytes []byte) (err error) + func (o LocalQueueResult) MarshalJSON() ([]byte, error) + func (o LocalQueueResult) ToMap() (map[string]interface{}, error) + type MappedNullable interface + ToMap func() (map[string]interface{}, error) + type NotifyImmediateTasksRequest struct + Namespace *string + ProcessExecutionId *string + ProcessId *string + ShardId int32 + func NewNotifyImmediateTasksRequest(shardId int32) *NotifyImmediateTasksRequest + func NewNotifyImmediateTasksRequestWithDefaults() *NotifyImmediateTasksRequest + func (o *NotifyImmediateTasksRequest) GetNamespace() string + func (o *NotifyImmediateTasksRequest) GetNamespaceOk() (*string, bool) + func (o *NotifyImmediateTasksRequest) GetProcessExecutionId() string + func (o *NotifyImmediateTasksRequest) GetProcessExecutionIdOk() (*string, bool) + func (o *NotifyImmediateTasksRequest) GetProcessId() string + func (o *NotifyImmediateTasksRequest) GetProcessIdOk() (*string, bool) + func (o *NotifyImmediateTasksRequest) GetShardId() int32 + func (o *NotifyImmediateTasksRequest) GetShardIdOk() (*int32, bool) + func (o *NotifyImmediateTasksRequest) HasNamespace() bool + func (o *NotifyImmediateTasksRequest) HasProcessExecutionId() bool + func (o *NotifyImmediateTasksRequest) HasProcessId() bool + func (o *NotifyImmediateTasksRequest) SetNamespace(v string) + func (o *NotifyImmediateTasksRequest) SetProcessExecutionId(v string) + func (o *NotifyImmediateTasksRequest) SetProcessId(v string) + func (o *NotifyImmediateTasksRequest) SetShardId(v int32) + func (o *NotifyImmediateTasksRequest) UnmarshalJSON(bytes []byte) (err error) + func (o NotifyImmediateTasksRequest) MarshalJSON() ([]byte, error) + func (o NotifyImmediateTasksRequest) ToMap() (map[string]interface{}, error) + type NotifyTimerTasksRequest struct + FireTimestamps []int64 + Namespace *string + ProcessExecutionId *string + ProcessId *string + ShardId int32 + func NewNotifyTimerTasksRequest(shardId int32, fireTimestamps []int64) *NotifyTimerTasksRequest + func NewNotifyTimerTasksRequestWithDefaults() *NotifyTimerTasksRequest + func (o *NotifyTimerTasksRequest) GetFireTimestamps() []int64 + func (o *NotifyTimerTasksRequest) GetFireTimestampsOk() ([]int64, bool) + func (o *NotifyTimerTasksRequest) GetNamespace() string + func (o *NotifyTimerTasksRequest) GetNamespaceOk() (*string, bool) + func (o *NotifyTimerTasksRequest) GetProcessExecutionId() string + func (o *NotifyTimerTasksRequest) GetProcessExecutionIdOk() (*string, bool) + func (o *NotifyTimerTasksRequest) GetProcessId() string + func (o *NotifyTimerTasksRequest) GetProcessIdOk() (*string, bool) + func (o *NotifyTimerTasksRequest) GetShardId() int32 + func (o *NotifyTimerTasksRequest) GetShardIdOk() (*int32, bool) + func (o *NotifyTimerTasksRequest) HasNamespace() bool + func (o *NotifyTimerTasksRequest) HasProcessExecutionId() bool + func (o *NotifyTimerTasksRequest) HasProcessId() bool + func (o *NotifyTimerTasksRequest) SetFireTimestamps(v []int64) + func (o *NotifyTimerTasksRequest) SetNamespace(v string) + func (o *NotifyTimerTasksRequest) SetProcessExecutionId(v string) + func (o *NotifyTimerTasksRequest) SetProcessId(v string) + func (o *NotifyTimerTasksRequest) SetShardId(v int32) + func (o *NotifyTimerTasksRequest) UnmarshalJSON(bytes []byte) (err error) + func (o NotifyTimerTasksRequest) MarshalJSON() ([]byte, error) + func (o NotifyTimerTasksRequest) ToMap() (map[string]interface{}, error) + type NullableApiErrorResponse struct + func NewNullableApiErrorResponse(val *ApiErrorResponse) *NullableApiErrorResponse + func (v *NullableApiErrorResponse) Set(val *ApiErrorResponse) + func (v *NullableApiErrorResponse) UnmarshalJSON(src []byte) error + func (v *NullableApiErrorResponse) Unset() + func (v NullableApiErrorResponse) Get() *ApiErrorResponse + func (v NullableApiErrorResponse) IsSet() bool + func (v NullableApiErrorResponse) MarshalJSON() ([]byte, error) + type NullableAsyncStateConfig struct + func NewNullableAsyncStateConfig(val *AsyncStateConfig) *NullableAsyncStateConfig + func (v *NullableAsyncStateConfig) Set(val *AsyncStateConfig) + func (v *NullableAsyncStateConfig) UnmarshalJSON(src []byte) error + func (v *NullableAsyncStateConfig) Unset() + func (v NullableAsyncStateConfig) Get() *AsyncStateConfig + func (v NullableAsyncStateConfig) IsSet() bool + func (v NullableAsyncStateConfig) MarshalJSON() ([]byte, error) + type NullableAsyncStateExecuteRequest struct + func NewNullableAsyncStateExecuteRequest(val *AsyncStateExecuteRequest) *NullableAsyncStateExecuteRequest + func (v *NullableAsyncStateExecuteRequest) Set(val *AsyncStateExecuteRequest) + func (v *NullableAsyncStateExecuteRequest) UnmarshalJSON(src []byte) error + func (v *NullableAsyncStateExecuteRequest) Unset() + func (v NullableAsyncStateExecuteRequest) Get() *AsyncStateExecuteRequest + func (v NullableAsyncStateExecuteRequest) IsSet() bool + func (v NullableAsyncStateExecuteRequest) MarshalJSON() ([]byte, error) + type NullableAsyncStateExecuteResponse struct + func NewNullableAsyncStateExecuteResponse(val *AsyncStateExecuteResponse) *NullableAsyncStateExecuteResponse + func (v *NullableAsyncStateExecuteResponse) Set(val *AsyncStateExecuteResponse) + func (v *NullableAsyncStateExecuteResponse) UnmarshalJSON(src []byte) error + func (v *NullableAsyncStateExecuteResponse) Unset() + func (v NullableAsyncStateExecuteResponse) Get() *AsyncStateExecuteResponse + func (v NullableAsyncStateExecuteResponse) IsSet() bool + func (v NullableAsyncStateExecuteResponse) MarshalJSON() ([]byte, error) + type NullableAsyncStateWaitUntilRequest struct + func NewNullableAsyncStateWaitUntilRequest(val *AsyncStateWaitUntilRequest) *NullableAsyncStateWaitUntilRequest + func (v *NullableAsyncStateWaitUntilRequest) Set(val *AsyncStateWaitUntilRequest) + func (v *NullableAsyncStateWaitUntilRequest) UnmarshalJSON(src []byte) error + func (v *NullableAsyncStateWaitUntilRequest) Unset() + func (v NullableAsyncStateWaitUntilRequest) Get() *AsyncStateWaitUntilRequest + func (v NullableAsyncStateWaitUntilRequest) IsSet() bool + func (v NullableAsyncStateWaitUntilRequest) MarshalJSON() ([]byte, error) + type NullableAsyncStateWaitUntilResponse struct + func NewNullableAsyncStateWaitUntilResponse(val *AsyncStateWaitUntilResponse) *NullableAsyncStateWaitUntilResponse + func (v *NullableAsyncStateWaitUntilResponse) Set(val *AsyncStateWaitUntilResponse) + func (v *NullableAsyncStateWaitUntilResponse) UnmarshalJSON(src []byte) error + func (v *NullableAsyncStateWaitUntilResponse) Unset() + func (v NullableAsyncStateWaitUntilResponse) Get() *AsyncStateWaitUntilResponse + func (v NullableAsyncStateWaitUntilResponse) IsSet() bool + func (v NullableAsyncStateWaitUntilResponse) MarshalJSON() ([]byte, error) + type NullableAttributeWriteConflictMode struct + func NewNullableAttributeWriteConflictMode(val *AttributeWriteConflictMode) *NullableAttributeWriteConflictMode + func (v *NullableAttributeWriteConflictMode) Set(val *AttributeWriteConflictMode) + func (v *NullableAttributeWriteConflictMode) UnmarshalJSON(src []byte) error + func (v *NullableAttributeWriteConflictMode) Unset() + func (v NullableAttributeWriteConflictMode) Get() *AttributeWriteConflictMode + func (v NullableAttributeWriteConflictMode) IsSet() bool + func (v NullableAttributeWriteConflictMode) MarshalJSON() ([]byte, error) + type NullableBool struct + func NewNullableBool(val *bool) *NullableBool + func (v *NullableBool) Set(val *bool) + func (v *NullableBool) UnmarshalJSON(src []byte) error + func (v *NullableBool) Unset() + func (v NullableBool) Get() *bool + func (v NullableBool) IsSet() bool + func (v NullableBool) MarshalJSON() ([]byte, error) + type NullableCommandRequest struct + func NewNullableCommandRequest(val *CommandRequest) *NullableCommandRequest + func (v *NullableCommandRequest) Set(val *CommandRequest) + func (v *NullableCommandRequest) UnmarshalJSON(src []byte) error + func (v *NullableCommandRequest) Unset() + func (v NullableCommandRequest) Get() *CommandRequest + func (v NullableCommandRequest) IsSet() bool + func (v NullableCommandRequest) MarshalJSON() ([]byte, error) + type NullableCommandResults struct + func NewNullableCommandResults(val *CommandResults) *NullableCommandResults + func (v *NullableCommandResults) Set(val *CommandResults) + func (v *NullableCommandResults) UnmarshalJSON(src []byte) error + func (v *NullableCommandResults) Unset() + func (v NullableCommandResults) Get() *CommandResults + func (v NullableCommandResults) IsSet() bool + func (v NullableCommandResults) MarshalJSON() ([]byte, error) + type NullableCommandStatus struct + func NewNullableCommandStatus(val *CommandStatus) *NullableCommandStatus + func (v *NullableCommandStatus) Set(val *CommandStatus) + func (v *NullableCommandStatus) UnmarshalJSON(src []byte) error + func (v *NullableCommandStatus) Unset() + func (v NullableCommandStatus) Get() *CommandStatus + func (v NullableCommandStatus) IsSet() bool + func (v NullableCommandStatus) MarshalJSON() ([]byte, error) + type NullableCommandWaitingType struct + func NewNullableCommandWaitingType(val *CommandWaitingType) *NullableCommandWaitingType + func (v *NullableCommandWaitingType) Set(val *CommandWaitingType) + func (v *NullableCommandWaitingType) UnmarshalJSON(src []byte) error + func (v *NullableCommandWaitingType) Unset() + func (v NullableCommandWaitingType) Get() *CommandWaitingType + func (v NullableCommandWaitingType) IsSet() bool + func (v NullableCommandWaitingType) MarshalJSON() ([]byte, error) + type NullableContext struct + func NewNullableContext(val *Context) *NullableContext + func (v *NullableContext) Set(val *Context) + func (v *NullableContext) UnmarshalJSON(src []byte) error + func (v *NullableContext) Unset() + func (v NullableContext) Get() *Context + func (v NullableContext) IsSet() bool + func (v NullableContext) MarshalJSON() ([]byte, error) + type NullableEncodedObject struct + func NewNullableEncodedObject(val *EncodedObject) *NullableEncodedObject + func (v *NullableEncodedObject) Set(val *EncodedObject) + func (v *NullableEncodedObject) UnmarshalJSON(src []byte) error + func (v *NullableEncodedObject) Unset() + func (v NullableEncodedObject) Get() *EncodedObject + func (v NullableEncodedObject) IsSet() bool + func (v NullableEncodedObject) MarshalJSON() ([]byte, error) + type NullableFloat32 struct + func NewNullableFloat32(val *float32) *NullableFloat32 + func (v *NullableFloat32) Set(val *float32) + func (v *NullableFloat32) UnmarshalJSON(src []byte) error + func (v *NullableFloat32) Unset() + func (v NullableFloat32) Get() *float32 + func (v NullableFloat32) IsSet() bool + func (v NullableFloat32) MarshalJSON() ([]byte, error) + type NullableFloat64 struct + func NewNullableFloat64(val *float64) *NullableFloat64 + func (v *NullableFloat64) Set(val *float64) + func (v *NullableFloat64) UnmarshalJSON(src []byte) error + func (v *NullableFloat64) Unset() + func (v NullableFloat64) Get() *float64 + func (v NullableFloat64) IsSet() bool + func (v NullableFloat64) MarshalJSON() ([]byte, error) + type NullableGlobalAttributeConfig struct + func NewNullableGlobalAttributeConfig(val *GlobalAttributeConfig) *NullableGlobalAttributeConfig + func (v *NullableGlobalAttributeConfig) Set(val *GlobalAttributeConfig) + func (v *NullableGlobalAttributeConfig) UnmarshalJSON(src []byte) error + func (v *NullableGlobalAttributeConfig) Unset() + func (v NullableGlobalAttributeConfig) Get() *GlobalAttributeConfig + func (v NullableGlobalAttributeConfig) IsSet() bool + func (v NullableGlobalAttributeConfig) MarshalJSON() ([]byte, error) + type NullableGlobalAttributeTableConfig struct + func NewNullableGlobalAttributeTableConfig(val *GlobalAttributeTableConfig) *NullableGlobalAttributeTableConfig + func (v *NullableGlobalAttributeTableConfig) Set(val *GlobalAttributeTableConfig) + func (v *NullableGlobalAttributeTableConfig) UnmarshalJSON(src []byte) error + func (v *NullableGlobalAttributeTableConfig) Unset() + func (v NullableGlobalAttributeTableConfig) Get() *GlobalAttributeTableConfig + func (v NullableGlobalAttributeTableConfig) IsSet() bool + func (v NullableGlobalAttributeTableConfig) MarshalJSON() ([]byte, error) + type NullableGlobalAttributeTableRowUpdate struct + func NewNullableGlobalAttributeTableRowUpdate(val *GlobalAttributeTableRowUpdate) *NullableGlobalAttributeTableRowUpdate + func (v *NullableGlobalAttributeTableRowUpdate) Set(val *GlobalAttributeTableRowUpdate) + func (v *NullableGlobalAttributeTableRowUpdate) UnmarshalJSON(src []byte) error + func (v *NullableGlobalAttributeTableRowUpdate) Unset() + func (v NullableGlobalAttributeTableRowUpdate) Get() *GlobalAttributeTableRowUpdate + func (v NullableGlobalAttributeTableRowUpdate) IsSet() bool + func (v NullableGlobalAttributeTableRowUpdate) MarshalJSON() ([]byte, error) + type NullableInt struct + func NewNullableInt(val *int) *NullableInt + func (v *NullableInt) Set(val *int) + func (v *NullableInt) UnmarshalJSON(src []byte) error + func (v *NullableInt) Unset() + func (v NullableInt) Get() *int + func (v NullableInt) IsSet() bool + func (v NullableInt) MarshalJSON() ([]byte, error) + type NullableInt32 struct + func NewNullableInt32(val *int32) *NullableInt32 + func (v *NullableInt32) Set(val *int32) + func (v *NullableInt32) UnmarshalJSON(src []byte) error + func (v *NullableInt32) Unset() + func (v NullableInt32) Get() *int32 + func (v NullableInt32) IsSet() bool + func (v NullableInt32) MarshalJSON() ([]byte, error) + type NullableInt64 struct + func NewNullableInt64(val *int64) *NullableInt64 + func (v *NullableInt64) Set(val *int64) + func (v *NullableInt64) UnmarshalJSON(src []byte) error + func (v *NullableInt64) Unset() + func (v NullableInt64) Get() *int64 + func (v NullableInt64) IsSet() bool + func (v NullableInt64) MarshalJSON() ([]byte, error) + type NullableKeyValue struct + func NewNullableKeyValue(val *KeyValue) *NullableKeyValue + func (v *NullableKeyValue) Set(val *KeyValue) + func (v *NullableKeyValue) UnmarshalJSON(src []byte) error + func (v *NullableKeyValue) Unset() + func (v NullableKeyValue) Get() *KeyValue + func (v NullableKeyValue) IsSet() bool + func (v NullableKeyValue) MarshalJSON() ([]byte, error) + type NullableLoadGlobalAttributeResponse struct + func NewNullableLoadGlobalAttributeResponse(val *LoadGlobalAttributeResponse) *NullableLoadGlobalAttributeResponse + func (v *NullableLoadGlobalAttributeResponse) Set(val *LoadGlobalAttributeResponse) + func (v *NullableLoadGlobalAttributeResponse) UnmarshalJSON(src []byte) error + func (v *NullableLoadGlobalAttributeResponse) Unset() + func (v NullableLoadGlobalAttributeResponse) Get() *LoadGlobalAttributeResponse + func (v NullableLoadGlobalAttributeResponse) IsSet() bool + func (v NullableLoadGlobalAttributeResponse) MarshalJSON() ([]byte, error) + type NullableLoadGlobalAttributesRequest struct + func NewNullableLoadGlobalAttributesRequest(val *LoadGlobalAttributesRequest) *NullableLoadGlobalAttributesRequest + func (v *NullableLoadGlobalAttributesRequest) Set(val *LoadGlobalAttributesRequest) + func (v *NullableLoadGlobalAttributesRequest) UnmarshalJSON(src []byte) error + func (v *NullableLoadGlobalAttributesRequest) Unset() + func (v NullableLoadGlobalAttributesRequest) Get() *LoadGlobalAttributesRequest + func (v NullableLoadGlobalAttributesRequest) IsSet() bool + func (v NullableLoadGlobalAttributesRequest) MarshalJSON() ([]byte, error) + type NullableLoadLocalAttributesRequest struct + func NewNullableLoadLocalAttributesRequest(val *LoadLocalAttributesRequest) *NullableLoadLocalAttributesRequest + func (v *NullableLoadLocalAttributesRequest) Set(val *LoadLocalAttributesRequest) + func (v *NullableLoadLocalAttributesRequest) UnmarshalJSON(src []byte) error + func (v *NullableLoadLocalAttributesRequest) Unset() + func (v NullableLoadLocalAttributesRequest) Get() *LoadLocalAttributesRequest + func (v NullableLoadLocalAttributesRequest) IsSet() bool + func (v NullableLoadLocalAttributesRequest) MarshalJSON() ([]byte, error) + type NullableLoadLocalAttributesResponse struct + func NewNullableLoadLocalAttributesResponse(val *LoadLocalAttributesResponse) *NullableLoadLocalAttributesResponse + func (v *NullableLoadLocalAttributesResponse) Set(val *LoadLocalAttributesResponse) + func (v *NullableLoadLocalAttributesResponse) UnmarshalJSON(src []byte) error + func (v *NullableLoadLocalAttributesResponse) Unset() + func (v NullableLoadLocalAttributesResponse) Get() *LoadLocalAttributesResponse + func (v NullableLoadLocalAttributesResponse) IsSet() bool + func (v NullableLoadLocalAttributesResponse) MarshalJSON() ([]byte, error) + type NullableLocalAttributeConfig struct + func NewNullableLocalAttributeConfig(val *LocalAttributeConfig) *NullableLocalAttributeConfig + func (v *NullableLocalAttributeConfig) Set(val *LocalAttributeConfig) + func (v *NullableLocalAttributeConfig) UnmarshalJSON(src []byte) error + func (v *NullableLocalAttributeConfig) Unset() + func (v NullableLocalAttributeConfig) Get() *LocalAttributeConfig + func (v NullableLocalAttributeConfig) IsSet() bool + func (v NullableLocalAttributeConfig) MarshalJSON() ([]byte, error) + type NullableLocalQueueCommand struct + func NewNullableLocalQueueCommand(val *LocalQueueCommand) *NullableLocalQueueCommand + func (v *NullableLocalQueueCommand) Set(val *LocalQueueCommand) + func (v *NullableLocalQueueCommand) UnmarshalJSON(src []byte) error + func (v *NullableLocalQueueCommand) Unset() + func (v NullableLocalQueueCommand) Get() *LocalQueueCommand + func (v NullableLocalQueueCommand) IsSet() bool + func (v NullableLocalQueueCommand) MarshalJSON() ([]byte, error) + type NullableLocalQueueMessage struct + func NewNullableLocalQueueMessage(val *LocalQueueMessage) *NullableLocalQueueMessage + func (v *NullableLocalQueueMessage) Set(val *LocalQueueMessage) + func (v *NullableLocalQueueMessage) UnmarshalJSON(src []byte) error + func (v *NullableLocalQueueMessage) Unset() + func (v NullableLocalQueueMessage) Get() *LocalQueueMessage + func (v NullableLocalQueueMessage) IsSet() bool + func (v NullableLocalQueueMessage) MarshalJSON() ([]byte, error) + type NullableLocalQueueMessageResult struct + func NewNullableLocalQueueMessageResult(val *LocalQueueMessageResult) *NullableLocalQueueMessageResult + func (v *NullableLocalQueueMessageResult) Set(val *LocalQueueMessageResult) + func (v *NullableLocalQueueMessageResult) UnmarshalJSON(src []byte) error + func (v *NullableLocalQueueMessageResult) Unset() + func (v NullableLocalQueueMessageResult) Get() *LocalQueueMessageResult + func (v NullableLocalQueueMessageResult) IsSet() bool + func (v NullableLocalQueueMessageResult) MarshalJSON() ([]byte, error) + type NullableLocalQueueResult struct + func NewNullableLocalQueueResult(val *LocalQueueResult) *NullableLocalQueueResult + func (v *NullableLocalQueueResult) Set(val *LocalQueueResult) + func (v *NullableLocalQueueResult) UnmarshalJSON(src []byte) error + func (v *NullableLocalQueueResult) Unset() + func (v NullableLocalQueueResult) Get() *LocalQueueResult + func (v NullableLocalQueueResult) IsSet() bool + func (v NullableLocalQueueResult) MarshalJSON() ([]byte, error) + type NullableNotifyImmediateTasksRequest struct + func NewNullableNotifyImmediateTasksRequest(val *NotifyImmediateTasksRequest) *NullableNotifyImmediateTasksRequest + func (v *NullableNotifyImmediateTasksRequest) Set(val *NotifyImmediateTasksRequest) + func (v *NullableNotifyImmediateTasksRequest) UnmarshalJSON(src []byte) error + func (v *NullableNotifyImmediateTasksRequest) Unset() + func (v NullableNotifyImmediateTasksRequest) Get() *NotifyImmediateTasksRequest + func (v NullableNotifyImmediateTasksRequest) IsSet() bool + func (v NullableNotifyImmediateTasksRequest) MarshalJSON() ([]byte, error) + type NullableNotifyTimerTasksRequest struct + func NewNullableNotifyTimerTasksRequest(val *NotifyTimerTasksRequest) *NullableNotifyTimerTasksRequest + func (v *NullableNotifyTimerTasksRequest) Set(val *NotifyTimerTasksRequest) + func (v *NullableNotifyTimerTasksRequest) UnmarshalJSON(src []byte) error + func (v *NullableNotifyTimerTasksRequest) Unset() + func (v NullableNotifyTimerTasksRequest) Get() *NotifyTimerTasksRequest + func (v NullableNotifyTimerTasksRequest) IsSet() bool + func (v NullableNotifyTimerTasksRequest) MarshalJSON() ([]byte, error) + type NullableProcessExecutionDescribeRequest struct + func NewNullableProcessExecutionDescribeRequest(val *ProcessExecutionDescribeRequest) *NullableProcessExecutionDescribeRequest + func (v *NullableProcessExecutionDescribeRequest) Set(val *ProcessExecutionDescribeRequest) + func (v *NullableProcessExecutionDescribeRequest) UnmarshalJSON(src []byte) error + func (v *NullableProcessExecutionDescribeRequest) Unset() + func (v NullableProcessExecutionDescribeRequest) Get() *ProcessExecutionDescribeRequest + func (v NullableProcessExecutionDescribeRequest) IsSet() bool + func (v NullableProcessExecutionDescribeRequest) MarshalJSON() ([]byte, error) + type NullableProcessExecutionDescribeResponse struct + func NewNullableProcessExecutionDescribeResponse(val *ProcessExecutionDescribeResponse) *NullableProcessExecutionDescribeResponse + func (v *NullableProcessExecutionDescribeResponse) Set(val *ProcessExecutionDescribeResponse) + func (v *NullableProcessExecutionDescribeResponse) UnmarshalJSON(src []byte) error + func (v *NullableProcessExecutionDescribeResponse) Unset() + func (v NullableProcessExecutionDescribeResponse) Get() *ProcessExecutionDescribeResponse + func (v NullableProcessExecutionDescribeResponse) IsSet() bool + func (v NullableProcessExecutionDescribeResponse) MarshalJSON() ([]byte, error) + type NullableProcessExecutionRpcRequest struct + func NewNullableProcessExecutionRpcRequest(val *ProcessExecutionRpcRequest) *NullableProcessExecutionRpcRequest + func (v *NullableProcessExecutionRpcRequest) Set(val *ProcessExecutionRpcRequest) + func (v *NullableProcessExecutionRpcRequest) UnmarshalJSON(src []byte) error + func (v *NullableProcessExecutionRpcRequest) Unset() + func (v NullableProcessExecutionRpcRequest) Get() *ProcessExecutionRpcRequest + func (v NullableProcessExecutionRpcRequest) IsSet() bool + func (v NullableProcessExecutionRpcRequest) MarshalJSON() ([]byte, error) + type NullableProcessExecutionRpcResponse struct + func NewNullableProcessExecutionRpcResponse(val *ProcessExecutionRpcResponse) *NullableProcessExecutionRpcResponse + func (v *NullableProcessExecutionRpcResponse) Set(val *ProcessExecutionRpcResponse) + func (v *NullableProcessExecutionRpcResponse) UnmarshalJSON(src []byte) error + func (v *NullableProcessExecutionRpcResponse) Unset() + func (v NullableProcessExecutionRpcResponse) Get() *ProcessExecutionRpcResponse + func (v NullableProcessExecutionRpcResponse) IsSet() bool + func (v NullableProcessExecutionRpcResponse) MarshalJSON() ([]byte, error) + type NullableProcessExecutionStartRequest struct + func NewNullableProcessExecutionStartRequest(val *ProcessExecutionStartRequest) *NullableProcessExecutionStartRequest + func (v *NullableProcessExecutionStartRequest) Set(val *ProcessExecutionStartRequest) + func (v *NullableProcessExecutionStartRequest) UnmarshalJSON(src []byte) error + func (v *NullableProcessExecutionStartRequest) Unset() + func (v NullableProcessExecutionStartRequest) Get() *ProcessExecutionStartRequest + func (v NullableProcessExecutionStartRequest) IsSet() bool + func (v NullableProcessExecutionStartRequest) MarshalJSON() ([]byte, error) + type NullableProcessExecutionStartResponse struct + func NewNullableProcessExecutionStartResponse(val *ProcessExecutionStartResponse) *NullableProcessExecutionStartResponse + func (v *NullableProcessExecutionStartResponse) Set(val *ProcessExecutionStartResponse) + func (v *NullableProcessExecutionStartResponse) UnmarshalJSON(src []byte) error + func (v *NullableProcessExecutionStartResponse) Unset() + func (v NullableProcessExecutionStartResponse) Get() *ProcessExecutionStartResponse + func (v NullableProcessExecutionStartResponse) IsSet() bool + func (v NullableProcessExecutionStartResponse) MarshalJSON() ([]byte, error) + type NullableProcessExecutionStopRequest struct + func NewNullableProcessExecutionStopRequest(val *ProcessExecutionStopRequest) *NullableProcessExecutionStopRequest + func (v *NullableProcessExecutionStopRequest) Set(val *ProcessExecutionStopRequest) + func (v *NullableProcessExecutionStopRequest) UnmarshalJSON(src []byte) error + func (v *NullableProcessExecutionStopRequest) Unset() + func (v NullableProcessExecutionStopRequest) Get() *ProcessExecutionStopRequest + func (v NullableProcessExecutionStopRequest) IsSet() bool + func (v NullableProcessExecutionStopRequest) MarshalJSON() ([]byte, error) + type NullableProcessExecutionStopType struct + func NewNullableProcessExecutionStopType(val *ProcessExecutionStopType) *NullableProcessExecutionStopType + func (v *NullableProcessExecutionStopType) Set(val *ProcessExecutionStopType) + func (v *NullableProcessExecutionStopType) UnmarshalJSON(src []byte) error + func (v *NullableProcessExecutionStopType) Unset() + func (v NullableProcessExecutionStopType) Get() *ProcessExecutionStopType + func (v NullableProcessExecutionStopType) IsSet() bool + func (v NullableProcessExecutionStopType) MarshalJSON() ([]byte, error) + type NullableProcessIdReusePolicy struct + func NewNullableProcessIdReusePolicy(val *ProcessIdReusePolicy) *NullableProcessIdReusePolicy + func (v *NullableProcessIdReusePolicy) Set(val *ProcessIdReusePolicy) + func (v *NullableProcessIdReusePolicy) UnmarshalJSON(src []byte) error + func (v *NullableProcessIdReusePolicy) Unset() + func (v NullableProcessIdReusePolicy) Get() *ProcessIdReusePolicy + func (v NullableProcessIdReusePolicy) IsSet() bool + func (v NullableProcessIdReusePolicy) MarshalJSON() ([]byte, error) + type NullableProcessRpcWorkerRequest struct + func NewNullableProcessRpcWorkerRequest(val *ProcessRpcWorkerRequest) *NullableProcessRpcWorkerRequest + func (v *NullableProcessRpcWorkerRequest) Set(val *ProcessRpcWorkerRequest) + func (v *NullableProcessRpcWorkerRequest) UnmarshalJSON(src []byte) error + func (v *NullableProcessRpcWorkerRequest) Unset() + func (v NullableProcessRpcWorkerRequest) Get() *ProcessRpcWorkerRequest + func (v NullableProcessRpcWorkerRequest) IsSet() bool + func (v NullableProcessRpcWorkerRequest) MarshalJSON() ([]byte, error) + type NullableProcessRpcWorkerResponse struct + func NewNullableProcessRpcWorkerResponse(val *ProcessRpcWorkerResponse) *NullableProcessRpcWorkerResponse + func (v *NullableProcessRpcWorkerResponse) Set(val *ProcessRpcWorkerResponse) + func (v *NullableProcessRpcWorkerResponse) UnmarshalJSON(src []byte) error + func (v *NullableProcessRpcWorkerResponse) Unset() + func (v NullableProcessRpcWorkerResponse) Get() *ProcessRpcWorkerResponse + func (v NullableProcessRpcWorkerResponse) IsSet() bool + func (v NullableProcessRpcWorkerResponse) MarshalJSON() ([]byte, error) + type NullableProcessStartConfig struct + func NewNullableProcessStartConfig(val *ProcessStartConfig) *NullableProcessStartConfig + func (v *NullableProcessStartConfig) Set(val *ProcessStartConfig) + func (v *NullableProcessStartConfig) UnmarshalJSON(src []byte) error + func (v *NullableProcessStartConfig) Unset() + func (v NullableProcessStartConfig) Get() *ProcessStartConfig + func (v NullableProcessStartConfig) IsSet() bool + func (v NullableProcessStartConfig) MarshalJSON() ([]byte, error) + type NullableProcessStatus struct + func NewNullableProcessStatus(val *ProcessStatus) *NullableProcessStatus + func (v *NullableProcessStatus) Set(val *ProcessStatus) + func (v *NullableProcessStatus) UnmarshalJSON(src []byte) error + func (v *NullableProcessStatus) Unset() + func (v NullableProcessStatus) Get() *ProcessStatus + func (v NullableProcessStatus) IsSet() bool + func (v NullableProcessStatus) MarshalJSON() ([]byte, error) + type NullablePublishToLocalQueueRequest struct + func NewNullablePublishToLocalQueueRequest(val *PublishToLocalQueueRequest) *NullablePublishToLocalQueueRequest + func (v *NullablePublishToLocalQueueRequest) Set(val *PublishToLocalQueueRequest) + func (v *NullablePublishToLocalQueueRequest) UnmarshalJSON(src []byte) error + func (v *NullablePublishToLocalQueueRequest) Unset() + func (v NullablePublishToLocalQueueRequest) Get() *PublishToLocalQueueRequest + func (v NullablePublishToLocalQueueRequest) IsSet() bool + func (v NullablePublishToLocalQueueRequest) MarshalJSON() ([]byte, error) + type NullableRetryPolicy struct + func NewNullableRetryPolicy(val *RetryPolicy) *NullableRetryPolicy + func (v *NullableRetryPolicy) Set(val *RetryPolicy) + func (v *NullableRetryPolicy) UnmarshalJSON(src []byte) error + func (v *NullableRetryPolicy) Unset() + func (v NullableRetryPolicy) Get() *RetryPolicy + func (v NullableRetryPolicy) IsSet() bool + func (v NullableRetryPolicy) MarshalJSON() ([]byte, error) + type NullableStateApiType struct + func NewNullableStateApiType(val *StateApiType) *NullableStateApiType + func (v *NullableStateApiType) Set(val *StateApiType) + func (v *NullableStateApiType) UnmarshalJSON(src []byte) error + func (v *NullableStateApiType) Unset() + func (v NullableStateApiType) Get() *StateApiType + func (v NullableStateApiType) IsSet() bool + func (v NullableStateApiType) MarshalJSON() ([]byte, error) + type NullableStateDecision struct + func NewNullableStateDecision(val *StateDecision) *NullableStateDecision + func (v *NullableStateDecision) Set(val *StateDecision) + func (v *NullableStateDecision) UnmarshalJSON(src []byte) error + func (v *NullableStateDecision) Unset() + func (v NullableStateDecision) Get() *StateDecision + func (v NullableStateDecision) IsSet() bool + func (v NullableStateDecision) MarshalJSON() ([]byte, error) + type NullableStateFailureRecoveryOptions struct + func NewNullableStateFailureRecoveryOptions(val *StateFailureRecoveryOptions) *NullableStateFailureRecoveryOptions + func (v *NullableStateFailureRecoveryOptions) Set(val *StateFailureRecoveryOptions) + func (v *NullableStateFailureRecoveryOptions) UnmarshalJSON(src []byte) error + func (v *NullableStateFailureRecoveryOptions) Unset() + func (v NullableStateFailureRecoveryOptions) Get() *StateFailureRecoveryOptions + func (v NullableStateFailureRecoveryOptions) IsSet() bool + func (v NullableStateFailureRecoveryOptions) MarshalJSON() ([]byte, error) + type NullableStateFailureRecoveryPolicy struct + func NewNullableStateFailureRecoveryPolicy(val *StateFailureRecoveryPolicy) *NullableStateFailureRecoveryPolicy + func (v *NullableStateFailureRecoveryPolicy) Set(val *StateFailureRecoveryPolicy) + func (v *NullableStateFailureRecoveryPolicy) UnmarshalJSON(src []byte) error + func (v *NullableStateFailureRecoveryPolicy) Unset() + func (v NullableStateFailureRecoveryPolicy) Get() *StateFailureRecoveryPolicy + func (v NullableStateFailureRecoveryPolicy) IsSet() bool + func (v NullableStateFailureRecoveryPolicy) MarshalJSON() ([]byte, error) + type NullableStateMovement struct + func NewNullableStateMovement(val *StateMovement) *NullableStateMovement + func (v *NullableStateMovement) Set(val *StateMovement) + func (v *NullableStateMovement) UnmarshalJSON(src []byte) error + func (v *NullableStateMovement) Unset() + func (v NullableStateMovement) Get() *StateMovement + func (v NullableStateMovement) IsSet() bool + func (v NullableStateMovement) MarshalJSON() ([]byte, error) + type NullableString struct + func NewNullableString(val *string) *NullableString + func (v *NullableString) Set(val *string) + func (v *NullableString) UnmarshalJSON(src []byte) error + func (v *NullableString) Unset() + func (v NullableString) Get() *string + func (v NullableString) IsSet() bool + func (v NullableString) MarshalJSON() ([]byte, error) + type NullableTableColumnDef struct + func NewNullableTableColumnDef(val *TableColumnDef) *NullableTableColumnDef + func (v *NullableTableColumnDef) Set(val *TableColumnDef) + func (v *NullableTableColumnDef) UnmarshalJSON(src []byte) error + func (v *NullableTableColumnDef) Unset() + func (v NullableTableColumnDef) Get() *TableColumnDef + func (v NullableTableColumnDef) IsSet() bool + func (v NullableTableColumnDef) MarshalJSON() ([]byte, error) + type NullableTableColumnValue struct + func NewNullableTableColumnValue(val *TableColumnValue) *NullableTableColumnValue + func (v *NullableTableColumnValue) Set(val *TableColumnValue) + func (v *NullableTableColumnValue) UnmarshalJSON(src []byte) error + func (v *NullableTableColumnValue) Unset() + func (v NullableTableColumnValue) Get() *TableColumnValue + func (v NullableTableColumnValue) IsSet() bool + func (v NullableTableColumnValue) MarshalJSON() ([]byte, error) + type NullableTableReadLockingPolicy struct + func NewNullableTableReadLockingPolicy(val *TableReadLockingPolicy) *NullableTableReadLockingPolicy + func (v *NullableTableReadLockingPolicy) Set(val *TableReadLockingPolicy) + func (v *NullableTableReadLockingPolicy) UnmarshalJSON(src []byte) error + func (v *NullableTableReadLockingPolicy) Unset() + func (v NullableTableReadLockingPolicy) Get() *TableReadLockingPolicy + func (v NullableTableReadLockingPolicy) IsSet() bool + func (v NullableTableReadLockingPolicy) MarshalJSON() ([]byte, error) + type NullableTableReadRequest struct + func NewNullableTableReadRequest(val *TableReadRequest) *NullableTableReadRequest + func (v *NullableTableReadRequest) Set(val *TableReadRequest) + func (v *NullableTableReadRequest) UnmarshalJSON(src []byte) error + func (v *NullableTableReadRequest) Unset() + func (v NullableTableReadRequest) Get() *TableReadRequest + func (v NullableTableReadRequest) IsSet() bool + func (v NullableTableReadRequest) MarshalJSON() ([]byte, error) + type NullableTableReadResponse struct + func NewNullableTableReadResponse(val *TableReadResponse) *NullableTableReadResponse + func (v *NullableTableReadResponse) Set(val *TableReadResponse) + func (v *NullableTableReadResponse) UnmarshalJSON(src []byte) error + func (v *NullableTableReadResponse) Unset() + func (v NullableTableReadResponse) Get() *TableReadResponse + func (v NullableTableReadResponse) IsSet() bool + func (v NullableTableReadResponse) MarshalJSON() ([]byte, error) + type NullableThreadCloseDecision struct + func NewNullableThreadCloseDecision(val *ThreadCloseDecision) *NullableThreadCloseDecision + func (v *NullableThreadCloseDecision) Set(val *ThreadCloseDecision) + func (v *NullableThreadCloseDecision) UnmarshalJSON(src []byte) error + func (v *NullableThreadCloseDecision) Unset() + func (v NullableThreadCloseDecision) Get() *ThreadCloseDecision + func (v NullableThreadCloseDecision) IsSet() bool + func (v NullableThreadCloseDecision) MarshalJSON() ([]byte, error) + type NullableThreadCloseType struct + func NewNullableThreadCloseType(val *ThreadCloseType) *NullableThreadCloseType + func (v *NullableThreadCloseType) Set(val *ThreadCloseType) + func (v *NullableThreadCloseType) UnmarshalJSON(src []byte) error + func (v *NullableThreadCloseType) Unset() + func (v NullableThreadCloseType) Get() *ThreadCloseType + func (v NullableThreadCloseType) IsSet() bool + func (v NullableThreadCloseType) MarshalJSON() ([]byte, error) + type NullableTime struct + func NewNullableTime(val *time.Time) *NullableTime + func (v *NullableTime) Set(val *time.Time) + func (v *NullableTime) UnmarshalJSON(src []byte) error + func (v *NullableTime) Unset() + func (v NullableTime) Get() *time.Time + func (v NullableTime) IsSet() bool + func (v NullableTime) MarshalJSON() ([]byte, error) + type NullableTimerCommand struct + func NewNullableTimerCommand(val *TimerCommand) *NullableTimerCommand + func (v *NullableTimerCommand) Set(val *TimerCommand) + func (v *NullableTimerCommand) UnmarshalJSON(src []byte) error + func (v *NullableTimerCommand) Unset() + func (v NullableTimerCommand) Get() *TimerCommand + func (v NullableTimerCommand) IsSet() bool + func (v NullableTimerCommand) MarshalJSON() ([]byte, error) + type NullableTimerResult struct + func NewNullableTimerResult(val *TimerResult) *NullableTimerResult + func (v *NullableTimerResult) Set(val *TimerResult) + func (v *NullableTimerResult) UnmarshalJSON(src []byte) error + func (v *NullableTimerResult) Unset() + func (v NullableTimerResult) Get() *TimerResult + func (v NullableTimerResult) IsSet() bool + func (v NullableTimerResult) MarshalJSON() ([]byte, error) + type NullableWorkerErrorResponse struct + func NewNullableWorkerErrorResponse(val *WorkerErrorResponse) *NullableWorkerErrorResponse + func (v *NullableWorkerErrorResponse) Set(val *WorkerErrorResponse) + func (v *NullableWorkerErrorResponse) UnmarshalJSON(src []byte) error + func (v *NullableWorkerErrorResponse) Unset() + func (v NullableWorkerErrorResponse) Get() *WorkerErrorResponse + func (v NullableWorkerErrorResponse) IsSet() bool + func (v NullableWorkerErrorResponse) MarshalJSON() ([]byte, error) + type ProcessExecutionDescribeRequest struct + Namespace string + ProcessId string + func NewProcessExecutionDescribeRequest(namespace string, processId string) *ProcessExecutionDescribeRequest + func NewProcessExecutionDescribeRequestWithDefaults() *ProcessExecutionDescribeRequest + func (o *ProcessExecutionDescribeRequest) GetNamespace() string + func (o *ProcessExecutionDescribeRequest) GetNamespaceOk() (*string, bool) + func (o *ProcessExecutionDescribeRequest) GetProcessId() string + func (o *ProcessExecutionDescribeRequest) GetProcessIdOk() (*string, bool) + func (o *ProcessExecutionDescribeRequest) SetNamespace(v string) + func (o *ProcessExecutionDescribeRequest) SetProcessId(v string) + func (o *ProcessExecutionDescribeRequest) UnmarshalJSON(bytes []byte) (err error) + func (o ProcessExecutionDescribeRequest) MarshalJSON() ([]byte, error) + func (o ProcessExecutionDescribeRequest) ToMap() (map[string]interface{}, error) + type ProcessExecutionDescribeResponse struct + ProcessExecutionId *string + ProcessType *string + StartTimestamp *int32 + Status *ProcessStatus + WorkerUrl *string + func NewProcessExecutionDescribeResponse() *ProcessExecutionDescribeResponse + func NewProcessExecutionDescribeResponseWithDefaults() *ProcessExecutionDescribeResponse + func (o *ProcessExecutionDescribeResponse) GetProcessExecutionId() string + func (o *ProcessExecutionDescribeResponse) GetProcessExecutionIdOk() (*string, bool) + func (o *ProcessExecutionDescribeResponse) GetProcessType() string + func (o *ProcessExecutionDescribeResponse) GetProcessTypeOk() (*string, bool) + func (o *ProcessExecutionDescribeResponse) GetStartTimestamp() int32 + func (o *ProcessExecutionDescribeResponse) GetStartTimestampOk() (*int32, bool) + func (o *ProcessExecutionDescribeResponse) GetStatus() ProcessStatus + func (o *ProcessExecutionDescribeResponse) GetStatusOk() (*ProcessStatus, bool) + func (o *ProcessExecutionDescribeResponse) GetWorkerUrl() string + func (o *ProcessExecutionDescribeResponse) GetWorkerUrlOk() (*string, bool) + func (o *ProcessExecutionDescribeResponse) HasProcessExecutionId() bool + func (o *ProcessExecutionDescribeResponse) HasProcessType() bool + func (o *ProcessExecutionDescribeResponse) HasStartTimestamp() bool + func (o *ProcessExecutionDescribeResponse) HasStatus() bool + func (o *ProcessExecutionDescribeResponse) HasWorkerUrl() bool + func (o *ProcessExecutionDescribeResponse) SetProcessExecutionId(v string) + func (o *ProcessExecutionDescribeResponse) SetProcessType(v string) + func (o *ProcessExecutionDescribeResponse) SetStartTimestamp(v int32) + func (o *ProcessExecutionDescribeResponse) SetStatus(v ProcessStatus) + func (o *ProcessExecutionDescribeResponse) SetWorkerUrl(v string) + func (o ProcessExecutionDescribeResponse) MarshalJSON() ([]byte, error) + func (o ProcessExecutionDescribeResponse) ToMap() (map[string]interface{}, error) + type ProcessExecutionRpcRequest struct + Input *EncodedObject + LoadGlobalAttributesRequest *LoadGlobalAttributesRequest + Namespace string + ProcessId string + RpcName string + TimeoutSeconds *int32 + func NewProcessExecutionRpcRequest(namespace string, processId string, rpcName string) *ProcessExecutionRpcRequest + func NewProcessExecutionRpcRequestWithDefaults() *ProcessExecutionRpcRequest + func (o *ProcessExecutionRpcRequest) GetInput() EncodedObject + func (o *ProcessExecutionRpcRequest) GetInputOk() (*EncodedObject, bool) + func (o *ProcessExecutionRpcRequest) GetLoadGlobalAttributesRequest() LoadGlobalAttributesRequest + func (o *ProcessExecutionRpcRequest) GetLoadGlobalAttributesRequestOk() (*LoadGlobalAttributesRequest, bool) + func (o *ProcessExecutionRpcRequest) GetNamespace() string + func (o *ProcessExecutionRpcRequest) GetNamespaceOk() (*string, bool) + func (o *ProcessExecutionRpcRequest) GetProcessId() string + func (o *ProcessExecutionRpcRequest) GetProcessIdOk() (*string, bool) + func (o *ProcessExecutionRpcRequest) GetRpcName() string + func (o *ProcessExecutionRpcRequest) GetRpcNameOk() (*string, bool) + func (o *ProcessExecutionRpcRequest) GetTimeoutSeconds() int32 + func (o *ProcessExecutionRpcRequest) GetTimeoutSecondsOk() (*int32, bool) + func (o *ProcessExecutionRpcRequest) HasInput() bool + func (o *ProcessExecutionRpcRequest) HasLoadGlobalAttributesRequest() bool + func (o *ProcessExecutionRpcRequest) HasTimeoutSeconds() bool + func (o *ProcessExecutionRpcRequest) SetInput(v EncodedObject) + func (o *ProcessExecutionRpcRequest) SetLoadGlobalAttributesRequest(v LoadGlobalAttributesRequest) + func (o *ProcessExecutionRpcRequest) SetNamespace(v string) + func (o *ProcessExecutionRpcRequest) SetProcessId(v string) + func (o *ProcessExecutionRpcRequest) SetRpcName(v string) + func (o *ProcessExecutionRpcRequest) SetTimeoutSeconds(v int32) + func (o *ProcessExecutionRpcRequest) UnmarshalJSON(bytes []byte) (err error) + func (o ProcessExecutionRpcRequest) MarshalJSON() ([]byte, error) + func (o ProcessExecutionRpcRequest) ToMap() (map[string]interface{}, error) + type ProcessExecutionRpcResponse struct + Output *EncodedObject + func NewProcessExecutionRpcResponse() *ProcessExecutionRpcResponse + func NewProcessExecutionRpcResponseWithDefaults() *ProcessExecutionRpcResponse + func (o *ProcessExecutionRpcResponse) GetOutput() EncodedObject + func (o *ProcessExecutionRpcResponse) GetOutputOk() (*EncodedObject, bool) + func (o *ProcessExecutionRpcResponse) HasOutput() bool + func (o *ProcessExecutionRpcResponse) SetOutput(v EncodedObject) + func (o ProcessExecutionRpcResponse) MarshalJSON() ([]byte, error) + func (o ProcessExecutionRpcResponse) ToMap() (map[string]interface{}, error) + type ProcessExecutionStartRequest struct + Namespace string + ProcessId string + ProcessStartConfig *ProcessStartConfig + ProcessType string + StartStateConfig *AsyncStateConfig + StartStateId *string + StartStateInput *EncodedObject + WorkerUrl string + func NewProcessExecutionStartRequest(namespace string, processId string, processType string, workerUrl string) *ProcessExecutionStartRequest + func NewProcessExecutionStartRequestWithDefaults() *ProcessExecutionStartRequest + func (o *ProcessExecutionStartRequest) GetNamespace() string + func (o *ProcessExecutionStartRequest) GetNamespaceOk() (*string, bool) + func (o *ProcessExecutionStartRequest) GetProcessId() string + func (o *ProcessExecutionStartRequest) GetProcessIdOk() (*string, bool) + func (o *ProcessExecutionStartRequest) GetProcessStartConfig() ProcessStartConfig + func (o *ProcessExecutionStartRequest) GetProcessStartConfigOk() (*ProcessStartConfig, bool) + func (o *ProcessExecutionStartRequest) GetProcessType() string + func (o *ProcessExecutionStartRequest) GetProcessTypeOk() (*string, bool) + func (o *ProcessExecutionStartRequest) GetStartStateConfig() AsyncStateConfig + func (o *ProcessExecutionStartRequest) GetStartStateConfigOk() (*AsyncStateConfig, bool) + func (o *ProcessExecutionStartRequest) GetStartStateId() string + func (o *ProcessExecutionStartRequest) GetStartStateIdOk() (*string, bool) + func (o *ProcessExecutionStartRequest) GetStartStateInput() EncodedObject + func (o *ProcessExecutionStartRequest) GetStartStateInputOk() (*EncodedObject, bool) + func (o *ProcessExecutionStartRequest) GetWorkerUrl() string + func (o *ProcessExecutionStartRequest) GetWorkerUrlOk() (*string, bool) + func (o *ProcessExecutionStartRequest) HasProcessStartConfig() bool + func (o *ProcessExecutionStartRequest) HasStartStateConfig() bool + func (o *ProcessExecutionStartRequest) HasStartStateId() bool + func (o *ProcessExecutionStartRequest) HasStartStateInput() bool + func (o *ProcessExecutionStartRequest) SetNamespace(v string) + func (o *ProcessExecutionStartRequest) SetProcessId(v string) + func (o *ProcessExecutionStartRequest) SetProcessStartConfig(v ProcessStartConfig) + func (o *ProcessExecutionStartRequest) SetProcessType(v string) + func (o *ProcessExecutionStartRequest) SetStartStateConfig(v AsyncStateConfig) + func (o *ProcessExecutionStartRequest) SetStartStateId(v string) + func (o *ProcessExecutionStartRequest) SetStartStateInput(v EncodedObject) + func (o *ProcessExecutionStartRequest) SetWorkerUrl(v string) + func (o *ProcessExecutionStartRequest) UnmarshalJSON(bytes []byte) (err error) + func (o ProcessExecutionStartRequest) MarshalJSON() ([]byte, error) + func (o ProcessExecutionStartRequest) ToMap() (map[string]interface{}, error) + type ProcessExecutionStartResponse struct + ProcessExecutionId string + func NewProcessExecutionStartResponse(processExecutionId string) *ProcessExecutionStartResponse + func NewProcessExecutionStartResponseWithDefaults() *ProcessExecutionStartResponse + func (o *ProcessExecutionStartResponse) GetProcessExecutionId() string + func (o *ProcessExecutionStartResponse) GetProcessExecutionIdOk() (*string, bool) + func (o *ProcessExecutionStartResponse) SetProcessExecutionId(v string) + func (o *ProcessExecutionStartResponse) UnmarshalJSON(bytes []byte) (err error) + func (o ProcessExecutionStartResponse) MarshalJSON() ([]byte, error) + func (o ProcessExecutionStartResponse) ToMap() (map[string]interface{}, error) + type ProcessExecutionStopRequest struct + Namespace string + ProcessId string + StopType *ProcessExecutionStopType + func NewProcessExecutionStopRequest(namespace string, processId string) *ProcessExecutionStopRequest + func NewProcessExecutionStopRequestWithDefaults() *ProcessExecutionStopRequest + func (o *ProcessExecutionStopRequest) GetNamespace() string + func (o *ProcessExecutionStopRequest) GetNamespaceOk() (*string, bool) + func (o *ProcessExecutionStopRequest) GetProcessId() string + func (o *ProcessExecutionStopRequest) GetProcessIdOk() (*string, bool) + func (o *ProcessExecutionStopRequest) GetStopType() ProcessExecutionStopType + func (o *ProcessExecutionStopRequest) GetStopTypeOk() (*ProcessExecutionStopType, bool) + func (o *ProcessExecutionStopRequest) HasStopType() bool + func (o *ProcessExecutionStopRequest) SetNamespace(v string) + func (o *ProcessExecutionStopRequest) SetProcessId(v string) + func (o *ProcessExecutionStopRequest) SetStopType(v ProcessExecutionStopType) + func (o *ProcessExecutionStopRequest) UnmarshalJSON(bytes []byte) (err error) + func (o ProcessExecutionStopRequest) MarshalJSON() ([]byte, error) + func (o ProcessExecutionStopRequest) ToMap() (map[string]interface{}, error) + type ProcessExecutionStopType string + const FAIL + const TERMINATE + func NewProcessExecutionStopTypeFromValue(v string) (*ProcessExecutionStopType, error) + func (v *ProcessExecutionStopType) UnmarshalJSON(src []byte) error + func (v ProcessExecutionStopType) IsValid() bool + func (v ProcessExecutionStopType) Ptr() *ProcessExecutionStopType + type ProcessIdReusePolicy string + const ALLOW_IF_NO_RUNNING + const ALLOW_IF_PREVIOUS_EXIT_ABNORMALLY + const DISALLOW_REUSE + const TERMINATE_IF_RUNNING + func NewProcessIdReusePolicyFromValue(v string) (*ProcessIdReusePolicy, error) + func (v *ProcessIdReusePolicy) UnmarshalJSON(src []byte) error + func (v ProcessIdReusePolicy) IsValid() bool + func (v ProcessIdReusePolicy) Ptr() *ProcessIdReusePolicy + type ProcessRpcWorkerRequest struct + Context Context + Input *EncodedObject + LoadedGlobalAttributes *LoadGlobalAttributeResponse + ProcessType string + RpcName string + func NewProcessRpcWorkerRequest(context Context, processType string, rpcName string) *ProcessRpcWorkerRequest + func NewProcessRpcWorkerRequestWithDefaults() *ProcessRpcWorkerRequest + func (o *ProcessRpcWorkerRequest) GetContext() Context + func (o *ProcessRpcWorkerRequest) GetContextOk() (*Context, bool) + func (o *ProcessRpcWorkerRequest) GetInput() EncodedObject + func (o *ProcessRpcWorkerRequest) GetInputOk() (*EncodedObject, bool) + func (o *ProcessRpcWorkerRequest) GetLoadedGlobalAttributes() LoadGlobalAttributeResponse + func (o *ProcessRpcWorkerRequest) GetLoadedGlobalAttributesOk() (*LoadGlobalAttributeResponse, bool) + func (o *ProcessRpcWorkerRequest) GetProcessType() string + func (o *ProcessRpcWorkerRequest) GetProcessTypeOk() (*string, bool) + func (o *ProcessRpcWorkerRequest) GetRpcName() string + func (o *ProcessRpcWorkerRequest) GetRpcNameOk() (*string, bool) + func (o *ProcessRpcWorkerRequest) HasInput() bool + func (o *ProcessRpcWorkerRequest) HasLoadedGlobalAttributes() bool + func (o *ProcessRpcWorkerRequest) SetContext(v Context) + func (o *ProcessRpcWorkerRequest) SetInput(v EncodedObject) + func (o *ProcessRpcWorkerRequest) SetLoadedGlobalAttributes(v LoadGlobalAttributeResponse) + func (o *ProcessRpcWorkerRequest) SetProcessType(v string) + func (o *ProcessRpcWorkerRequest) SetRpcName(v string) + func (o *ProcessRpcWorkerRequest) UnmarshalJSON(bytes []byte) (err error) + func (o ProcessRpcWorkerRequest) MarshalJSON() ([]byte, error) + func (o ProcessRpcWorkerRequest) ToMap() (map[string]interface{}, error) + type ProcessRpcWorkerResponse struct + Output *EncodedObject + PublishToLocalQueue []LocalQueueMessage + StateDecision StateDecision + WriteToGlobalAttributes []GlobalAttributeTableRowUpdate + func NewProcessRpcWorkerResponse(stateDecision StateDecision) *ProcessRpcWorkerResponse + func NewProcessRpcWorkerResponseWithDefaults() *ProcessRpcWorkerResponse + func (o *ProcessRpcWorkerResponse) GetOutput() EncodedObject + func (o *ProcessRpcWorkerResponse) GetOutputOk() (*EncodedObject, bool) + func (o *ProcessRpcWorkerResponse) GetPublishToLocalQueue() []LocalQueueMessage + func (o *ProcessRpcWorkerResponse) GetPublishToLocalQueueOk() ([]LocalQueueMessage, bool) + func (o *ProcessRpcWorkerResponse) GetStateDecision() StateDecision + func (o *ProcessRpcWorkerResponse) GetStateDecisionOk() (*StateDecision, bool) + func (o *ProcessRpcWorkerResponse) GetWriteToGlobalAttributes() []GlobalAttributeTableRowUpdate + func (o *ProcessRpcWorkerResponse) GetWriteToGlobalAttributesOk() ([]GlobalAttributeTableRowUpdate, bool) + func (o *ProcessRpcWorkerResponse) HasOutput() bool + func (o *ProcessRpcWorkerResponse) HasPublishToLocalQueue() bool + func (o *ProcessRpcWorkerResponse) HasWriteToGlobalAttributes() bool + func (o *ProcessRpcWorkerResponse) SetOutput(v EncodedObject) + func (o *ProcessRpcWorkerResponse) SetPublishToLocalQueue(v []LocalQueueMessage) + func (o *ProcessRpcWorkerResponse) SetStateDecision(v StateDecision) + func (o *ProcessRpcWorkerResponse) SetWriteToGlobalAttributes(v []GlobalAttributeTableRowUpdate) + func (o *ProcessRpcWorkerResponse) UnmarshalJSON(bytes []byte) (err error) + func (o ProcessRpcWorkerResponse) MarshalJSON() ([]byte, error) + func (o ProcessRpcWorkerResponse) ToMap() (map[string]interface{}, error) + type ProcessStartConfig struct + GlobalAttributeConfig *GlobalAttributeConfig + IdReusePolicy *ProcessIdReusePolicy + LocalAttributeConfig *LocalAttributeConfig + TimeoutSeconds *int32 + func NewProcessStartConfig() *ProcessStartConfig + func NewProcessStartConfigWithDefaults() *ProcessStartConfig + func (o *ProcessStartConfig) GetGlobalAttributeConfig() GlobalAttributeConfig + func (o *ProcessStartConfig) GetGlobalAttributeConfigOk() (*GlobalAttributeConfig, bool) + func (o *ProcessStartConfig) GetIdReusePolicy() ProcessIdReusePolicy + func (o *ProcessStartConfig) GetIdReusePolicyOk() (*ProcessIdReusePolicy, bool) + func (o *ProcessStartConfig) GetLocalAttributeConfig() LocalAttributeConfig + func (o *ProcessStartConfig) GetLocalAttributeConfigOk() (*LocalAttributeConfig, bool) + func (o *ProcessStartConfig) GetTimeoutSeconds() int32 + func (o *ProcessStartConfig) GetTimeoutSecondsOk() (*int32, bool) + func (o *ProcessStartConfig) HasGlobalAttributeConfig() bool + func (o *ProcessStartConfig) HasIdReusePolicy() bool + func (o *ProcessStartConfig) HasLocalAttributeConfig() bool + func (o *ProcessStartConfig) HasTimeoutSeconds() bool + func (o *ProcessStartConfig) SetGlobalAttributeConfig(v GlobalAttributeConfig) + func (o *ProcessStartConfig) SetIdReusePolicy(v ProcessIdReusePolicy) + func (o *ProcessStartConfig) SetLocalAttributeConfig(v LocalAttributeConfig) + func (o *ProcessStartConfig) SetTimeoutSeconds(v int32) + func (o ProcessStartConfig) MarshalJSON() ([]byte, error) + func (o ProcessStartConfig) ToMap() (map[string]interface{}, error) + type ProcessStatus string + const COMPLETED + const FAILED + const RUNNING + const TERMINATED + const TIMEOUT + func NewProcessStatusFromValue(v string) (*ProcessStatus, error) + func (v *ProcessStatus) UnmarshalJSON(src []byte) error + func (v ProcessStatus) IsValid() bool + func (v ProcessStatus) Ptr() *ProcessStatus + type PublishToLocalQueueRequest struct + Messages []LocalQueueMessage + Namespace string + ProcessId string + func NewPublishToLocalQueueRequest(namespace string, processId string) *PublishToLocalQueueRequest + func NewPublishToLocalQueueRequestWithDefaults() *PublishToLocalQueueRequest + func (o *PublishToLocalQueueRequest) GetMessages() []LocalQueueMessage + func (o *PublishToLocalQueueRequest) GetMessagesOk() ([]LocalQueueMessage, bool) + func (o *PublishToLocalQueueRequest) GetNamespace() string + func (o *PublishToLocalQueueRequest) GetNamespaceOk() (*string, bool) + func (o *PublishToLocalQueueRequest) GetProcessId() string + func (o *PublishToLocalQueueRequest) GetProcessIdOk() (*string, bool) + func (o *PublishToLocalQueueRequest) HasMessages() bool + func (o *PublishToLocalQueueRequest) SetMessages(v []LocalQueueMessage) + func (o *PublishToLocalQueueRequest) SetNamespace(v string) + func (o *PublishToLocalQueueRequest) SetProcessId(v string) + func (o *PublishToLocalQueueRequest) UnmarshalJSON(bytes []byte) (err error) + func (o PublishToLocalQueueRequest) MarshalJSON() ([]byte, error) + func (o PublishToLocalQueueRequest) ToMap() (map[string]interface{}, error) + type RetryPolicy struct + BackoffCoefficient *float32 + InitialIntervalSeconds *int32 + MaximumAttempts *int32 + MaximumAttemptsDurationSeconds *int32 + MaximumIntervalSeconds *int32 + func NewRetryPolicy() *RetryPolicy + func NewRetryPolicyWithDefaults() *RetryPolicy + func (o *RetryPolicy) GetBackoffCoefficient() float32 + func (o *RetryPolicy) GetBackoffCoefficientOk() (*float32, bool) + func (o *RetryPolicy) GetInitialIntervalSeconds() int32 + func (o *RetryPolicy) GetInitialIntervalSecondsOk() (*int32, bool) + func (o *RetryPolicy) GetMaximumAttempts() int32 + func (o *RetryPolicy) GetMaximumAttemptsDurationSeconds() int32 + func (o *RetryPolicy) GetMaximumAttemptsDurationSecondsOk() (*int32, bool) + func (o *RetryPolicy) GetMaximumAttemptsOk() (*int32, bool) + func (o *RetryPolicy) GetMaximumIntervalSeconds() int32 + func (o *RetryPolicy) GetMaximumIntervalSecondsOk() (*int32, bool) + func (o *RetryPolicy) HasBackoffCoefficient() bool + func (o *RetryPolicy) HasInitialIntervalSeconds() bool + func (o *RetryPolicy) HasMaximumAttempts() bool + func (o *RetryPolicy) HasMaximumAttemptsDurationSeconds() bool + func (o *RetryPolicy) HasMaximumIntervalSeconds() bool + func (o *RetryPolicy) SetBackoffCoefficient(v float32) + func (o *RetryPolicy) SetInitialIntervalSeconds(v int32) + func (o *RetryPolicy) SetMaximumAttempts(v int32) + func (o *RetryPolicy) SetMaximumAttemptsDurationSeconds(v int32) + func (o *RetryPolicy) SetMaximumIntervalSeconds(v int32) + func (o RetryPolicy) MarshalJSON() ([]byte, error) + func (o RetryPolicy) ToMap() (map[string]interface{}, error) + type ServerConfiguration struct + Description string + URL string + Variables map[string]ServerVariable + type ServerConfigurations []ServerConfiguration + func (sc ServerConfigurations) URL(index int, variables map[string]string) (string, error) + type ServerVariable struct + DefaultValue string + Description string + EnumValues []string + type StateApiType string + const EXECUTE_API + const WAIT_UNTIL_API + func NewStateApiTypeFromValue(v string) (*StateApiType, error) + func (v *StateApiType) UnmarshalJSON(src []byte) error + func (v StateApiType) IsValid() bool + func (v StateApiType) Ptr() *StateApiType + type StateDecision struct + NextStates []StateMovement + ThreadCloseDecision *ThreadCloseDecision + func NewStateDecision() *StateDecision + func NewStateDecisionWithDefaults() *StateDecision + func (o *StateDecision) GetNextStates() []StateMovement + func (o *StateDecision) GetNextStatesOk() ([]StateMovement, bool) + func (o *StateDecision) GetThreadCloseDecision() ThreadCloseDecision + func (o *StateDecision) GetThreadCloseDecisionOk() (*ThreadCloseDecision, bool) + func (o *StateDecision) HasNextStates() bool + func (o *StateDecision) HasThreadCloseDecision() bool + func (o *StateDecision) SetNextStates(v []StateMovement) + func (o *StateDecision) SetThreadCloseDecision(v ThreadCloseDecision) + func (o StateDecision) MarshalJSON() ([]byte, error) + func (o StateDecision) ToMap() (map[string]interface{}, error) + type StateFailureRecoveryOptions struct + Policy StateFailureRecoveryPolicy + StateFailureProceedStateConfig *AsyncStateConfig + StateFailureProceedStateId *string + func NewStateFailureRecoveryOptions(policy StateFailureRecoveryPolicy) *StateFailureRecoveryOptions + func NewStateFailureRecoveryOptionsWithDefaults() *StateFailureRecoveryOptions + func (o *StateFailureRecoveryOptions) GetPolicy() StateFailureRecoveryPolicy + func (o *StateFailureRecoveryOptions) GetPolicyOk() (*StateFailureRecoveryPolicy, bool) + func (o *StateFailureRecoveryOptions) GetStateFailureProceedStateConfig() AsyncStateConfig + func (o *StateFailureRecoveryOptions) GetStateFailureProceedStateConfigOk() (*AsyncStateConfig, bool) + func (o *StateFailureRecoveryOptions) GetStateFailureProceedStateId() string + func (o *StateFailureRecoveryOptions) GetStateFailureProceedStateIdOk() (*string, bool) + func (o *StateFailureRecoveryOptions) HasStateFailureProceedStateConfig() bool + func (o *StateFailureRecoveryOptions) HasStateFailureProceedStateId() bool + func (o *StateFailureRecoveryOptions) SetPolicy(v StateFailureRecoveryPolicy) + func (o *StateFailureRecoveryOptions) SetStateFailureProceedStateConfig(v AsyncStateConfig) + func (o *StateFailureRecoveryOptions) SetStateFailureProceedStateId(v string) + func (o *StateFailureRecoveryOptions) UnmarshalJSON(bytes []byte) (err error) + func (o StateFailureRecoveryOptions) MarshalJSON() ([]byte, error) + func (o StateFailureRecoveryOptions) ToMap() (map[string]interface{}, error) + type StateFailureRecoveryPolicy string + const FAIL_PROCESS_ON_STATE_FAILURE + const PROCEED_TO_CONFIGURED_STATE + func NewStateFailureRecoveryPolicyFromValue(v string) (*StateFailureRecoveryPolicy, error) + func (v *StateFailureRecoveryPolicy) UnmarshalJSON(src []byte) error + func (v StateFailureRecoveryPolicy) IsValid() bool + func (v StateFailureRecoveryPolicy) Ptr() *StateFailureRecoveryPolicy + type StateMovement struct + StateConfig *AsyncStateConfig + StateId string + StateInput *EncodedObject + func NewStateMovement(stateId string) *StateMovement + func NewStateMovementWithDefaults() *StateMovement + func (o *StateMovement) GetStateConfig() AsyncStateConfig + func (o *StateMovement) GetStateConfigOk() (*AsyncStateConfig, bool) + func (o *StateMovement) GetStateId() string + func (o *StateMovement) GetStateIdOk() (*string, bool) + func (o *StateMovement) GetStateInput() EncodedObject + func (o *StateMovement) GetStateInputOk() (*EncodedObject, bool) + func (o *StateMovement) HasStateConfig() bool + func (o *StateMovement) HasStateInput() bool + func (o *StateMovement) SetStateConfig(v AsyncStateConfig) + func (o *StateMovement) SetStateId(v string) + func (o *StateMovement) SetStateInput(v EncodedObject) + func (o *StateMovement) UnmarshalJSON(bytes []byte) (err error) + func (o StateMovement) MarshalJSON() ([]byte, error) + func (o StateMovement) ToMap() (map[string]interface{}, error) + type TableColumnDef struct + DbColumn string + func NewTableColumnDef(dbColumn string) *TableColumnDef + func NewTableColumnDefWithDefaults() *TableColumnDef + func (o *TableColumnDef) GetDbColumn() string + func (o *TableColumnDef) GetDbColumnOk() (*string, bool) + func (o *TableColumnDef) SetDbColumn(v string) + func (o *TableColumnDef) UnmarshalJSON(bytes []byte) (err error) + func (o TableColumnDef) MarshalJSON() ([]byte, error) + func (o TableColumnDef) ToMap() (map[string]interface{}, error) + type TableColumnValue struct + DbColumn string + DbQueryValue string + func NewTableColumnValue(dbColumn string, dbQueryValue string) *TableColumnValue + func NewTableColumnValueWithDefaults() *TableColumnValue + func (o *TableColumnValue) GetDbColumn() string + func (o *TableColumnValue) GetDbColumnOk() (*string, bool) + func (o *TableColumnValue) GetDbQueryValue() string + func (o *TableColumnValue) GetDbQueryValueOk() (*string, bool) + func (o *TableColumnValue) SetDbColumn(v string) + func (o *TableColumnValue) SetDbQueryValue(v string) + func (o *TableColumnValue) UnmarshalJSON(bytes []byte) (err error) + func (o TableColumnValue) MarshalJSON() ([]byte, error) + func (o TableColumnValue) ToMap() (map[string]interface{}, error) + type TableReadLockingPolicy string + const EXCLUSIVE_LOCK + const NO_LOCKING + const SHARE_LOCK + func NewTableReadLockingPolicyFromValue(v string) (*TableReadLockingPolicy, error) + func (v *TableReadLockingPolicy) UnmarshalJSON(src []byte) error + func (v TableReadLockingPolicy) IsValid() bool + func (v TableReadLockingPolicy) Ptr() *TableReadLockingPolicy + type TableReadRequest struct + Columns []TableColumnDef + LockingPolicy *TableReadLockingPolicy + TableName *string + func NewTableReadRequest() *TableReadRequest + func NewTableReadRequestWithDefaults() *TableReadRequest + func (o *TableReadRequest) GetColumns() []TableColumnDef + func (o *TableReadRequest) GetColumnsOk() ([]TableColumnDef, bool) + func (o *TableReadRequest) GetLockingPolicy() TableReadLockingPolicy + func (o *TableReadRequest) GetLockingPolicyOk() (*TableReadLockingPolicy, bool) + func (o *TableReadRequest) GetTableName() string + func (o *TableReadRequest) GetTableNameOk() (*string, bool) + func (o *TableReadRequest) HasColumns() bool + func (o *TableReadRequest) HasLockingPolicy() bool + func (o *TableReadRequest) HasTableName() bool + func (o *TableReadRequest) SetColumns(v []TableColumnDef) + func (o *TableReadRequest) SetLockingPolicy(v TableReadLockingPolicy) + func (o *TableReadRequest) SetTableName(v string) + func (o TableReadRequest) MarshalJSON() ([]byte, error) + func (o TableReadRequest) ToMap() (map[string]interface{}, error) + type TableReadResponse struct + Columns []TableColumnValue + TableName *string + func NewTableReadResponse() *TableReadResponse + func NewTableReadResponseWithDefaults() *TableReadResponse + func (o *TableReadResponse) GetColumns() []TableColumnValue + func (o *TableReadResponse) GetColumnsOk() ([]TableColumnValue, bool) + func (o *TableReadResponse) GetTableName() string + func (o *TableReadResponse) GetTableNameOk() (*string, bool) + func (o *TableReadResponse) HasColumns() bool + func (o *TableReadResponse) HasTableName() bool + func (o *TableReadResponse) SetColumns(v []TableColumnValue) + func (o *TableReadResponse) SetTableName(v string) + func (o TableReadResponse) MarshalJSON() ([]byte, error) + func (o TableReadResponse) ToMap() (map[string]interface{}, error) + type ThreadCloseDecision struct + CloseInput *EncodedObject + CloseType ThreadCloseType + func NewThreadCloseDecision(closeType ThreadCloseType) *ThreadCloseDecision + func NewThreadCloseDecisionWithDefaults() *ThreadCloseDecision + func (o *ThreadCloseDecision) GetCloseInput() EncodedObject + func (o *ThreadCloseDecision) GetCloseInputOk() (*EncodedObject, bool) + func (o *ThreadCloseDecision) GetCloseType() ThreadCloseType + func (o *ThreadCloseDecision) GetCloseTypeOk() (*ThreadCloseType, bool) + func (o *ThreadCloseDecision) HasCloseInput() bool + func (o *ThreadCloseDecision) SetCloseInput(v EncodedObject) + func (o *ThreadCloseDecision) SetCloseType(v ThreadCloseType) + func (o *ThreadCloseDecision) UnmarshalJSON(bytes []byte) (err error) + func (o ThreadCloseDecision) MarshalJSON() ([]byte, error) + func (o ThreadCloseDecision) ToMap() (map[string]interface{}, error) + type ThreadCloseType string + const DEAD_END + const FORCE_COMPLETE_PROCESS + const FORCE_FAIL_PROCESS + const GRACEFUL_COMPLETE_PROCESS + func NewThreadCloseTypeFromValue(v string) (*ThreadCloseType, error) + func (v *ThreadCloseType) UnmarshalJSON(src []byte) error + func (v ThreadCloseType) IsValid() bool + func (v ThreadCloseType) Ptr() *ThreadCloseType + type TimerCommand struct + DelayInSeconds int64 + func NewTimerCommand(delayInSeconds int64) *TimerCommand + func NewTimerCommandWithDefaults() *TimerCommand + func (o *TimerCommand) GetDelayInSeconds() int64 + func (o *TimerCommand) GetDelayInSecondsOk() (*int64, bool) + func (o *TimerCommand) SetDelayInSeconds(v int64) + func (o *TimerCommand) UnmarshalJSON(bytes []byte) (err error) + func (o TimerCommand) MarshalJSON() ([]byte, error) + func (o TimerCommand) ToMap() (map[string]interface{}, error) + type TimerResult struct + Status CommandStatus + func NewTimerResult(status CommandStatus) *TimerResult + func NewTimerResultWithDefaults() *TimerResult + func (o *TimerResult) GetStatus() CommandStatus + func (o *TimerResult) GetStatusOk() (*CommandStatus, bool) + func (o *TimerResult) SetStatus(v CommandStatus) + func (o *TimerResult) UnmarshalJSON(bytes []byte) (err error) + func (o TimerResult) MarshalJSON() ([]byte, error) + func (o TimerResult) ToMap() (map[string]interface{}, error) + type WorkerErrorResponse struct + Detail *string + ErrorType string + func NewWorkerErrorResponse(errorType string) *WorkerErrorResponse + func NewWorkerErrorResponseWithDefaults() *WorkerErrorResponse + func (o *WorkerErrorResponse) GetDetail() string + func (o *WorkerErrorResponse) GetDetailOk() (*string, bool) + func (o *WorkerErrorResponse) GetErrorType() string + func (o *WorkerErrorResponse) GetErrorTypeOk() (*string, bool) + func (o *WorkerErrorResponse) HasDetail() bool + func (o *WorkerErrorResponse) SetDetail(v string) + func (o *WorkerErrorResponse) SetErrorType(v string) + func (o *WorkerErrorResponse) UnmarshalJSON(bytes []byte) (err error) + func (o WorkerErrorResponse) MarshalJSON() ([]byte, error) + func (o WorkerErrorResponse) ToMap() (map[string]interface{}, error)
Go to main page