features

type APIKeyAuth struct {
	HeaderName string
	APIKey     string
}

type BasicAuth struct {
	Username string
	Password string
}

type CELClient interface {
	Debug(ctx context.Context, expression string, input map[string]interface{}, additionalMetadata, filterPayload *map[string]interface{}) (*CELEvaluationResult, error)
}

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

type CreateCronTrigger struct {
	Name               string                 `json:"name"`
	Expression         string                 `json:"expression"`
	Input              map[string]interface{} `json:"input,omitempty"`
	AdditionalMetadata map[string]interface{} `json:"additionalMetadata,omitempty"`
	Priority           *int32                 `json:"priority,omitempty"`
}

type CreateRatelimitOpts struct {
	Key      string
	Limit    int
	Duration types.RateLimitDuration
}

type CreateScheduledRunTrigger struct {
	// TriggerAt specifies when the workflow should be triggered.
	TriggerAt time.Time `json:"triggerAt"`

	// Input is the optional input data for the workflow.
	Input map[string]interface{} `json:"input,omitempty"`

	// AdditionalMetadata is optional metadata to associate with the scheduled run.
	AdditionalMetadata map[string]interface{} `json:"additionalMetadata,omitempty"`

	Priority *int32 `json:"priority,omitempty"`
}

type CreateWebhookOpts struct {
	Name               string
	SourceName         rest.V1WebhookSourceName
	EventKeyExpression string
	Auth               WebhookAuth
}

type CronsClient interface {
	Create(ctx context.Context, workflowName string, cron CreateCronTrigger) (*rest.CronWorkflows, error)

	Delete(ctx context.Context, cronId string) error

	List(ctx context.Context, opts rest.CronWorkflowListParams) (*rest.CronWorkflowsList, error)

	Get(ctx context.Context, cronId string) (*rest.CronWorkflows, error)
}

type FiltersClient interface {
	List(ctx context.Context, opts *rest.V1FilterListParams) (*rest.V1FilterList, error)

	Get(ctx context.Context, filterID string) (*rest.V1Filter, error)

	Create(ctx context.Context, opts rest.V1CreateFilterRequest) (*rest.V1Filter, error)

	Delete(ctx context.Context, filterID string) (*rest.V1Filter, error)

	Update(ctx context.Context, filterID string, opts rest.V1FilterUpdateJSONRequestBody) (*rest.V1Filter, error)
}

type HMACAuth struct {
	SigningSecret       string
	SignatureHeaderName string
	Algorithm           rest.V1WebhookHMACAlgorithm
	Encoding            rest.V1WebhookHMACEncoding
}

type InvalidCronExpressionError struct {
	Expression string
}

type MetricsClient interface {
	GetWorkflowMetrics(ctx context.Context, workflowId string, opts *rest.WorkflowGetMetricsParams) (*rest.WorkflowMetrics, error)

	GetQueueMetrics(ctx context.Context, opts *rest.TenantGetQueueMetricsParams) (*rest.TenantGetQueueMetricsResponse, error)

	GetTaskQueueMetrics(ctx context.Context) (*rest.TenantGetStepRunQueueMetricsResponse, error)
}

type RateLimitsClient interface {
	Upsert(opts CreateRatelimitOpts) error

	List(ctx context.Context, opts *rest.RateLimitListParams) (*rest.RateLimitListResponse, error)
}

type RunsClient interface {
	// Get retrieves a workflow run by its ID.
	Get(ctx context.Context, runId string) (*rest.V1WorkflowRunGetResponse, error)

	// Get the status of a workflow run by its ID.
	GetStatus(ctx context.Context, runId string) (*rest.V1WorkflowRunGetStatusResponse, error)

	// GetDetails retrieves detailed information about a workflow run by its ID.
	//
	// Deprecated: Use Get instead.
	GetDetails(ctx context.Context, runId string) (*rest.V1WorkflowRunGetResponse, error)

	// GetV1Details retrieves detailed information about a workflow run via gRPC,
	// including task-level output, errors, and status.
	GetV1Details(ctx context.Context, runId uuid.UUID) (*client.RunDetails, error)

	// List retrieves a collection of workflow runs based on the provided parameters.
	List(ctx context.Context, opts rest.V1WorkflowRunListParams) (*rest.V1WorkflowRunListResponse, error)

	// Replay requests a task to be replayed within a workflow run.
	Replay(ctx context.Context, opts rest.V1ReplayTaskRequest) (*rest.V1TaskReplayResponse, error)

	// Cancel requests cancellation of a specific task within a workflow run.
	Cancel(ctx context.Context, opts rest.V1CancelTaskRequest) (*rest.V1TaskCancelResponse, error)

	// SubscribeToStream subscribes to streaming events for a specific workflow run.
	SubscribeToStream(ctx context.Context, workflowRunId string) (<-chan string, error)
}

type SchedulesClient interface {
	// Create creates a new scheduled workflow run.
	Create(ctx context.Context, workflowName string, trigger CreateScheduledRunTrigger) (*rest.ScheduledWorkflows, error)

	// Delete removes a scheduled workflow run.
	Delete(ctx context.Context, scheduledRunId string) error

	// List retrieves a collection of scheduled workflow runs based on the provided parameters.
	List(ctx context.Context, opts rest.WorkflowScheduledListParams) (*rest.ScheduledWorkflowsList, error)

	// Get retrieves a specific scheduled workflow run by its ID.
	Get(ctx context.Context, scheduledRunId string) (*rest.ScheduledWorkflows, error)
}

type TenantClient interface {
	// Get the details of the current tenant
	Get(ctx context.Context) (*rest.Tenant, error)
}

type UpdateWebhookOpts struct {
	EventKeyExpression *string
}

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

type WebhooksClient interface {
	// List retrieves a collection of webhooks based on the provided parameters.
	List(ctx context.Context, opts rest.V1WebhookListParams) (*rest.V1WebhookList, error)

	// Get retrieves a specific webhook by its name.
	Get(ctx context.Context, webhookName string) (*rest.V1Webhook, error)

	// Create creates a new webhook configuration.
	Create(ctx context.Context, opts CreateWebhookOpts) (*rest.V1Webhook, error)

	// Update updates an existing webhook configuration.
	Update(ctx context.Context, webhookName string, opts UpdateWebhookOpts) (*rest.V1Webhook, error)

	// Delete removes a webhook configuration.
	Delete(ctx context.Context, webhookName string) error
}

type WorkersClient interface {
	// Get retrieves a worker by its ID.
	Get(ctx context.Context, workerId string) (*rest.Worker, error)

	// List retrieves all workers for the tenant.
	List(ctx context.Context) (*rest.WorkerList, error)

	// IsPaused checks if a worker is paused.
	IsPaused(ctx context.Context, workerId string) (bool, error)

	// Pause pauses a worker.
	Pause(ctx context.Context, workerId string) (*rest.Worker, error)

	// Unpause unpauses a worker.
	Unpause(ctx context.Context, workerId string) (*rest.Worker, error)
}

type WorkflowsClient interface {
	// Get retrieves a workflow by its name.
	Get(ctx context.Context, workflowName string) (*rest.Workflow, error)

	// GetId retrieves a workflow by its name.
	GetId(ctx context.Context, workflowName string) (uuid.UUID, error)

	// List retrieves all workflows for the tenant with optional filtering parameters.
	List(ctx context.Context, opts *rest.WorkflowListParams) (*rest.WorkflowList, error)

	// Delete removes a workflow by its name.
	Delete(ctx context.Context, workflowName string) (*rest.WorkflowDeleteResponse, error)
}