Documentation
¶
Index ¶
- func ToAPIToken(token *sqlcv1.APIToken) *gen.APIToken
- func ToCronWorkflowsFromSQLC(cron *sqlcv1.ListCronWorkflowsRow) *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 ToLogFromSQLC(log *sqlcv1.LogLine) *gen.LogLine
- func ToRateLimitFromSQLC(rl *sqlcv1.ListRateLimitsForTenantNoMutateRow) (*gen.RateLimit, error)
- func ToSNSIntegration(sns *sqlcv1.SNSIntegration, serverUrl string) *gen.SNSIntegration
- func ToScheduledWorkflowsFromSQLC(scheduled *sqlcv1.ListScheduledWorkflowsRow) *gen.ScheduledWorkflows
- func ToSlackWebhook(slack *sqlcv1.SlackAppWebhook) *gen.SlackWebhook
- func ToStep(step *sqlcv1.Step, parents []pgtype.UUID) *gen.Step
- func ToTaskStats(stats map[string]v1.TaskStat) gen.TaskStats
- func ToTenant(tenant *sqlcv1.Tenant) *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 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, remainingSlots *int, webhookUrl *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, ...) *gen.WorkflowVersion
- func ToWorkflowVersionConcurrency(concurrency *WorkflowConcurrency) *gen.WorkflowConcurrency
- func ToWorkflowVersionFromSQLC(row *sqlcv1.WorkflowVersion, workflow *gen.Workflow) *gen.WorkflowVersion
- func ToWorkflowVersionMeta(version *sqlcv1.WorkflowVersion, workflow *sqlcv1.Workflow) *gen.WorkflowVersionMeta
- type WorkflowConcurrency
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ToCronWorkflowsFromSQLC ¶
func ToCronWorkflowsFromSQLC(cron *sqlcv1.ListCronWorkflowsRow) *gen.CronWorkflows
func ToEventFromSQLCV1 ¶ added in v0.73.6
func ToEventFromSQLCV1(event *v1.EventWithPayload) (*gen.Event, error)
func ToRateLimitFromSQLC ¶
func ToRateLimitFromSQLC(rl *sqlcv1.ListRateLimitsForTenantNoMutateRow) (*gen.RateLimit, error)
func ToSNSIntegration ¶
func ToSNSIntegration(sns *sqlcv1.SNSIntegration, serverUrl string) *gen.SNSIntegration
func ToScheduledWorkflowsFromSQLC ¶
func ToScheduledWorkflowsFromSQLC(scheduled *sqlcv1.ListScheduledWorkflowsRow) *gen.ScheduledWorkflows
func ToSlackWebhook ¶
func ToSlackWebhook(slack *sqlcv1.SlackAppWebhook) *gen.SlackWebhook
func ToTenantAlertEmailGroup ¶
func ToTenantAlertEmailGroup(group *sqlcv1.TenantAlertEmailGroup) *gen.TenantAlertEmailGroup
func ToTenantAlertingSettings ¶
func ToTenantAlertingSettings(alerting *sqlcv1.TenantAlertingSettings) *gen.TenantAlertingSettings
func ToTenantInviteLink ¶
func ToTenantInviteLink(invite *sqlcv1.TenantInviteLink) *gen.TenantInvite
func ToTenantMember ¶
func ToTenantMember(tenantMember *sqlcv1.PopulateTenantMembersRow) *gen.TenantMember
func ToTenantResourcePolicy ¶
func ToTenantResourcePolicy(_limits []*sqlcv1.TenantResourceLimit) *gen.TenantResourcePolicy
func ToUserTenantInviteLink ¶
func ToUserTenantInviteLink(invite *sqlcv1.ListTenantInvitesByEmailRow) *gen.TenantInvite
func ToWebhookWorker ¶
func ToWebhookWorker(webhookWorker *sqlcv1.WebhookWorker) *gen.WebhookWorker
func ToWebhookWorkerCreated ¶
func ToWebhookWorkerCreated(webhookWorker *sqlcv1.WebhookWorker) *gen.WebhookWorkerCreated
func ToWebhookWorkerRequest ¶
func ToWebhookWorkerRequest(webhookWorker *sqlcv1.WebhookWorkerRequest) *gen.WebhookWorkerRequest
func ToWorkerLabels ¶
func ToWorkerLabels(labels []*sqlcv1.ListWorkerLabelsRow) *[]gen.WorkerLabel
func ToWorkerRuntimeInfo ¶
func ToWorkerRuntimeInfo(worker *sqlcv1.Worker) *gen.WorkerRuntimeInfo
func ToWorkerSqlc ¶
func ToWorkflow ¶
func ToWorkflowVersion ¶
func ToWorkflowVersion( version *sqlcv1.WorkflowVersion, workflow *sqlcv1.Workflow, concurrency *WorkflowConcurrency, crons []*sqlcv1.WorkflowTriggerCronRef, events []*sqlcv1.WorkflowTriggerEventRef, schedules []*sqlcv1.WorkflowTriggerScheduledRef, ) *gen.WorkflowVersion
func ToWorkflowVersionConcurrency ¶
func ToWorkflowVersionConcurrency(concurrency *WorkflowConcurrency) *gen.WorkflowConcurrency
func ToWorkflowVersionFromSQLC ¶
func ToWorkflowVersionFromSQLC(row *sqlcv1.WorkflowVersion, workflow *gen.Workflow) *gen.WorkflowVersion
func ToWorkflowVersionMeta ¶
func ToWorkflowVersionMeta(version *sqlcv1.WorkflowVersion, workflow *sqlcv1.Workflow) *gen.WorkflowVersionMeta
Types ¶
type WorkflowConcurrency ¶
Source Files
¶
Click to show internal directories.
Click to hide internal directories.