transformers

package
v0.1.0-debug.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 22, 2025 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ToAPIToken 

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

func ToCronWorkflowsFromSQLC 

func ToCronWorkflowsFromSQLC(cron *dbsqlc.ListCronWorkflowsRow) *gen.CronWorkflows

func ToEvent 

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

func ToEventFromSQLC 

func ToEventFromSQLC(eventRow *dbsqlc.ListEventsRow) (*gen.Event, error)

func ToEventList 

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

func ToJob 

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

func ToJobRun 

func ToJobRun(
	jobRun *dbsqlc.ListJobRunsForWorkflowRunFullRow,
	steps []*dbsqlc.GetStepsForJobsRow,
	stepRuns []*repository.StepRunForJobRun,
) *gen.JobRun

func ToLogFromSQLC 

func ToLogFromSQLC(log *dbsqlc.LogLine) *gen.LogLine

func ToRateLimitFromSQLC 

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

func ToRecentStepRun 

func ToRecentStepRun(stepRun *dbsqlc.GetStepRunForEngineRow) (*gen.RecentStepRuns, error)

func ToSNSIntegration 

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

func ToScheduledWorkflowsFromSQLC 

func ToScheduledWorkflowsFromSQLC(scheduled *dbsqlc.ListScheduledWorkflowsRow) *gen.ScheduledWorkflows

func ToSlackWebhook 

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

func ToSlotState 

func ToSlotState(slots []*dbsqlc.ListSemaphoreSlotsWithStateForWorkerRow, remainingSlots int) *[]gen.SemaphoreSlots

func ToStep 

func ToStep(step *dbsqlc.Step, parents []pgtype.UUID) *gen.Step

func ToStepRun 

func ToStepRun(stepRun *repository.StepRunForJobRun) *gen.StepRun

func ToStepRunArchive 

func ToStepRunArchive(stepRunArchive *dbsqlc.StepRunResultArchive) *gen.StepRunArchive

func ToStepRunEvent 

func ToStepRunEvent(stepRunEvent *dbsqlc.StepRunEvent) *gen.StepRunEvent

func ToStepRunFull 

func ToStepRunFull(stepRun *repository.GetStepRunFull) *gen.StepRun

func ToTenant 

func ToTenant(tenant *dbsqlc.Tenant) *gen.Tenant

func ToTenantAlertEmailGroup 

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

func ToTenantAlertingSettings 

func ToTenantAlertingSettings(alerting *dbsqlc.TenantAlertingSettings) *gen.TenantAlertingSettings
func ToTenantInviteLink(invite *dbsqlc.TenantInviteLink) *gen.TenantInvite

func ToTenantMember 

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

func ToTenantResourcePolicy 

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

func ToUser 

func ToUser(user *dbsqlc.User, hasPassword bool, hashedEmail *string) *gen.User
func ToUserTenantInviteLink(invite *dbsqlc.ListTenantInvitesByEmailRow) *gen.TenantInvite

func ToWebhookWorker 

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

func ToWebhookWorkerCreated 

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

func ToWebhookWorkerRequest 

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

func ToWorkerLabels 

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

func ToWorkerRuntimeInfo 

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

func ToWorkerSqlc 

func ToWorkerSqlc(worker *dbsqlc.Worker, remainingSlots *int, webhookUrl *string, actions []pgtype.Text) *gen.Worker

func ToWorkflow 

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

func ToWorkflowFromSQLC 

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

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 

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 

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

Types

type WorkflowConcurrency 

type WorkflowConcurrency struct {
	ID                    pgtype.UUID
	GetConcurrencyGroupId pgtype.UUID
	MaxRuns               pgtype.Int4
	LimitStrategy         dbsqlc.NullConcurrencyLimitStrategy
}

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.