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)
}

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)
	// 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 CancelTasksRequest struct {
	ExternalIds []string     `protobuf:"bytes,1,rep,name=externalIds,proto3" json:"externalIds,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 step, default 0
	RateLimits   []*CreateTaskRateLimit          `protobuf:"bytes,7,rep,name=rate_limits,json=rateLimits,proto3" json:"rate_limits,omitempty"` // (optional) the rate limits for the step
	WorkerLabels map[string]*DesiredWorkerLabels ``                                                                                            // (optional) the desired worker affinity state for the step
	/* 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 step
	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 step
	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
	// 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 step 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 steps 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
	// 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=strValue,proto3,oneof" json:"strValue,omitempty"`
	IntValue *int32  `protobuf:"varint,2,opt,name=intValue,proto3,oneof" json:"intValue,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 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
	// 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=externalIds,proto3" json:"externalIds,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
	// 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 TriggerWorkflowRunRequest struct {
	WorkflowName       string `protobuf:"bytes,1,opt,name=workflow_name,json=workflowName,proto3" json:"workflow_name,omitempty"`
	Input              []byte `protobuf:"bytes,2,opt,name=input,proto3" json:"input,omitempty"`
	AdditionalMetadata []byte `protobuf:"bytes,3,opt,name=additional_metadata,json=additionalMetadata,proto3" json:"additional_metadata,omitempty"`
	Priority           *int32 `protobuf:"varint,4,opt,name=priority,proto3,oneof" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

type TriggerWorkflowRunResponse struct {
	ExternalId string `protobuf:"bytes,1,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedAdminServiceServer struct {
}

type UnimplementedV1DispatcherServer struct {
}

type UnsafeAdminServiceServer interface {
	// contains filtered or unexported methods
}

type UnsafeV1DispatcherServer interface {
	// contains filtered or unexported methods
}

type UserEventMatchCondition struct {
	Base         *BaseMatchCondition `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	UserEventKey string              `protobuf:"bytes,2,opt,name=user_event_key,json=userEventKey,proto3" json:"user_event_key,omitempty"`
	// contains filtered or unexported fields
}

type V1DispatcherClient interface {
	RegisterDurableEvent(ctx context.Context, in *RegisterDurableEventRequest, opts ...grpc.CallOption) (*RegisterDurableEventResponse, error)
	ListenForDurableEvent(ctx context.Context, opts ...grpc.CallOption) (V1Dispatcher_ListenForDurableEventClient, error)
}

type V1DispatcherServer interface {
	RegisterDurableEvent(context.Context, *RegisterDurableEventRequest) (*RegisterDurableEventResponse, error)
	ListenForDurableEvent(V1Dispatcher_ListenForDurableEventServer) error
	// contains filtered or unexported methods
}

type V1Dispatcher_ListenForDurableEventClient interface {
	Send(*ListenForDurableEventRequest) error
	Recv() (*DurableEvent, error)
	grpc.ClientStream
}

type V1Dispatcher_ListenForDurableEventServer interface {
	Send(*DurableEvent) error
	Recv() (*ListenForDurableEventRequest, error)
	grpc.ServerStream
}

type WorkerLabelComparator int32