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 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 */
	// 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 */
	// 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
	// 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"`
	// 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"`
	// 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"`
	// 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 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
}

type ParentOverrideMatchCondition struct {
	Base             *BaseMatchCondition `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	ParentReadableId string              `protobuf:"bytes,2,opt,name=parent_readable_id,json=parentReadableId,proto3" json:"parent_readable_id,omitempty"`
	// contains filtered or unexported fields
}

type RateLimitDuration int32

type RegisterDurableEventRequest struct {
	TaskId     string                          `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`          // external uuid for the task run
	SignalKey  string                          `protobuf:"bytes,2,opt,name=signal_key,json=signalKey,proto3" json:"signal_key,omitempty"` // the signal key for the event
	Conditions *DurableEventListenerConditions `protobuf:"bytes,3,opt,name=conditions,proto3" json:"conditions,omitempty"`                // the task conditions for creating the task
	// contains filtered or unexported fields
}

type RegisterDurableEventResponse struct {
	// contains filtered or unexported fields
}

type ReplayTasksRequest 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 ReplayTasksResponse struct {
	ReplayedTasks []string `protobuf:"bytes,1,rep,name=replayed_tasks,json=replayedTasks,proto3" json:"replayed_tasks,omitempty"`
	// contains filtered or unexported fields
}

type RunStatus int32

type SleepMatchCondition struct {
	Base     *BaseMatchCondition `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	SleepFor string              `protobuf:"bytes,2,opt,name=sleep_for,json=sleepFor,proto3" json:"sleep_for,omitempty"` // a duration string indicating how long to sleep
	// contains filtered or unexported fields
}

type StickyStrategy int32

type TaskConditions struct {
	ParentOverrideConditions []*ParentOverrideMatchCondition `` /* 135-byte string literal not displayed */
	SleepConditions          []*SleepMatchCondition          `protobuf:"bytes,2,rep,name=sleep_conditions,json=sleepConditions,proto3" json:"sleep_conditions,omitempty"`
	UserEventConditions      []*UserEventMatchCondition      `protobuf:"bytes,3,rep,name=user_event_conditions,json=userEventConditions,proto3" json:"user_event_conditions,omitempty"`
	// contains filtered or unexported fields
}

type TaskRunDetail struct {
	ExternalId string    `protobuf:"bytes,1,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"` // the external id (uuid) of the task run
	Status     RunStatus `protobuf:"varint,2,opt,name=status,proto3,enum=v1.RunStatus" json:"status,omitempty"`        // the status of the task run
	Error      *string   `protobuf:"bytes,3,opt,name=error,proto3,oneof" json:"error,omitempty"`                       // (optional) error message from the task run, if any
	Output     []byte    `protobuf:"bytes,4,opt,name=output,proto3,oneof" json:"output,omitempty"`                     // (optional) the output payload for the task run
	ReadableId string    `protobuf:"bytes,5,opt,name=readable_id,json=readableId,proto3" json:"readable_id,omitempty"` // the readable id of the task
	IsEvicted  bool      `protobuf:"varint,6,opt,name=is_evicted,json=isEvicted,proto3" json:"is_evicted,omitempty"`   // whether the task has been evicted from a worker (status will be RUNNING)
	// contains filtered or unexported fields
}

type TasksFilter struct {
	Statuses           []string               `protobuf:"bytes,1,rep,name=statuses,proto3" json:"statuses,omitempty"`
	Since              *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=since,proto3" json:"since,omitempty"`
	Until              *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=until,proto3,oneof" json:"until,omitempty"`
	WorkflowIds        []string               `protobuf:"bytes,4,rep,name=workflow_ids,json=workflowIds,proto3" json:"workflow_ids,omitempty"`
	AdditionalMetadata []string               `protobuf:"bytes,5,rep,name=additional_metadata,json=additionalMetadata,proto3" json:"additional_metadata,omitempty"`
	// contains filtered or unexported fields
}

type TriggerWorkflowRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// (optional) the input data for the workflow
	Input string `protobuf:"bytes,2,opt,name=input,proto3" json:"input,omitempty"`
	// (optional) the parent workflow run id
	ParentId *string `protobuf:"bytes,3,opt,name=parent_id,json=parentId,proto3,oneof" json:"parent_id,omitempty"`
	// (optional) the parent task external run id
	ParentTaskRunExternalId *string `` /* 142-byte string literal not displayed */
	// (optional) the index of the child workflow. if this is set, matches on the index or the
	// child key will return an existing workflow run if the parent id, parent task run id, and
	// child index/key match an existing workflow run.
	ChildIndex *int32 `protobuf:"varint,5,opt,name=child_index,json=childIndex,proto3,oneof" json:"child_index,omitempty"`
	// (optional) the key for the child. if this is set, matches on the index or the
	// child key will return an existing workflow run if the parent id, parent task run id, and
	// child index/key match an existing workflow run.
	ChildKey *string `protobuf:"bytes,6,opt,name=child_key,json=childKey,proto3,oneof" json:"child_key,omitempty"`
	// (optional) additional metadata for the workflow
	AdditionalMetadata *string `protobuf:"bytes,7,opt,name=additional_metadata,json=additionalMetadata,proto3,oneof" json:"additional_metadata,omitempty"`
	// (optional) desired worker id for the workflow run,
	// requires the workflow definition to have a sticky strategy
	DesiredWorkerId *string `protobuf:"bytes,8,opt,name=desired_worker_id,json=desiredWorkerId,proto3,oneof" json:"desired_worker_id,omitempty"`
	// (optional) override for the priority of the workflow tasks, will set all tasks to this priority
	Priority *int32 `protobuf:"varint,9,opt,name=priority,proto3,oneof" json:"priority,omitempty"`
	// (optional) the desired worker labels for the workflow run, which will be used to determine which workers can pick up the workflow's tasks. if not set, defaults to an empty set of labels, which means any worker can pick up the tasks.
	DesiredWorkerLabels map[string]*DesiredWorkerLabels `` /* 209-byte string literal not displayed */
	// contains filtered or unexported fields
}