sql

May 20, 2024

Changes in this version

+ type ConnI interface

+ Begin func(ctx context.Context) (pgx.Tx, error)

type DBI

+ Conn func() ConnI

type Tx

+ func (t *Tx) Begin(ctx context.Context) (*Tx, error)

+ func (t *Tx) Conn() ConnI

May 2, 2024

Changes in this version

type AcquireAsyncCallRow

+ Origin AsyncCallOrigin

+ OriginKey string

+ Request []byte

+ Verb schema.Ref

+ type NullRef = optional.Option[schema.Ref]

type Querier

+ CompleteAsyncCall func(ctx context.Context, response []byte, error optional.Option[string], iD int64) (bool, error)

+ LoadAsyncCall func(ctx context.Context, id int64) (AsyncCall, error)

type Queries

+ func (q *Queries) CompleteAsyncCall(ctx context.Context, response []byte, error optional.Option[string], iD int64) (bool, error)

+ func (q *Queries) LoadAsyncCall(ctx context.Context, id int64) (AsyncCall, error)

May 1, 2024

Changes in this version

+ type AcquireAsyncCallRow struct

+ AsyncCallID int64

+ LeaseIdempotencyKey uuid.UUID

+ LeaseKey leases.Key

+ type AddAsyncCallParams struct

+ Origin AsyncCallOrigin

+ OriginKey string

+ Request []byte

+ Verb string

+ type AsyncCall struct

+ CreatedAt time.Time

+ Error optional.Option[string]

+ ID int64

+ LeaseID optional.Option[int64]

+ Origin AsyncCallOrigin

+ OriginKey string

+ Request []byte

+ Response []byte

+ State AsyncCallState

+ Verb string

+ type AsyncCallOrigin string

+ const AsyncCallOriginCron

+ const AsyncCallOriginFsm

+ const AsyncCallOriginPubsub

+ func (e *AsyncCallOrigin) Scan(src interface{}) error

+ type AsyncCallState string

+ const AsyncCallStateError

+ const AsyncCallStateExecuting

+ const AsyncCallStatePending

+ const AsyncCallStateSuccess

+ func (e *AsyncCallState) Scan(src interface{}) error

+ type FsmExecution struct

+ CreatedAt time.Time

+ ID int64

+ Key string

+ Name string

+ State string

+ Status FsmStatus

+ type FsmStatus string

+ const FsmStatusCompleted

+ const FsmStatusFailed

+ const FsmStatusRunning

+ func (e *FsmStatus) Scan(src interface{}) error

+ type FsmTransition struct

+ AsyncCallsID int64

+ FsmExecutionsID int64

+ ID int64

+ type NullAsyncCallOrigin struct

+ AsyncCallOrigin AsyncCallOrigin

+ Valid bool

+ func (ns *NullAsyncCallOrigin) Scan(value interface{}) error

+ func (ns NullAsyncCallOrigin) Value() (driver.Value, error)

+ type NullAsyncCallState struct

+ AsyncCallState AsyncCallState

+ Valid bool

+ func (ns *NullAsyncCallState) Scan(value interface{}) error

+ func (ns NullAsyncCallState) Value() (driver.Value, error)

+ type NullFsmStatus struct

+ FsmStatus FsmStatus

+ Valid bool

+ func (ns *NullFsmStatus) Scan(value interface{}) error

+ func (ns NullFsmStatus) Value() (driver.Value, error)

type Querier

+ AcquireAsyncCall func(ctx context.Context, ttl time.Duration) (AcquireAsyncCallRow, error)

+ AddAsyncCall func(ctx context.Context, arg AddAsyncCallParams) (bool, error)

+ SendFSMEvent func(ctx context.Context, arg SendFSMEventParams) (int64, error)

type Queries

+ func (q *Queries) AcquireAsyncCall(ctx context.Context, ttl time.Duration) (AcquireAsyncCallRow, error)

+ func (q *Queries) AddAsyncCall(ctx context.Context, arg AddAsyncCallParams) (bool, error)

+ func (q *Queries) SendFSMEvent(ctx context.Context, arg SendFSMEventParams) (int64, error)

+ type SendFSMEventParams struct

+ Key string

+ Name string

+ Request []byte

+ State string

+ Verb string

Apr 29, 2024

Changes in this version

+ type Lease struct

+ CreatedAt time.Time

+ ExpiresAt time.Time

+ ID int64

+ IdempotencyKey uuid.UUID

+ Key leases.Key

+ type NullLeaseKey = optional.Option[leases.Key]

+ type NullUUID = optional.Option[uuid.UUID]

type Querier

+ ExpireLeases func(ctx context.Context) (int64, error)

+ NewLease func(ctx context.Context, key leases.Key, expiresAt time.Time) (uuid.UUID, error)

+ ReleaseLease func(ctx context.Context, idempotencyKey uuid.UUID, key leases.Key) (bool, error)

+ RenewLease func(ctx context.Context, expiresIn time.Duration, idempotencyKey uuid.UUID, ...) (bool, error)

type Queries

+ func (q *Queries) ExpireLeases(ctx context.Context) (int64, error)

+ func (q *Queries) NewLease(ctx context.Context, key leases.Key, expiresAt time.Time) (uuid.UUID, error)

+ func (q *Queries) ReleaseLease(ctx context.Context, idempotencyKey uuid.UUID, key leases.Key) (bool, error)

+ func (q *Queries) RenewLease(ctx context.Context, expiresIn time.Duration, idempotencyKey uuid.UUID, ...) (bool, error)

Apr 17, 2024

Changes in this version

+ type GetActiveIngressRoutesRow struct

+ DeploymentKey model.DeploymentKey

+ Method string

+ Module string

+ Path string

+ Verb string

type Querier

+ GetActiveControllers func(ctx context.Context) ([]Controller, error)

+ GetActiveIngressRoutes func(ctx context.Context) ([]GetActiveIngressRoutesRow, error)

type Queries

+ func (q *Queries) GetActiveControllers(ctx context.Context) ([]Controller, error)

+ func (q *Queries) GetActiveIngressRoutes(ctx context.Context) ([]GetActiveIngressRoutesRow, error)

Apr 12, 2024

Changes in this version

+ type CreateCronJobParams struct

+ DeploymentKey model.DeploymentKey

+ Key model.CronJobKey

+ ModuleName string

+ NextExecution time.Time

+ Schedule string

+ StartTime time.Time

+ Verb string

+ type CronJob struct

+ DeploymentID int64

+ ID int64

+ Key model.CronJobKey

+ ModuleName string

+ NextExecution time.Time

+ Schedule string

+ StartTime time.Time

+ State CronJobState

+ Verb string

+ type CronJobState string

+ const CronJobStateExecuting

+ const CronJobStateIdle

+ func (e *CronJobState) Scan(src interface{}) error

+ type EndCronJobRow struct

+ DeploymentKey model.DeploymentKey

+ Key model.CronJobKey

+ Module string

+ NextExecution time.Time

+ Schedule string

+ StartTime time.Time

+ State CronJobState

+ Verb string

+ type GetCronJobsRow struct

+ DeploymentKey model.DeploymentKey

+ Key model.CronJobKey

+ Module string

+ NextExecution time.Time

+ Schedule string

+ StartTime time.Time

+ State CronJobState

+ Verb string

+ type GetStaleCronJobsRow struct

+ DeploymentKey model.DeploymentKey

+ Key model.CronJobKey

+ Module string

+ NextExecution time.Time

+ Schedule string

+ StartTime time.Time

+ State CronJobState

+ Verb string

+ type NullCronJobKey = optional.Option[model.CronJobKey]

+ type NullCronJobState struct

+ CronJobState CronJobState

+ Valid bool

+ func (ns *NullCronJobState) Scan(value interface{}) error

+ func (ns NullCronJobState) Value() (driver.Value, error)

type Querier

+ CreateCronJob func(ctx context.Context, arg CreateCronJobParams) error

+ CreateCronRequest func(ctx context.Context, origin Origin, key model.RequestKey, sourceAddr string) error

+ CreateRequest func(ctx context.Context, origin Origin, key model.RequestKey, sourceAddr string) error

+ EndCronJob func(ctx context.Context, nextExecution time.Time, key model.CronJobKey, ...) (EndCronJobRow, error)

+ GetCronJobs func(ctx context.Context) ([]GetCronJobsRow, error)

+ GetStaleCronJobs func(ctx context.Context, dollar_1 time.Duration) ([]GetStaleCronJobsRow, error)

+ StartCronJobs func(ctx context.Context, keys []string) ([]StartCronJobsRow, error)

type Queries

+ func (q *Queries) CreateCronJob(ctx context.Context, arg CreateCronJobParams) error

+ func (q *Queries) CreateCronRequest(ctx context.Context, origin Origin, key model.RequestKey, sourceAddr string) error

+ func (q *Queries) CreateRequest(ctx context.Context, origin Origin, key model.RequestKey, sourceAddr string) error

+ func (q *Queries) EndCronJob(ctx context.Context, nextExecution time.Time, key model.CronJobKey, ...) (EndCronJobRow, error)

+ func (q *Queries) GetCronJobs(ctx context.Context) ([]GetCronJobsRow, error)

+ func (q *Queries) GetStaleCronJobs(ctx context.Context, dollar_1 time.Duration) ([]GetStaleCronJobsRow, error)

+ func (q *Queries) StartCronJobs(ctx context.Context, keys []string) ([]StartCronJobsRow, error)

+ type StartCronJobsRow struct

+ DeploymentKey model.DeploymentKey

+ HasMinReplicas bool

+ Key model.CronJobKey

+ Module string

+ NextExecution time.Time

+ Schedule string

+ StartTime time.Time

+ State CronJobState

+ Updated bool

+ Verb string

Apr 10, 2024

Changes in this version

type InsertCallEventParams

+ RequestKey optional.Option[string]

type InsertLogEventParams

+ RequestKey optional.Option[string]

+ type NullRequestKey = optional.Option[model.RequestKey]

type Request

+ Key model.RequestKey

Apr 9, 2024

Changes in this version

+ type GetDeploymentsWithMinReplicasRow struct

+ Deployment Deployment

+ Language string

+ ModuleName string

type Querier

+ GetDeploymentsWithMinReplicas func(ctx context.Context) ([]GetDeploymentsWithMinReplicasRow, error)

type Queries

+ func (q *Queries) GetDeploymentsWithMinReplicas(ctx context.Context) ([]GetDeploymentsWithMinReplicasRow, error)

type Topic

+ Key interface{}

type TopicSubscriber

+ Key interface{}

type TopicSubscription

+ Key interface{}

Apr 4, 2024

Changes in this version

type GetActiveDeploymentsRow

+ Replicas int64

Apr 2, 2024

Changes in this version

+ type Topic struct

+ CreatedAt time.Time

+ ID int64

+ ModuleID int64

+ Name string

+ Type string

+ type TopicEvent struct

+ CreatedAt time.Time

+ ID int64

+ Payload []byte

+ TopicID int64

+ type TopicSubscriber struct

+ CreatedAt time.Time

+ DeploymentID int64

+ ID int64

+ TopicSubscriptionsID int64

+ Verb string

+ type TopicSubscription struct

+ CreatedAt time.Time

+ Cursor int64

+ ID int64

+ Name string

+ TopicID int64

Mar 15, 2024

Changes in this version

type AssociateArtefactWithDeploymentParams

+ Key model.DeploymentKey

type CreateIngressRouteParams

+ Key model.DeploymentKey

type Deployment

+ Key model.DeploymentKey

type GetActiveDeploymentSchemasRow

+ Key model.DeploymentKey

type GetActiveRunnersRow

+ DeploymentKey optional.Option[string]

type GetAllIngressRoutesRow

+ DeploymentKey model.DeploymentKey

type GetDeploymentsNeedingReconciliationRow

+ DeploymentKey model.DeploymentKey

type GetDeploymentsWithArtefactsRow

+ DeploymentKey model.DeploymentKey

type GetExistingDeploymentForModuleRow

+ Key model.DeploymentKey

type GetIngressRoutesRow

+ DeploymentKey model.DeploymentKey

type GetProcessListRow

+ DeploymentKey model.DeploymentKey

type GetRouteForRunnerRow

+ DeploymentKey NullDeploymentKey

type GetRoutingTableRow

+ DeploymentKey NullDeploymentKey

type GetRunnerRow

+ DeploymentKey optional.Option[string]

type GetRunnersForDeploymentRow

+ Key_2 model.DeploymentKey

type InsertCallEventParams

+ DeploymentKey model.DeploymentKey

type InsertDeploymentCreatedEventParams

+ DeploymentKey model.DeploymentKey

type InsertDeploymentUpdatedEventParams

+ DeploymentKey model.DeploymentKey

type InsertLogEventParams

+ DeploymentKey model.DeploymentKey

+ type NullDeploymentKey = optional.Option[model.DeploymentKey]

type UpsertRunnerParams

+ DeploymentKey NullDeploymentKey

Mar 13, 2024

Changes in this version

+ type NullRunnerKey = optional.Option[model.RunnerKey]

Jan 31, 2024

Changes in this version

type GetDeploymentsWithArtefactsRow

+ Schema []byte

Dec 5, 2023

Changes in this version

type GetIngressRoutesRow

+ DeploymentName model.DeploymentName

+ Path string

Dec 4, 2023

Changes in this version

+ type GetActiveDeploymentSchemasRow struct

+ Name model.DeploymentName

+ Schema []byte

+ type GetActiveDeploymentsRow struct

+ Deployment Deployment

+ Language string

+ ModuleName string

type Querier

+ GetActiveDeploymentSchemas func(ctx context.Context) ([]GetActiveDeploymentSchemasRow, error)

+ GetActiveDeployments func(ctx context.Context, all bool) ([]GetActiveDeploymentsRow, error)

type Queries

+ func (q *Queries) GetActiveDeploymentSchemas(ctx context.Context) ([]GetActiveDeploymentSchemasRow, error)

+ func (q *Queries) GetActiveDeployments(ctx context.Context, all bool) ([]GetActiveDeploymentsRow, error)

Nov 28, 2023

Changes in this version

type InsertCallEventParams

+ Stack types.Option[string]

type InsertLogEventParams

+ Stack types.Option[string]

Nov 24, 2023

Changes in this version

type InsertEventParams

+ CustomKey2 types.Option[string]

Nov 3, 2023

Changes in this version

+ func Migrate(ctx context.Context, dsn string) error

+ type Artefact struct

+ Content []byte

+ CreatedAt time.Time

+ Digest []byte

+ ID int64

+ type AssociateArtefactWithDeploymentParams struct

+ ArtefactID int64

+ Executable bool

+ Name model.DeploymentName

+ Path string

+ type Controller struct

+ Created time.Time

+ Endpoint string

+ ID int64

+ Key model.ControllerKey

+ LastSeen time.Time

+ State ControllerState

+ type ControllerState string

+ const ControllerStateDead

+ const ControllerStateLive

+ func (e *ControllerState) Scan(src interface{}) error

+ type CreateIngressRouteParams struct

+ Method string

+ Module string

+ Name model.DeploymentName

+ Path string

+ Verb string

+ type DB struct

+ func NewDB(conn DBI) *DB

+ func (d *DB) Begin(ctx context.Context) (*Tx, error)

+ func (d *DB) Conn() DBI

+ type DBI interface

+ Begin func(ctx context.Context) (pgx.Tx, error)

+ type DBTX interface

+ Exec func(context.Context, string, ...interface{}) (pgconn.CommandTag, error)

+ Query func(context.Context, string, ...interface{}) (pgx.Rows, error)

+ QueryRow func(context.Context, string, ...interface{}) pgx.Row

+ type Deployment struct

+ CreatedAt time.Time

+ ID int64

+ Labels []byte

+ MinReplicas int32

+ ModuleID int64

+ Name model.DeploymentName

+ Schema []byte

+ type DeploymentArtefact struct

+ ArtefactID int64

+ CreatedAt time.Time

+ DeploymentID int64

+ Executable bool

+ Path string

+ type Event struct

+ CustomKey1 types.Option[string]

+ CustomKey2 types.Option[string]

+ CustomKey3 types.Option[string]

+ CustomKey4 types.Option[string]

+ DeploymentID int64

+ ID int64

+ Payload json.RawMessage

+ RequestID types.Option[int64]

+ TimeStamp time.Time

+ Type EventType

+ type EventType string

+ const EventTypeCall

+ const EventTypeDeploymentCreated

+ const EventTypeDeploymentUpdated

+ const EventTypeLog

+ func (e *EventType) Scan(src interface{}) error

+ type GetActiveRunnersRow struct

+ DeploymentName interface{}

+ Endpoint string

+ Labels []byte

+ LastSeen time.Time

+ ModuleName types.Option[string]

+ RunnerKey Key

+ State RunnerState

+ type GetAllIngressRoutesRow struct

+ DeploymentName model.DeploymentName

+ Method string

+ Module string

+ Path string

+ Verb string

+ type GetArtefactDigestsRow struct

+ Digest []byte

+ ID int64

+ type GetDeploymentArtefactsRow struct

+ CreatedAt time.Time

+ Digest []byte

+ Executable bool

+ Executable_2 bool

+ ID int64

+ Path string

+ type GetDeploymentRow struct

+ Deployment Deployment

+ Language string

+ MinReplicas int32

+ ModuleName string

+ type GetDeploymentsNeedingReconciliationRow struct

+ AssignedRunnersCount int64

+ DeploymentName model.DeploymentName

+ Language string

+ ModuleName string

+ RequiredRunnersCount int64

+ type GetDeploymentsRow struct

+ Deployment Deployment

+ Language string

+ ModuleName string

+ type GetDeploymentsWithArtefactsRow struct

+ CreatedAt time.Time

+ DeploymentName model.DeploymentName

+ ID int64

+ ModuleName string

+ type GetExistingDeploymentForModuleRow struct

+ CreatedAt time.Time

+ ID int64

+ ID_2 int64

+ Labels []byte

+ Language string

+ MinReplicas int32

+ ModuleID int64

+ Name model.DeploymentName

+ Name_2 string

+ Schema []byte

+ type GetIngressRoutesRow struct

+ Endpoint string

+ Module string

+ RunnerKey Key

+ Verb string

+ type GetProcessListRow struct

+ DeploymentLabels []byte

+ DeploymentName model.DeploymentName

+ Endpoint types.Option[string]

+ MinReplicas int32

+ RunnerKey NullKey

+ RunnerLabels []byte

+ type GetRouteForRunnerRow struct

+ DeploymentName model.DeploymentName

+ Endpoint string

+ ModuleName types.Option[string]

+ RunnerKey Key

+ State RunnerState

+ type GetRoutingTableRow struct

+ DeploymentName model.DeploymentName

+ Endpoint string

+ ModuleName types.Option[string]

+ RunnerKey Key

+ type GetRunnerRow struct

+ DeploymentName interface{}

+ Endpoint string

+ Labels []byte

+ LastSeen time.Time

+ ModuleName types.Option[string]

+ RunnerKey Key

+ State RunnerState

+ type GetRunnersForDeploymentRow struct

+ Created time.Time

+ CreatedAt time.Time

+ DeploymentID types.Option[int64]

+ Endpoint string

+ ID int64

+ ID_2 int64

+ Key Key

+ Labels []byte

+ Labels_2 []byte

+ LastSeen time.Time

+ MinReplicas int32

+ ModuleID int64

+ ModuleName types.Option[string]

+ Name model.DeploymentName

+ ReservationTimeout NullTime

+ Schema []byte

+ State RunnerState

+ type IngressRoute struct

+ DeploymentID int64

+ Method string

+ Module string

+ Path string

+ Verb string

+ type InsertCallEventParams struct

+ DeploymentName string

+ DestModule string

+ DestVerb string

+ DurationMs int64

+ Error types.Option[string]

+ Request []byte

+ RequestName types.Option[string]

+ Response []byte

+ SourceModule types.Option[string]

+ SourceVerb types.Option[string]

+ TimeStamp time.Time

+ type InsertDeploymentCreatedEventParams struct

+ DeploymentName string

+ Language string

+ MinReplicas int32

+ ModuleName string

+ Replaced types.Option[string]

+ type InsertDeploymentUpdatedEventParams struct

+ DeploymentName string

+ Language string

+ MinReplicas int32

+ ModuleName string

+ PrevMinReplicas int32

+ type InsertEventParams struct

+ CustomKey1 types.Option[string]

+ CustomKey3 types.Option[string]

+ CustomKey4 types.Option[string]

+ DeploymentID int64

+ Payload json.RawMessage

+ RequestID types.Option[int64]

+ Type EventType

+ type InsertLogEventParams struct

+ Attributes []byte

+ DeploymentName model.DeploymentName

+ Error types.Option[string]

+ Level int32

+ Message string

+ RequestName types.Option[string]

+ TimeStamp time.Time

+ type Key ulid.ULID

+ func (u *Key) Scan(src any) error

+ func (u *Key) UnmarshalText(text []byte) error

+ func (u Key) Value() (driver.Value, error)

+ type Module struct

+ ID int64

+ Language string

+ Name string

+ type NullControllerState struct

+ ControllerState ControllerState

+ Valid bool

+ func (ns *NullControllerState) Scan(value interface{}) error

+ func (ns NullControllerState) Value() (driver.Value, error)

+ type NullDuration = types.Option[time.Duration]

+ type NullEventType struct

+ EventType EventType

+ Valid bool

+ func (ns *NullEventType) Scan(value interface{}) error

+ func (ns NullEventType) Value() (driver.Value, error)

+ type NullKey = types.Option[Key]

+ func FromOption(o types.Option[T]) NullKey

+ func NoneKey() NullKey

+ func SomeKey(key Key) NullKey

+ type NullOrigin struct

+ Origin Origin

+ Valid bool

+ func (ns *NullOrigin) Scan(value interface{}) error

+ func (ns NullOrigin) Value() (driver.Value, error)

+ type NullRunnerState struct

+ RunnerState RunnerState

+ Valid bool

+ func (ns *NullRunnerState) Scan(value interface{}) error

+ func (ns NullRunnerState) Value() (driver.Value, error)

+ type NullTime = types.Option[time.Time]

+ type Origin string

+ const OriginCron

+ const OriginIngress

+ const OriginPubsub

+ func (e *Origin) Scan(src interface{}) error

+ type Querier interface

+ AssociateArtefactWithDeployment func(ctx context.Context, arg AssociateArtefactWithDeploymentParams) error

+ CreateArtefact func(ctx context.Context, digest []byte, content []byte) (int64, error)

+ CreateDeployment func(ctx context.Context, name model.DeploymentName, moduleName string, ...) error

+ CreateIngressRequest func(ctx context.Context, origin Origin, name string, sourceAddr string) error

+ CreateIngressRoute func(ctx context.Context, arg CreateIngressRouteParams) error

+ DeregisterRunner func(ctx context.Context, key Key) (int64, error)

+ ExpireRunnerReservations func(ctx context.Context) (int64, error)

+ GetActiveRunners func(ctx context.Context, all bool) ([]GetActiveRunnersRow, error)

+ GetAllIngressRoutes func(ctx context.Context, all bool) ([]GetAllIngressRoutesRow, error)

+ GetArtefactContentRange func(ctx context.Context, start int32, count int32, iD int64) ([]byte, error)

+ GetArtefactDigests func(ctx context.Context, digests [][]byte) ([]GetArtefactDigestsRow, error)

+ GetControllers func(ctx context.Context, all bool) ([]Controller, error)

+ GetDeployment func(ctx context.Context, name model.DeploymentName) (GetDeploymentRow, error)

+ GetDeploymentArtefacts func(ctx context.Context, deploymentID int64) ([]GetDeploymentArtefactsRow, error)

+ GetDeployments func(ctx context.Context, all bool) ([]GetDeploymentsRow, error)

+ GetDeploymentsByID func(ctx context.Context, ids []int64) ([]Deployment, error)

+ GetDeploymentsNeedingReconciliation func(ctx context.Context) ([]GetDeploymentsNeedingReconciliationRow, error)

+ GetDeploymentsWithArtefacts func(ctx context.Context, digests [][]byte, count interface{}) ([]GetDeploymentsWithArtefactsRow, error)

+ GetExistingDeploymentForModule func(ctx context.Context, name string) (GetExistingDeploymentForModuleRow, error)

+ GetIdleRunners func(ctx context.Context, labels []byte, limit int32) ([]Runner, error)

+ GetIngressRoutes func(ctx context.Context, method string, path string) ([]GetIngressRoutesRow, error)

+ GetModulesByID func(ctx context.Context, ids []int64) ([]Module, error)

+ GetProcessList func(ctx context.Context) ([]GetProcessListRow, error)

+ GetRouteForRunner func(ctx context.Context, key Key) (GetRouteForRunnerRow, error)

+ GetRoutingTable func(ctx context.Context, modules []string) ([]GetRoutingTableRow, error)

+ GetRunner func(ctx context.Context, key Key) (GetRunnerRow, error)

+ GetRunnerState func(ctx context.Context, key Key) (RunnerState, error)

+ GetRunnersForDeployment func(ctx context.Context, name model.DeploymentName) ([]GetRunnersForDeploymentRow, error)

+ InsertCallEvent func(ctx context.Context, arg InsertCallEventParams) error

+ InsertDeploymentCreatedEvent func(ctx context.Context, arg InsertDeploymentCreatedEventParams) error

+ InsertDeploymentUpdatedEvent func(ctx context.Context, arg InsertDeploymentUpdatedEventParams) error

+ InsertEvent func(ctx context.Context, arg InsertEventParams) error

+ InsertLogEvent func(ctx context.Context, arg InsertLogEventParams) error

+ KillStaleControllers func(ctx context.Context, timeout time.Duration) (int64, error)

+ KillStaleRunners func(ctx context.Context, timeout time.Duration) (int64, error)

+ ReplaceDeployment func(ctx context.Context, oldDeployment string, newDeployment string, ...) (int64, error)

+ ReserveRunner func(ctx context.Context, reservationTimeout time.Time, ...) (Runner, error)

+ SetDeploymentDesiredReplicas func(ctx context.Context, name model.DeploymentName, minReplicas int32) error

+ UpsertController func(ctx context.Context, key model.ControllerKey, endpoint string) (int64, error)

+ UpsertModule func(ctx context.Context, language string, name string) (int64, error)

+ UpsertRunner func(ctx context.Context, arg UpsertRunnerParams) (types.Option[int64], error)

+ type Queries struct

+ func New(db DBTX) *Queries

+ func (q *Queries) AssociateArtefactWithDeployment(ctx context.Context, arg AssociateArtefactWithDeploymentParams) error

+ func (q *Queries) CreateArtefact(ctx context.Context, digest []byte, content []byte) (int64, error)

+ func (q *Queries) CreateDeployment(ctx context.Context, name model.DeploymentName, moduleName string, ...) error

+ func (q *Queries) CreateIngressRequest(ctx context.Context, origin Origin, name string, sourceAddr string) error

+ func (q *Queries) CreateIngressRoute(ctx context.Context, arg CreateIngressRouteParams) error

+ func (q *Queries) DeregisterRunner(ctx context.Context, key Key) (int64, error)

+ func (q *Queries) ExpireRunnerReservations(ctx context.Context) (int64, error)

+ func (q *Queries) GetActiveRunners(ctx context.Context, all bool) ([]GetActiveRunnersRow, error)

+ func (q *Queries) GetAllIngressRoutes(ctx context.Context, all bool) ([]GetAllIngressRoutesRow, error)

+ func (q *Queries) GetArtefactContentRange(ctx context.Context, start int32, count int32, iD int64) ([]byte, error)

+ func (q *Queries) GetArtefactDigests(ctx context.Context, digests [][]byte) ([]GetArtefactDigestsRow, error)

+ func (q *Queries) GetControllers(ctx context.Context, all bool) ([]Controller, error)

+ func (q *Queries) GetDeployment(ctx context.Context, name model.DeploymentName) (GetDeploymentRow, error)

+ func (q *Queries) GetDeploymentArtefacts(ctx context.Context, deploymentID int64) ([]GetDeploymentArtefactsRow, error)

+ func (q *Queries) GetDeployments(ctx context.Context, all bool) ([]GetDeploymentsRow, error)

+ func (q *Queries) GetDeploymentsByID(ctx context.Context, ids []int64) ([]Deployment, error)

+ func (q *Queries) GetDeploymentsNeedingReconciliation(ctx context.Context) ([]GetDeploymentsNeedingReconciliationRow, error)

+ func (q *Queries) GetDeploymentsWithArtefacts(ctx context.Context, digests [][]byte, count interface{}) ([]GetDeploymentsWithArtefactsRow, error)

+ func (q *Queries) GetExistingDeploymentForModule(ctx context.Context, name string) (GetExistingDeploymentForModuleRow, error)

+ func (q *Queries) GetIdleRunners(ctx context.Context, labels []byte, limit int32) ([]Runner, error)

+ func (q *Queries) GetIngressRoutes(ctx context.Context, method string, path string) ([]GetIngressRoutesRow, error)

+ func (q *Queries) GetModulesByID(ctx context.Context, ids []int64) ([]Module, error)

+ func (q *Queries) GetProcessList(ctx context.Context) ([]GetProcessListRow, error)

+ func (q *Queries) GetRouteForRunner(ctx context.Context, key Key) (GetRouteForRunnerRow, error)

+ func (q *Queries) GetRoutingTable(ctx context.Context, modules []string) ([]GetRoutingTableRow, error)

+ func (q *Queries) GetRunner(ctx context.Context, key Key) (GetRunnerRow, error)

+ func (q *Queries) GetRunnerState(ctx context.Context, key Key) (RunnerState, error)

+ func (q *Queries) GetRunnersForDeployment(ctx context.Context, name model.DeploymentName) ([]GetRunnersForDeploymentRow, error)

+ func (q *Queries) InsertCallEvent(ctx context.Context, arg InsertCallEventParams) error

+ func (q *Queries) InsertDeploymentCreatedEvent(ctx context.Context, arg InsertDeploymentCreatedEventParams) error

+ func (q *Queries) InsertDeploymentUpdatedEvent(ctx context.Context, arg InsertDeploymentUpdatedEventParams) error

+ func (q *Queries) InsertEvent(ctx context.Context, arg InsertEventParams) error

+ func (q *Queries) InsertLogEvent(ctx context.Context, arg InsertLogEventParams) error

+ func (q *Queries) KillStaleControllers(ctx context.Context, timeout time.Duration) (int64, error)

+ func (q *Queries) KillStaleRunners(ctx context.Context, timeout time.Duration) (int64, error)

+ func (q *Queries) ReplaceDeployment(ctx context.Context, oldDeployment string, newDeployment string, ...) (int64, error)

+ func (q *Queries) ReserveRunner(ctx context.Context, reservationTimeout time.Time, ...) (Runner, error)

+ func (q *Queries) SetDeploymentDesiredReplicas(ctx context.Context, name model.DeploymentName, minReplicas int32) error

+ func (q *Queries) UpsertController(ctx context.Context, key model.ControllerKey, endpoint string) (int64, error)

+ func (q *Queries) UpsertModule(ctx context.Context, language string, name string) (int64, error)

+ func (q *Queries) UpsertRunner(ctx context.Context, arg UpsertRunnerParams) (types.Option[int64], error)

+ func (q *Queries) WithTx(tx pgx.Tx) *Queries

+ type Request struct

+ ID int64

+ Name string

+ Origin Origin

+ SourceAddr string

+ type Runner struct

+ Created time.Time

+ DeploymentID types.Option[int64]

+ Endpoint string

+ ID int64

+ Key Key

+ Labels []byte

+ LastSeen time.Time

+ ModuleName types.Option[string]

+ ReservationTimeout NullTime

+ State RunnerState

+ type RunnerState string

+ const RunnerStateAssigned

+ const RunnerStateDead

+ const RunnerStateIdle

+ const RunnerStateReserved

+ func (e *RunnerState) Scan(src interface{}) error

+ type Tx struct

+ func (t *Tx) Commit(ctx context.Context) error

+ func (t *Tx) CommitOrRollback(ctx context.Context, err *error)

+ func (t *Tx) Rollback(ctx context.Context) error

+ type UpsertRunnerParams struct

+ DeploymentName types.Option[string]

+ Endpoint string

+ Key Key

+ Labels []byte

+ State RunnerState