Documentation ¶
Index ¶
- func ToAPIToken(token *db.APITokenModel) *gen.APIToken
- func ToEvent(event *db.EventModel) *gen.Event
- func ToEventFromSQLC(eventRow *dbsqlc.ListEventsRow) (*gen.Event, error)
- func ToEventList(events []*dbsqlc.Event) []gen.Event
- func ToJob(job *dbsqlc.Job, steps []*dbsqlc.GetStepsForJobsRow) *gen.Job
- func ToJobRun(jobRun *dbsqlc.ListJobRunsForWorkflowRunFullRow, ...) *gen.JobRun
- func ToLogFromSQLC(log *dbsqlc.LogLine) *gen.LogLine
- func ToRateLimitFromSQLC(rl *dbsqlc.ListRateLimitsForTenantNoMutateRow) (*gen.RateLimit, error)
- func ToRecentStepRun(stepRun *dbsqlc.GetStepRunForEngineRow) (*gen.RecentStepRuns, error)
- func ToSNSIntegration(sns *db.SNSIntegrationModel, serverUrl string) *gen.SNSIntegration
- func ToSlackWebhook(slack *db.SlackAppWebhookModel) *gen.SlackWebhook
- func ToSlotState(slots []*dbsqlc.ListSemaphoreSlotsWithStateForWorkerRow, remainingSlots int) *[]gen.SemaphoreSlots
- func ToStep(step *dbsqlc.Step, parents []pgtype.UUID) *gen.Step
- func ToStepRun(stepRun *repository.StepRunForJobRun) *gen.StepRun
- func ToStepRunArchive(stepRunArchive *dbsqlc.StepRunResultArchive) *gen.StepRunArchive
- func ToStepRunEvent(stepRunEvent *dbsqlc.StepRunEvent) *gen.StepRunEvent
- func ToStepRunFull(stepRun *repository.GetStepRunFull) *gen.StepRun
- func ToTenant(tenant *db.TenantModel) *gen.Tenant
- func ToTenantAlertEmailGroup(group *db.TenantAlertEmailGroupModel) *gen.TenantAlertEmailGroup
- func ToTenantAlertingSettings(alerting *db.TenantAlertingSettingsModel) *gen.TenantAlertingSettings
- func ToTenantInviteLink(invite *db.TenantInviteLinkModel) *gen.TenantInvite
- func ToTenantMember(tenantMember *db.TenantMemberModel) *gen.TenantMember
- func ToTenantResourcePolicy(_limits []*dbsqlc.TenantResourceLimit) *gen.TenantResourcePolicy
- func ToTenantSqlc(tenant *dbsqlc.Tenant) *gen.Tenant
- func ToUser(user *db.UserModel, hasPassword bool, hashedEmail *string) *gen.User
- func ToUserTenantPublic(user *db.UserModel) *gen.UserTenantPublic
- func ToWebhookWorker(webhookWorker *dbsqlc.WebhookWorker) *gen.WebhookWorker
- func ToWebhookWorkerCreated(webhookWorker *dbsqlc.WebhookWorker) *gen.WebhookWorkerCreated
- func ToWebhookWorkerRequest(webhookWorker *dbsqlc.WebhookWorkerRequest) *gen.WebhookWorkerRequest
- func ToWorkerLabels(labels []*dbsqlc.ListWorkerLabelsRow) *[]gen.WorkerLabel
- func ToWorkerRuntimeInfo(worker *dbsqlc.Worker) *gen.WorkerRuntimeInfo
- func ToWorkerSqlc(worker *dbsqlc.Worker, remainingSlots *int, webhookUrl *string, ...) *gen.Worker
- func ToWorkflow(workflow *dbsqlc.Workflow, version *dbsqlc.WorkflowVersion) *gen.Workflow
- func ToWorkflowFromSQLC(row *dbsqlc.Workflow) *gen.Workflow
- func ToWorkflowRun(run *dbsqlc.GetWorkflowRunByIdRow, ...) (*gen.WorkflowRun, error)
- func ToWorkflowRunFromSQLC(row *dbsqlc.ListWorkflowRunsRow) *gen.WorkflowRun
- func ToWorkflowRunShape(run *dbsqlc.GetWorkflowRunByIdRow, version *dbsqlc.GetWorkflowVersionByIdRow, ...) *gen.WorkflowRunShape
- func ToWorkflowRunTriggeredBy(parentWorkflowRunId pgtype.UUID, triggeredBy *dbsqlc.WorkflowRunTriggeredBy) *gen.WorkflowRunTriggeredBy
- func ToWorkflowVersion(version *dbsqlc.WorkflowVersion, workflow *dbsqlc.Workflow, ...) *gen.WorkflowVersion
- func ToWorkflowVersionConcurrency(concurrency *WorkflowConcurrency) *gen.WorkflowConcurrency
- func ToWorkflowVersionFromSQLC(row *dbsqlc.WorkflowVersion, workflow *gen.Workflow) *gen.WorkflowVersion
- func ToWorkflowVersionMeta(version *dbsqlc.WorkflowVersion, workflow *dbsqlc.Workflow) *gen.WorkflowVersionMeta
- func ToWorkflowYAMLBytes(workflow *db.WorkflowModel, version *db.WorkflowVersionModel) ([]byte, error)
- type WorkflowConcurrency
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ToAPIToken ¶ added in v0.7.0
func ToAPIToken(token *db.APITokenModel) *gen.APIToken
func ToEventFromSQLC ¶
func ToEventFromSQLC(eventRow *dbsqlc.ListEventsRow) (*gen.Event, error)
func ToJobRun ¶
func ToJobRun( jobRun *dbsqlc.ListJobRunsForWorkflowRunFullRow, steps []*dbsqlc.GetStepsForJobsRow, stepRuns []*repository.StepRunForJobRun, ) *gen.JobRun
func ToRateLimitFromSQLC ¶ added in v0.47.0
func ToRateLimitFromSQLC(rl *dbsqlc.ListRateLimitsForTenantNoMutateRow) (*gen.RateLimit, error)
func ToRecentStepRun ¶ added in v0.42.0
func ToRecentStepRun(stepRun *dbsqlc.GetStepRunForEngineRow) (*gen.RecentStepRuns, error)
func ToSNSIntegration ¶ added in v0.15.2
func ToSNSIntegration(sns *db.SNSIntegrationModel, serverUrl string) *gen.SNSIntegration
func ToSlackWebhook ¶ added in v0.25.0
func ToSlackWebhook(slack *db.SlackAppWebhookModel) *gen.SlackWebhook
func ToSlotState ¶ added in v0.42.0
func ToSlotState(slots []*dbsqlc.ListSemaphoreSlotsWithStateForWorkerRow, remainingSlots int) *[]gen.SemaphoreSlots
func ToStepRun ¶
func ToStepRun(stepRun *repository.StepRunForJobRun) *gen.StepRun
func ToStepRunArchive ¶ added in v0.34.2
func ToStepRunArchive(stepRunArchive *dbsqlc.StepRunResultArchive) *gen.StepRunArchive
func ToStepRunEvent ¶ added in v0.26.0
func ToStepRunEvent(stepRunEvent *dbsqlc.StepRunEvent) *gen.StepRunEvent
func ToStepRunFull ¶ added in v0.44.8
func ToStepRunFull(stepRun *repository.GetStepRunFull) *gen.StepRun
func ToTenantAlertEmailGroup ¶ added in v0.25.0
func ToTenantAlertEmailGroup(group *db.TenantAlertEmailGroupModel) *gen.TenantAlertEmailGroup
func ToTenantAlertingSettings ¶ added in v0.25.0
func ToTenantAlertingSettings(alerting *db.TenantAlertingSettingsModel) *gen.TenantAlertingSettings
func ToTenantInviteLink ¶
func ToTenantInviteLink(invite *db.TenantInviteLinkModel) *gen.TenantInvite
func ToTenantMember ¶
func ToTenantMember(tenantMember *db.TenantMemberModel) *gen.TenantMember
func ToTenantResourcePolicy ¶ added in v0.31.0
func ToTenantResourcePolicy(_limits []*dbsqlc.TenantResourceLimit) *gen.TenantResourcePolicy
func ToUserTenantPublic ¶
func ToUserTenantPublic(user *db.UserModel) *gen.UserTenantPublic
func ToWebhookWorker ¶ added in v0.34.0
func ToWebhookWorker(webhookWorker *dbsqlc.WebhookWorker) *gen.WebhookWorker
func ToWebhookWorkerCreated ¶ added in v0.34.0
func ToWebhookWorkerCreated(webhookWorker *dbsqlc.WebhookWorker) *gen.WebhookWorkerCreated
func ToWebhookWorkerRequest ¶ added in v0.42.13
func ToWebhookWorkerRequest(webhookWorker *dbsqlc.WebhookWorkerRequest) *gen.WebhookWorkerRequest
func ToWorkerLabels ¶ added in v0.40.0
func ToWorkerLabels(labels []*dbsqlc.ListWorkerLabelsRow) *[]gen.WorkerLabel
func ToWorkerRuntimeInfo ¶ added in v0.50.4
func ToWorkerRuntimeInfo(worker *dbsqlc.Worker) *gen.WorkerRuntimeInfo
func ToWorkerSqlc ¶ added in v0.12.0
func ToWorkflow ¶
func ToWorkflowRun ¶
func ToWorkflowRun( run *dbsqlc.GetWorkflowRunByIdRow, jobs []*dbsqlc.ListJobRunsForWorkflowRunFullRow, steps []*dbsqlc.GetStepsForJobsRow, stepRuns []*repository.StepRunForJobRun, ) (*gen.WorkflowRun, error)
func ToWorkflowRunFromSQLC ¶
func ToWorkflowRunFromSQLC(row *dbsqlc.ListWorkflowRunsRow) *gen.WorkflowRun
func ToWorkflowRunShape ¶ added in v0.44.8
func ToWorkflowRunShape( run *dbsqlc.GetWorkflowRunByIdRow, version *dbsqlc.GetWorkflowVersionByIdRow, jobs []*dbsqlc.ListJobRunsForWorkflowRunFullRow, steps []*dbsqlc.GetStepsForJobsRow, stepRuns []*repository.StepRunForJobRun, ) *gen.WorkflowRunShape
func ToWorkflowRunTriggeredBy ¶
func ToWorkflowRunTriggeredBy(parentWorkflowRunId pgtype.UUID, triggeredBy *dbsqlc.WorkflowRunTriggeredBy) *gen.WorkflowRunTriggeredBy
func ToWorkflowVersion ¶
func ToWorkflowVersion( version *dbsqlc.WorkflowVersion, workflow *dbsqlc.Workflow, concurrency *WorkflowConcurrency, crons []*dbsqlc.WorkflowTriggerCronRef, events []*dbsqlc.WorkflowTriggerEventRef, schedules []*dbsqlc.WorkflowTriggerScheduledRef, ) *gen.WorkflowVersion
func ToWorkflowVersionConcurrency ¶ added in v0.15.1
func ToWorkflowVersionConcurrency(concurrency *WorkflowConcurrency) *gen.WorkflowConcurrency
func ToWorkflowVersionFromSQLC ¶
func ToWorkflowVersionFromSQLC(row *dbsqlc.WorkflowVersion, workflow *gen.Workflow) *gen.WorkflowVersion
func ToWorkflowVersionMeta ¶
func ToWorkflowVersionMeta(version *dbsqlc.WorkflowVersion, workflow *dbsqlc.Workflow) *gen.WorkflowVersionMeta
func ToWorkflowYAMLBytes ¶
func ToWorkflowYAMLBytes(workflow *db.WorkflowModel, version *db.WorkflowVersionModel) ([]byte, error)
Types ¶
type WorkflowConcurrency ¶ added in v0.44.8
Click to show internal directories.
Click to hide internal directories.