v1

type Action int32

type AdminServiceClient interface {
	PutWorkflow(ctx context.Context, in *CreateWorkflowVersionRequest, opts ...grpc.CallOption) (*CreateWorkflowVersionResponse, error)
	CancelTasks(ctx context.Context, in *CancelTasksRequest, opts ...grpc.CallOption) (*CancelTasksResponse, error)
	ReplayTasks(ctx context.Context, in *ReplayTasksRequest, opts ...grpc.CallOption) (*ReplayTasksResponse, error)
	TriggerWorkflowRun(ctx context.Context, in *TriggerWorkflowRunRequest, opts ...grpc.CallOption) (*TriggerWorkflowRunResponse, error)
	GetRunDetails(ctx context.Context, in *GetRunDetailsRequest, opts ...grpc.CallOption) (*GetRunDetailsResponse, error)
	BranchDurableTask(ctx context.Context, in *BranchDurableTaskRequest, opts ...grpc.CallOption) (*BranchDurableTaskResponse, error)
}

type AdminServiceServer interface {
	PutWorkflow(context.Context, *CreateWorkflowVersionRequest) (*CreateWorkflowVersionResponse, error)
	CancelTasks(context.Context, *CancelTasksRequest) (*CancelTasksResponse, error)
	ReplayTasks(context.Context, *ReplayTasksRequest) (*ReplayTasksResponse, error)
	TriggerWorkflowRun(context.Context, *TriggerWorkflowRunRequest) (*TriggerWorkflowRunResponse, error)
	GetRunDetails(context.Context, *GetRunDetailsRequest) (*GetRunDetailsResponse, error)
	BranchDurableTask(context.Context, *BranchDurableTaskRequest) (*BranchDurableTaskResponse, error)
	// contains filtered or unexported methods
}

type BaseMatchCondition struct {
	ReadableDataKey string `protobuf:"bytes,1,opt,name=readable_data_key,json=readableDataKey,proto3" json:"readable_data_key,omitempty"`
	Action          Action `protobuf:"varint,2,opt,name=action,proto3,enum=v1.Action" json:"action,omitempty"`
	OrGroupId       string `protobuf:"bytes,3,opt,name=or_group_id,json=orGroupId,proto3" json:"or_group_id,omitempty"` // a UUID defining the OR group for this condition
	Expression      string `protobuf:"bytes,4,opt,name=expression,proto3" json:"expression,omitempty"`
	// contains filtered or unexported fields
}

type BranchDurableTaskRequest struct {
	TaskExternalId string `protobuf:"bytes,1,opt,name=task_external_id,json=taskExternalId,proto3" json:"task_external_id,omitempty"` // (required) the external id (uuid) of the durable task
	NodeId         int64  `protobuf:"varint,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`                          // (required) the node id to branch from
	BranchId       int64  `protobuf:"varint,3,opt,name=branch_id,json=branchId,proto3" json:"branch_id,omitempty"`                    // (required) the branch id to branch from
	// contains filtered or unexported fields
}

type BranchDurableTaskResponse struct {
	TaskExternalId string `protobuf:"bytes,1,opt,name=task_external_id,json=taskExternalId,proto3" json:"task_external_id,omitempty"` // the external id of the durable task
	NodeId         int64  `protobuf:"varint,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`                          // the node id of the new entry
	BranchId       int64  `protobuf:"varint,3,opt,name=branch_id,json=branchId,proto3" json:"branch_id,omitempty"`                    // the branch id of the new entry
	// contains filtered or unexported fields
}

type BulkTriggerIdempotencyCollisionError struct {
	SuccessfulWorkflowRunExternalIds []string `` // the external IDs of the successfully triggered workflow runs
	/* 163-byte string literal not displayed */
	Collisions []*IdempotencyCollisionError `protobuf:"bytes,2,rep,name=collisions,proto3" json:"collisions,omitempty"` // the idempotency collision errors
	// contains filtered or unexported fields
}

type CancelTasksRequest struct {
	ExternalIds []string     `protobuf:"bytes,1,rep,name=external_ids,json=externalIds,proto3" json:"external_ids,omitempty"` // a list of external UUIDs
	Filter      *TasksFilter `protobuf:"bytes,2,opt,name=filter,proto3,oneof" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

type CancelTasksResponse struct {
	CancelledTasks []string `protobuf:"bytes,1,rep,name=cancelled_tasks,json=cancelledTasks,proto3" json:"cancelled_tasks,omitempty"`
	// contains filtered or unexported fields
}

type Concurrency struct {
	Expression    string                    `protobuf:"bytes,1,opt,name=expression,proto3" json:"expression,omitempty"`                 // (required) the expression to use for concurrency
	MaxRuns       *int32                    `protobuf:"varint,2,opt,name=max_runs,json=maxRuns,proto3,oneof" json:"max_runs,omitempty"` // (optional) the maximum number of concurrent workflow runs, default 1
	LimitStrategy *ConcurrencyLimitStrategy ``                                                                                          // (optional) the strategy to use when the concurrency limit is reached, default CANCEL_IN_PROGRESS
	/* 140-byte string literal not displayed */
	Name              *string `protobuf:"bytes,4,opt,name=name,proto3,oneof" json:"name,omitempty"`                                                      // (required when is_tenant_scoped) the strategy name; unique per tenant for tenant-scoped strategies
	IsTenantScoped    *bool   `protobuf:"varint,5,opt,name=is_tenant_scoped,json=isTenantScoped,proto3,oneof" json:"is_tenant_scoped,omitempty"`         // (optional) when true, the entry is a tenant-scoped strategy shared across workflows, default false
	MaxRunsExpression *string `protobuf:"bytes,6,opt,name=max_runs_expression,json=maxRunsExpression,proto3,oneof" json:"max_runs_expression,omitempty"` // (optional) CEL expression over task input returning the max runs for that task's concurrency group; the group's effective limit is the value from its most recently created task. Overrides max_runs per group; a non-integer or negative result fails the task, and 0 holds the group until a newer task raises the limit
	// contains filtered or unexported fields
}

type ConcurrencyLimitStrategy int32

type CreateTaskOpts struct {
	ReadableId   string                          `protobuf:"bytes,1,opt,name=readable_id,json=readableId,proto3" json:"readable_id,omitempty"` // (required) the task name
	Action       string                          `protobuf:"bytes,2,opt,name=action,proto3" json:"action,omitempty"`                           // (required) the task action id
	Timeout      string                          `protobuf:"bytes,3,opt,name=timeout,proto3" json:"timeout,omitempty"`                         // (optional) the task timeout
	Inputs       string                          `protobuf:"bytes,4,opt,name=inputs,proto3" json:"inputs,omitempty"`                           // (optional) the task inputs, assuming string representation of JSON
	Parents      []string                        `protobuf:"bytes,5,rep,name=parents,proto3" json:"parents,omitempty"`                         // (optional) the task parents. if none are passed in, this is a root task
	Retries      int32                           `protobuf:"varint,6,opt,name=retries,proto3" json:"retries,omitempty"`                        // (optional) the number of retries for the task, default 0
	RateLimits   []*CreateTaskRateLimit          `protobuf:"bytes,7,rep,name=rate_limits,json=rateLimits,proto3" json:"rate_limits,omitempty"` // (optional) the rate limits for the task
	WorkerLabels map[string]*DesiredWorkerLabels ``                                                                                            // (optional) the desired worker affinity state for the task
	/* 185-byte string literal not displayed */
	BackoffFactor     *float32         `protobuf:"fixed32,9,opt,name=backoff_factor,json=backoffFactor,proto3,oneof" json:"backoff_factor,omitempty"`               // (optional) the retry backoff factor for the task
	BackoffMaxSeconds *int32           `protobuf:"varint,10,opt,name=backoff_max_seconds,json=backoffMaxSeconds,proto3,oneof" json:"backoff_max_seconds,omitempty"` // (optional) the maximum backoff time for the task
	Concurrency       []*Concurrency   `protobuf:"bytes,11,rep,name=concurrency,proto3" json:"concurrency,omitempty"`                                               // (optional) the task concurrency options
	Conditions        *TaskConditions  `protobuf:"bytes,12,opt,name=conditions,proto3,oneof" json:"conditions,omitempty"`                                           // (optional) the task conditions for creating the task
	ScheduleTimeout   *string          `protobuf:"bytes,13,opt,name=schedule_timeout,json=scheduleTimeout,proto3,oneof" json:"schedule_timeout,omitempty"`          // (optional) the timeout for the schedule
	IsDurable         bool             `protobuf:"varint,14,opt,name=is_durable,json=isDurable,proto3" json:"is_durable,omitempty"`                                 // (optional) whether the task is durable
	SlotRequests      map[string]int32 ``                                                                                                                           // (optional) slot requests (slot_type -> units)
	/* 187-byte string literal not displayed */
	Batch *TaskBatchConfig `protobuf:"bytes,16,opt,name=batch,proto3,oneof" json:"batch,omitempty"` // (optional) batch execution configuration
	// contains filtered or unexported fields
}

type CreateTaskRateLimit struct {
	Key             string             `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`                                                        // (required) the key for the rate limit
	Units           *int32             `protobuf:"varint,2,opt,name=units,proto3,oneof" json:"units,omitempty"`                                             // (optional) the number of units this task consumes
	KeyExpr         *string            `protobuf:"bytes,3,opt,name=key_expr,json=keyExpr,proto3,oneof" json:"key_expr,omitempty"`                           // (optional) a CEL expression for determining the rate limit key
	UnitsExpr       *string            `protobuf:"bytes,4,opt,name=units_expr,json=unitsExpr,proto3,oneof" json:"units_expr,omitempty"`                     // (optional) a CEL expression for determining the number of units consumed
	LimitValuesExpr *string            `protobuf:"bytes,5,opt,name=limit_values_expr,json=limitValuesExpr,proto3,oneof" json:"limit_values_expr,omitempty"` // (optional) a CEL expression for determining the total amount of rate limit units
	Duration        *RateLimitDuration `protobuf:"varint,6,opt,name=duration,proto3,enum=v1.RateLimitDuration,oneof" json:"duration,omitempty"`             // (optional) the default rate limit window to use for dynamic rate limits
	// contains filtered or unexported fields
}

type CreateWorkflowVersionRequest struct {
	Name          string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`                                        // (required) the workflow name
	Description   string            `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`                          // (optional) the workflow description
	Version       string            `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`                                  // (optional) the workflow version
	EventTriggers []string          `protobuf:"bytes,4,rep,name=event_triggers,json=eventTriggers,proto3" json:"event_triggers,omitempty"` // (optional) event triggers for the workflow
	CronTriggers  []string          `protobuf:"bytes,5,rep,name=cron_triggers,json=cronTriggers,proto3" json:"cron_triggers,omitempty"`    // (optional) cron triggers for the workflow
	Tasks         []*CreateTaskOpts `protobuf:"bytes,6,rep,name=tasks,proto3" json:"tasks,omitempty"`                                      // (required) the workflow jobs
	// Deprecated: use concurrency_arr instead
	Concurrency     *Concurrency       `protobuf:"bytes,7,opt,name=concurrency,proto3" json:"concurrency,omitempty"`                                         // (optional) the workflow concurrency options
	CronInput       *string            `protobuf:"bytes,8,opt,name=cron_input,json=cronInput,proto3,oneof" json:"cron_input,omitempty"`                      // (optional) the input for the cron trigger
	OnFailureTask   *CreateTaskOpts    `protobuf:"bytes,9,opt,name=on_failure_task,json=onFailureTask,proto3,oneof" json:"on_failure_task,omitempty"`        // (optional) the job to run on failure
	Sticky          *StickyStrategy    `protobuf:"varint,10,opt,name=sticky,proto3,enum=v1.StickyStrategy,oneof" json:"sticky,omitempty"`                    // (optional) the sticky strategy for assigning tasks to workers
	DefaultPriority *int32             `protobuf:"varint,11,opt,name=default_priority,json=defaultPriority,proto3,oneof" json:"default_priority,omitempty"`  // (optional) the default priority for the workflow
	ConcurrencyArr  []*Concurrency     `protobuf:"bytes,12,rep,name=concurrency_arr,json=concurrencyArr,proto3" json:"concurrency_arr,omitempty"`            // (optional) the workflow concurrency options
	DefaultFilters  []*DefaultFilter   `protobuf:"bytes,13,rep,name=default_filters,json=defaultFilters,proto3" json:"default_filters,omitempty"`            // (optional) the default filters for the workflow
	InputJsonSchema []byte             `protobuf:"bytes,14,opt,name=input_json_schema,json=inputJsonSchema,proto3,oneof" json:"input_json_schema,omitempty"` // (optional) the JSON schema for the workflow input
	Idempotency     *IdempotencyConfig `protobuf:"bytes,15,opt,name=idempotency,proto3,oneof" json:"idempotency,omitempty"`                                  // (optional) idempotency configuration for the workflow
	// contains filtered or unexported fields
}

type CreateWorkflowVersionResponse struct {
	Id         string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	WorkflowId string `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	// contains filtered or unexported fields
}

type DefaultFilter struct {
	Expression string `protobuf:"bytes,1,opt,name=expression,proto3" json:"expression,omitempty"` // (required) the CEL expression for the filter
	Scope      string `protobuf:"bytes,2,opt,name=scope,proto3" json:"scope,omitempty"`           // (required) the scope of the filter
	Payload    []byte `protobuf:"bytes,3,opt,name=payload,proto3,oneof" json:"payload,omitempty"` // (optional) the payload for the filter, if any. A JSON object as a string.
	// contains filtered or unexported fields
}

type DesiredWorkerLabels struct {

	// value of the affinity
	StrValue *string `protobuf:"bytes,1,opt,name=str_value,json=strValue,proto3,oneof" json:"str_value,omitempty"`
	IntValue *int32  `protobuf:"varint,2,opt,name=int_value,json=intValue,proto3,oneof" json:"int_value,omitempty"`
	// *
	// (optional) Specifies whether the affinity setting is required.
	// If required, the worker will not accept actions that do not have a truthy affinity setting.
	//
	// Defaults to false.
	Required *bool `protobuf:"varint,3,opt,name=required,proto3,oneof" json:"required,omitempty"`
	// *
	// (optional) Specifies the comparator for the affinity setting.
	// If not set, the default is EQUAL.
	Comparator *WorkerLabelComparator `protobuf:"varint,4,opt,name=comparator,proto3,enum=v1.WorkerLabelComparator,oneof" json:"comparator,omitempty"`
	// *
	// (optional) Specifies the weight of the affinity setting.
	// If not set, the default is 100.
	Weight *int32 `protobuf:"varint,5,opt,name=weight,proto3,oneof" json:"weight,omitempty"`
	// contains filtered or unexported fields
}

type DurableEvent struct {
	TaskId    string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	SignalKey string `protobuf:"bytes,2,opt,name=signal_key,json=signalKey,proto3" json:"signal_key,omitempty"`
	Data      []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` // the data for the event
	// contains filtered or unexported fields
}

type DurableEventListenerConditions struct {
	SleepConditions     []*SleepMatchCondition     `protobuf:"bytes,1,rep,name=sleep_conditions,json=sleepConditions,proto3" json:"sleep_conditions,omitempty"`
	UserEventConditions []*UserEventMatchCondition `protobuf:"bytes,2,rep,name=user_event_conditions,json=userEventConditions,proto3" json:"user_event_conditions,omitempty"`
	// contains filtered or unexported fields
}

type DurableEventLogEntryRef struct {
	DurableTaskExternalId string `` /* 128-byte string literal not displayed */
	InvocationCount       int32  `protobuf:"varint,2,opt,name=invocation_count,json=invocationCount,proto3" json:"invocation_count,omitempty"`
	BranchId              int64  `protobuf:"varint,3,opt,name=branch_id,json=branchId,proto3" json:"branch_id,omitempty"`
	NodeId                int64  `protobuf:"varint,4,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// contains filtered or unexported fields
}

type DurableTaskAwaitedCompletedEntry struct {
	DurableTaskExternalId string `` /* 128-byte string literal not displayed */
	BranchId              int64  `protobuf:"varint,2,opt,name=branch_id,json=branchId,proto3" json:"branch_id,omitempty"`
	NodeId                int64  `protobuf:"varint,3,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	InvocationCount       int32  `protobuf:"varint,4,opt,name=invocation_count,json=invocationCount,proto3" json:"invocation_count,omitempty"`
	// contains filtered or unexported fields
}

type DurableTaskCompleteMemoRequest struct {
	Ref     *DurableEventLogEntryRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	Payload []byte                   `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	MemoKey []byte                   `protobuf:"bytes,3,opt,name=memo_key,json=memoKey,proto3" json:"memo_key,omitempty"`
	// contains filtered or unexported fields
}

type DurableTaskErrorResponse struct {
	Ref          *DurableEventLogEntryRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	ErrorType    DurableTaskErrorType     `protobuf:"varint,2,opt,name=error_type,json=errorType,proto3,enum=v1.DurableTaskErrorType" json:"error_type,omitempty"`
	ErrorMessage string                   `protobuf:"bytes,3,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// contains filtered or unexported fields
}

type DurableTaskErrorType int32

type DurableTaskEventLogEntryCompletedResponse struct {
	Ref          *DurableEventLogEntryRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	Payload      []byte                   `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	IsFailure    bool                     `protobuf:"varint,3,opt,name=is_failure,json=isFailure,proto3" json:"is_failure,omitempty"`
	ErrorMessage *string                  `protobuf:"bytes,4,opt,name=error_message,json=errorMessage,proto3,oneof" json:"error_message,omitempty"`
	// contains filtered or unexported fields
}

type DurableTaskEventMemoAckResponse struct {
	Ref                *DurableEventLogEntryRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	MemoAlreadyExisted bool                     `protobuf:"varint,2,opt,name=memo_already_existed,json=memoAlreadyExisted,proto3" json:"memo_already_existed,omitempty"`
	MemoResultPayload  []byte                   `protobuf:"bytes,3,opt,name=memo_result_payload,json=memoResultPayload,proto3,oneof" json:"memo_result_payload,omitempty"`
	// contains filtered or unexported fields
}

type DurableTaskEventTriggerRunsAckResponse struct {
	DurableTaskExternalId string                    `` /* 128-byte string literal not displayed */
	InvocationCount       int32                     `protobuf:"varint,2,opt,name=invocation_count,json=invocationCount,proto3" json:"invocation_count,omitempty"`
	RunEntries            []*DurableTaskRunAckEntry `protobuf:"bytes,3,rep,name=run_entries,json=runEntries,proto3" json:"run_entries,omitempty"`
	// contains filtered or unexported fields
}

type DurableTaskEventWaitForAckResponse struct {
	Ref *DurableEventLogEntryRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// contains filtered or unexported fields
}

type DurableTaskEvictInvocationRequest struct {
	InvocationCount       int32   `protobuf:"varint,1,opt,name=invocation_count,json=invocationCount,proto3" json:"invocation_count,omitempty"`
	DurableTaskExternalId string  `` /* 128-byte string literal not displayed */
	Reason                *string `protobuf:"bytes,3,opt,name=reason,proto3,oneof" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

type DurableTaskEvictionAckResponse struct {
	InvocationCount       int32  `protobuf:"varint,1,opt,name=invocation_count,json=invocationCount,proto3" json:"invocation_count,omitempty"`
	DurableTaskExternalId string `` /* 128-byte string literal not displayed */
	// contains filtered or unexported fields
}

type DurableTaskMemoRequest struct {

	// The invocation_count is a monotonically increasing count that uniquely identifies an "attempt"
	// at running a durable task. Each time the task is started, it gets a new invocation count (which has)
	// incremented by one since the previous invocation. This allows the server (and the worker) to have a way of
	// differentiating between different attempts of the same task running in different places, to prevent race conditions
	// and other problems from duplication. It also allows for older invocations to be evicted cleanly
	InvocationCount       int32  `protobuf:"varint,1,opt,name=invocation_count,json=invocationCount,proto3" json:"invocation_count,omitempty"`
	DurableTaskExternalId string `` /* 128-byte string literal not displayed */
	Key                   []byte `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// optional payload because we can send a memo request to check if a memo already exists
	Payload []byte `protobuf:"bytes,4,opt,name=payload,proto3,oneof" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

type DurableTaskRequest struct {

	// Types that are assignable to Message:
	//
	//	*DurableTaskRequest_RegisterWorker
	//	*DurableTaskRequest_Memo
	//	*DurableTaskRequest_TriggerRuns
	//	*DurableTaskRequest_WaitFor
	//	*DurableTaskRequest_EvictInvocation
	//	*DurableTaskRequest_WorkerStatus
	//	*DurableTaskRequest_CompleteMemo
	Message isDurableTaskRequest_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

type DurableTaskRequestRegisterWorker struct {
	WorkerId string `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	// contains filtered or unexported fields
}

type DurableTaskRequest_CompleteMemo struct {
	CompleteMemo *DurableTaskCompleteMemoRequest `protobuf:"bytes,7,opt,name=complete_memo,json=completeMemo,proto3,oneof"`
}

type DurableTaskRequest_EvictInvocation struct {
	EvictInvocation *DurableTaskEvictInvocationRequest `protobuf:"bytes,5,opt,name=evict_invocation,json=evictInvocation,proto3,oneof"`
}

type DurableTaskRequest_Memo struct {
	Memo *DurableTaskMemoRequest `protobuf:"bytes,2,opt,name=memo,proto3,oneof"`
}

type DurableTaskRequest_RegisterWorker struct {
	RegisterWorker *DurableTaskRequestRegisterWorker `protobuf:"bytes,1,opt,name=register_worker,json=registerWorker,proto3,oneof"`
}

type DurableTaskRequest_TriggerRuns struct {
	TriggerRuns *DurableTaskTriggerRunsRequest `protobuf:"bytes,3,opt,name=trigger_runs,json=triggerRuns,proto3,oneof"`
}

type DurableTaskRequest_WaitFor struct {
	WaitFor *DurableTaskWaitForRequest `protobuf:"bytes,4,opt,name=wait_for,json=waitFor,proto3,oneof"`
}

type DurableTaskRequest_WorkerStatus struct {
	WorkerStatus *DurableTaskWorkerStatusRequest `protobuf:"bytes,6,opt,name=worker_status,json=workerStatus,proto3,oneof"`
}

type DurableTaskResponse struct {

	// Types that are assignable to Message:
	//
	//	*DurableTaskResponse_RegisterWorker
	//	*DurableTaskResponse_MemoAck
	//	*DurableTaskResponse_TriggerRunsAck
	//	*DurableTaskResponse_WaitForAck
	//	*DurableTaskResponse_EntryCompleted
	//	*DurableTaskResponse_Error
	//	*DurableTaskResponse_EvictionAck
	//	*DurableTaskResponse_ServerEvict
	Message isDurableTaskResponse_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

type DurableTaskResponseRegisterWorker struct {
	WorkerId string `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	// contains filtered or unexported fields
}

type DurableTaskResponse_EntryCompleted struct {
	EntryCompleted *DurableTaskEventLogEntryCompletedResponse `protobuf:"bytes,5,opt,name=entry_completed,json=entryCompleted,proto3,oneof"`
}

type DurableTaskResponse_Error struct {
	Error *DurableTaskErrorResponse `protobuf:"bytes,6,opt,name=error,proto3,oneof"`
}

type DurableTaskResponse_EvictionAck struct {
	EvictionAck *DurableTaskEvictionAckResponse `protobuf:"bytes,7,opt,name=eviction_ack,json=evictionAck,proto3,oneof"`
}

type DurableTaskResponse_MemoAck struct {
	MemoAck *DurableTaskEventMemoAckResponse `protobuf:"bytes,2,opt,name=memo_ack,json=memoAck,proto3,oneof"`
}

type DurableTaskResponse_RegisterWorker struct {
	RegisterWorker *DurableTaskResponseRegisterWorker `protobuf:"bytes,1,opt,name=register_worker,json=registerWorker,proto3,oneof"`
}

type DurableTaskResponse_ServerEvict struct {
	ServerEvict *DurableTaskServerEvictNotice `protobuf:"bytes,8,opt,name=server_evict,json=serverEvict,proto3,oneof"`
}

type DurableTaskResponse_TriggerRunsAck struct {
	TriggerRunsAck *DurableTaskEventTriggerRunsAckResponse `protobuf:"bytes,3,opt,name=trigger_runs_ack,json=triggerRunsAck,proto3,oneof"`
}

type DurableTaskResponse_WaitForAck struct {
	WaitForAck *DurableTaskEventWaitForAckResponse `protobuf:"bytes,4,opt,name=wait_for_ack,json=waitForAck,proto3,oneof"`
}

type DurableTaskRunAckEntry struct {
	NodeId                int64  `protobuf:"varint,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	BranchId              int64  `protobuf:"varint,2,opt,name=branch_id,json=branchId,proto3" json:"branch_id,omitempty"`
	WorkflowRunExternalId string `` /* 128-byte string literal not displayed */
	// contains filtered or unexported fields
}

type DurableTaskServerEvictNotice struct {
	DurableTaskExternalId string `` /* 128-byte string literal not displayed */
	InvocationCount       int32  `protobuf:"varint,2,opt,name=invocation_count,json=invocationCount,proto3" json:"invocation_count,omitempty"`
	Reason                string `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

type DurableTaskTriggerRunsRequest struct {

	// The invocation_count is a monotonically increasing count that uniquely identifies an "attempt"
	// at running a durable task. Each time the task is started, it gets a new invocation count (which has)
	// incremented by one since the previous invocation. This allows the server (and the worker) to have a way of
	// differentiating between different attempts of the same task running in different places, to prevent race conditions
	// and other problems from duplication. It also allows for older invocations to be evicted cleanly
	InvocationCount       int32                     `protobuf:"varint,1,opt,name=invocation_count,json=invocationCount,proto3" json:"invocation_count,omitempty"`
	DurableTaskExternalId string                    `` /* 128-byte string literal not displayed */
	TriggerOpts           []*TriggerWorkflowRequest `protobuf:"bytes,3,rep,name=trigger_opts,json=triggerOpts,proto3" json:"trigger_opts,omitempty"`
	// contains filtered or unexported fields
}

type DurableTaskWaitForRequest struct {

	// The invocation_count is a monotonically increasing count that uniquely identifies an "attempt"
	// at running a durable task. Each time the task is started, it gets a new invocation count (which has)
	// incremented by one since the previous invocation. This allows the server (and the worker) to have a way of
	// differentiating between different attempts of the same task running in different places, to prevent race conditions
	// and other problems from duplication. It also allows for older invocations to be evicted cleanly
	InvocationCount       int32  `protobuf:"varint,1,opt,name=invocation_count,json=invocationCount,proto3" json:"invocation_count,omitempty"`
	DurableTaskExternalId string `` /* 128-byte string literal not displayed */
	// Fields for DURABLE_TASK_TRIGGER_KIND_WAIT_FOR
	WaitForConditions *DurableEventListenerConditions `protobuf:"bytes,3,opt,name=wait_for_conditions,json=waitForConditions,proto3,oneof" json:"wait_for_conditions,omitempty"`
	// An optional human-readable label for this wait, displayed in the dashboard.
	// Example: "Waiting for payment confirmation"
	Label *string `protobuf:"bytes,4,opt,name=label,proto3,oneof" json:"label,omitempty"`
	// contains filtered or unexported fields
}

type DurableTaskWorkerStatusRequest struct {
	WorkerId       string                              `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	WaitingEntries []*DurableTaskAwaitedCompletedEntry `protobuf:"bytes,2,rep,name=waiting_entries,json=waitingEntries,proto3" json:"waiting_entries,omitempty"`
	// contains filtered or unexported fields
}

type GetRunDetailsRequest struct {
	ExternalId string `protobuf:"bytes,1,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"` // (required) the external id (uuid) of the workflow run
	// contains filtered or unexported fields
}

type GetRunDetailsResponse struct {
	Input    []byte                    `protobuf:"bytes,1,opt,name=input,proto3" json:"input,omitempty"`                      // the input payload for the workflow run
	Status   RunStatus                 `protobuf:"varint,2,opt,name=status,proto3,enum=v1.RunStatus" json:"status,omitempty"` // the status of the workflow run
	TaskRuns map[string]*TaskRunDetail ``                                                                                     // map of task run external ids to their details
	/* 173-byte string literal not displayed */
	Done               bool   `protobuf:"varint,4,opt,name=done,proto3" json:"done,omitempty"`                                                      // indicates if the workflow run is done
	AdditionalMetadata []byte `protobuf:"bytes,5,opt,name=additional_metadata,json=additionalMetadata,proto3" json:"additional_metadata,omitempty"` // (optional) additional metadata for the workflow run
	IsEvicted          bool   `protobuf:"varint,6,opt,name=is_evicted,json=isEvicted,proto3" json:"is_evicted,omitempty"`                           // whether any task in this run has been evicted
	// contains filtered or unexported fields
}

type GetStreamTopicMetadataRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Topic     string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

type IdempotencyCollisionError struct {
	ExistingRunExternalId string `` // the external ID of the existing workflow run that caused the collision
	/* 128-byte string literal not displayed */
	CollidingRunExternalId string `` // the external ID of the workflow run that caused the collision
	/* 131-byte string literal not displayed */
	// contains filtered or unexported fields
}

type IdempotencyConfig struct {
	Expression string             `protobuf:"bytes,1,opt,name=expression,proto3" json:"expression,omitempty"`                          // a CEL expression for determining the idempotency key for workflow runs
	TtlMs      int64              `protobuf:"varint,2,opt,name=ttl_ms,json=ttlMs,proto3" json:"ttl_ms,omitempty"`                      // time-to-live for idempotency keys in milliseconds. if the method is `STATUS`, this is a "fallback" - the longest the key can live before it's evicted
	Method     *IdempotencyMethod `protobuf:"varint,3,opt,name=method,proto3,enum=v1.IdempotencyMethod,oneof" json:"method,omitempty"` // the method to use for idempotency, defaults to TTL
	// contains filtered or unexported fields
}

type IdempotencyMethod int32

type ListenForDurableEventRequest struct {
	TaskId    string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`          // single listener per worker
	SignalKey string `protobuf:"bytes,2,opt,name=signal_key,json=signalKey,proto3" json:"signal_key,omitempty"` // the match id for the listener
	// contains filtered or unexported fields
}