transformers

func ToAPIToken(token *sqlcv1.APIToken) *gen.APIToken

func ToCronWorkflowsFromSQLC(cron *sqlcv1.ListCronWorkflowsRow, opts ...PayloadOption) *gen.CronWorkflows

func ToEvent(event *sqlcv1.Event) gen.Event

func ToEventFromSQLCV1(event *v1.EventWithPayload) (*gen.Event, error)

func ToEventList(events []*sqlcv1.Event) []gen.Event

func ToJob(job *sqlcv1.Job, steps []*sqlcv1.GetStepsForJobsRow) *gen.Job

func ToRateLimitFromSQLC(rl *sqlcv1.ListRateLimitsForTenantNoMutateRow) (*gen.RateLimit, error)

func ToSNSIntegration(sns *sqlcv1.SNSIntegration, serverUrl string) *gen.SNSIntegration

func ToScheduledWorkflowsFromSQLC(scheduled *sqlcv1.ListScheduledWorkflowsRow, opts ...PayloadOption) *gen.ScheduledWorkflows

func ToSlackWebhook(slack *sqlcv1.SlackAppWebhook) *gen.SlackWebhook

func ToStep(step *sqlcv1.Step, parents []uuid.UUID) *gen.Step

func ToTaskStats(stats map[string]v1.TaskStat, requiredNames []string) gen.TaskStats

func ToTenant(tenant *sqlcv1.Tenant, serverURL string) *gen.Tenant

func ToTenantAlertEmailGroup(group *sqlcv1.TenantAlertEmailGroup) *gen.TenantAlertEmailGroup

func ToTenantAlertingSettings(alerting *sqlcv1.TenantAlertingSettings) *gen.TenantAlertingSettings

func ToTenantInviteLink(invite *sqlcv1.TenantInviteLink) *gen.TenantInvite

func ToTenantMember(tenantMember *sqlcv1.PopulateTenantMembersRow) *gen.TenantMember

func ToTenantResourcePolicy(_limits []*sqlcv1.TenantResourceLimit) *gen.TenantResourcePolicy

func ToUser(user *sqlcv1.User, hasPassword bool, hashedEmail *string) *gen.User

func ToUserTenantInviteLink(invite *sqlcv1.ListTenantInvitesByEmailRow) *gen.TenantInvite

func ToV1Concurrency(workflowConcurrencies []*sqlcv1.ListWorkflowConcurrencyByVersionIdRow, taskConcurrencies []*sqlcv1.ListConcurrencyStrategiesByWorkflowVersionIdRow) *[]gen.ConcurrencySetting

func ToWebhookWorker(webhookWorker *sqlcv1.WebhookWorker) *gen.WebhookWorker

func ToWebhookWorkerCreated(webhookWorker *sqlcv1.WebhookWorker) *gen.WebhookWorkerCreated

func ToWebhookWorkerRequest(webhookWorker *sqlcv1.WebhookWorkerRequest) *gen.WebhookWorkerRequest

func ToWorkerLabels(labels []*sqlcv1.ListWorkerLabelsRow) *[]gen.WorkerLabel

func ToWorkerRuntimeInfo(worker *sqlcv1.Worker) *gen.WorkerRuntimeInfo

func ToWorkerSqlc(worker *sqlcv1.Worker, slotConfig map[string]gen.WorkerSlotConfig, actions []string) *gen.Worker

func ToWorkflow(
	workflow *sqlcv1.Workflow,
	version *sqlcv1.WorkflowVersion,
) *gen.Workflow

func ToWorkflowFromSQLC(row *sqlcv1.Workflow) *gen.Workflow

func ToWorkflowVersion(
	version *sqlcv1.WorkflowVersion,
	workflow *sqlcv1.Workflow,
	workflowConcurrency []*sqlcv1.ListWorkflowConcurrencyByVersionIdRow,
	crons []*sqlcv1.WorkflowTriggerCronRef,
	events []*sqlcv1.WorkflowTriggerEventRef,
	schedules []*sqlcv1.WorkflowTriggerScheduledRef,
	stepConcurrency []*sqlcv1.ListConcurrencyStrategiesByWorkflowVersionIdRow,
) *gen.WorkflowVersion

func ToWorkflowVersionFromSQLC(row *sqlcv1.WorkflowVersion, workflow *gen.Workflow) *gen.WorkflowVersion

func ToWorkflowVersionMeta(version *sqlcv1.WorkflowVersion, workflow *sqlcv1.Workflow) *gen.WorkflowVersionMeta