sql

Aug 23, 2024

Changes in this version

type ConnI

+ Begin func() (*sql.Tx, error)

+ type CreateAsyncCallParams struct

+ Backoff sqltypes.Duration

+ CatchVerb optional.Option[schema.RefKey]

+ MaxBackoff sqltypes.Duration

+ Origin string

+ ParentRequestKey optional.Option[string]

+ RemainingAttempts int32

+ Request encryption.EncryptedAsyncColumn

+ ScheduledAt time.Time

+ TraceContext json.RawMessage

+ Verb schema.RefKey

type CronJob

+ LastAsyncCallID optional.Option[int64]

+ LastExecution optional.Option[time.Time]

type DB

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

type DBI

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

+ type GetCronJobByKeyRow struct

+ CronJob CronJob

+ Deployment Deployment

+ type GetUnscheduledCronJobsRow struct

+ CronJob CronJob

+ Deployment Deployment

type Querier

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

+ CreateAsyncCall func(ctx context.Context, arg CreateAsyncCallParams) (int64, error)

+ GetCronJobByKey func(ctx context.Context, key model.CronJobKey) (GetCronJobByKeyRow, error)

+ GetUnscheduledCronJobs func(ctx context.Context, startTime time.Time) ([]GetUnscheduledCronJobsRow, error)

+ IsCronJobPending func(ctx context.Context, key model.CronJobKey, startTime time.Time) (bool, error)

+ UpdateCronJobExecution func(ctx context.Context, arg UpdateCronJobExecutionParams) error

type Queries

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

+ func (q *Queries) CreateAsyncCall(ctx context.Context, arg CreateAsyncCallParams) (int64, error)

+ func (q *Queries) GetCronJobByKey(ctx context.Context, key model.CronJobKey) (GetCronJobByKeyRow, error)

+ func (q *Queries) GetUnscheduledCronJobs(ctx context.Context, startTime time.Time) ([]GetUnscheduledCronJobsRow, error)

+ func (q *Queries) IsCronJobPending(ctx context.Context, key model.CronJobKey, startTime time.Time) (bool, error)

+ func (q *Queries) UpdateCronJobExecution(ctx context.Context, arg UpdateCronJobExecutionParams) error

+ type Tx struct

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

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

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

+ func (t *Tx) Conn() ConnI

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

+ func (t *Tx) Tx() *sql.Tx

+ type UpdateCronJobExecutionParams struct

+ Key model.CronJobKey

+ LastAsyncCallID int64

+ LastExecution time.Time

+ NextExecution time.Time

Aug 21, 2024

Changes in this version

type EncryptionKey

+ VerifyAsync encryption.OptionalEncryptedAsyncColumn

+ VerifyTimeline encryption.OptionalEncryptedTimelineColumn

Aug 15, 2024

Changes in this version

+ type FsmNextEvent struct

+ CreatedAt time.Time

+ FsmInstanceID int64

+ ID int64

+ NextState schema.RefKey

+ Request []byte

+ RequestType Type

+ type Type = csql.Type

Aug 14, 2024

Changes in this version

+ type Timeline struct

+ CustomKey1 optional.Option[string]

+ CustomKey2 optional.Option[string]

+ CustomKey3 optional.Option[string]

+ CustomKey4 optional.Option[string]

+ DeploymentID int64

+ ID int64

+ ParentRequestID optional.Option[string]

+ Payload []byte

+ RequestID optional.Option[int64]

+ TimeStamp time.Time

+ Type EventType

Aug 14, 2024

Changes in this version

+ type EncryptionKey struct

+ CreatedAt time.Time

+ ID int64

+ Key []byte

Aug 11, 2024

Changes in this version

type DBTX

+ ExecContext func(context.Context, string, ...interface{}) (sql.Result, error)

+ PrepareContext func(context.Context, string) (*sql.Stmt, error)

+ QueryContext func(context.Context, string, ...interface{}) (*sql.Rows, error)

+ QueryRowContext func(context.Context, string, ...interface{}) *sql.Row

Aug 8, 2024

Changes in this version

type AsyncCall

+ ParentRequestKey optional.Option[string]

+ TraceContext []byte

type Event

+ ParentRequestID optional.Option[string]

type TopicEvent

+ RequestKey optional.Option[string]

+ TraceContext []byte

Aug 8, 2024

Changes in this version

type AsyncCall

+ CatchVerb optional.Option[schema.RefKey]

+ Catching bool

type TopicSubscriber

+ CatchVerb optional.Option[schema.RefKey]

Aug 1, 2024

Changes in this version

type TopicEvent

+ Caller string

Jul 29, 2024

Changes in this version

type FsmInstance

+ UpdatedAt time.Time

Jul 9, 2024

Changes in this version

+ type ModuleSecret struct

+ CreatedAt time.Time

+ ID int64

+ Module optional.Option[string]

+ Name string

+ Url string

Jul 8, 2024

Changes in this version

+ type Artefact struct

+ Content []byte

+ CreatedAt time.Time

+ Digest []byte

+ ID int64

+ type AsyncCall struct

+ Backoff time.Duration

+ CreatedAt time.Time

+ Error optional.Option[string]

+ ID int64

+ LeaseID optional.Option[int64]

+ MaxBackoff time.Duration

+ Origin string

+ RemainingAttempts int32

+ Request []byte

+ Response []byte

+ ScheduledAt time.Time

+ State AsyncCallState

+ Verb schema.RefKey

+ type AsyncCallState string

+ const AsyncCallStateError

+ const AsyncCallStateExecuting

+ const AsyncCallStatePending

+ const AsyncCallStateSuccess

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

+ type ConnI interface

+ 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 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 model.CronJobState

+ Verb string

+ type CronJobState string

+ const CronJobStateExecuting

+ const CronJobStateIdle

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

+ type DB struct

+ func NewDB(conn ConnI) *DB

+ func (d *DB) Conn() ConnI

+ type DBI interface

+ Conn func() ConnI

+ 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

+ Key model.DeploymentKey

+ Labels []byte

+ MinReplicas int32

+ ModuleID int64

+ Schema *schema.Module

+ type DeploymentArtefact struct

+ ArtefactID int64

+ CreatedAt time.Time

+ DeploymentID int64

+ Executable bool

+ Path string

+ type EndCronJobRow struct

+ DeploymentKey model.DeploymentKey

+ Key model.CronJobKey

+ Module string

+ NextExecution time.Time

+ Schedule string

+ StartTime time.Time

+ State model.CronJobState

+ Verb string

+ type Event struct

+ CustomKey1 optional.Option[string]

+ CustomKey2 optional.Option[string]

+ CustomKey3 optional.Option[string]

+ CustomKey4 optional.Option[string]

+ DeploymentID int64

+ ID int64

+ Payload json.RawMessage

+ RequestID optional.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 FsmInstance struct

+ AsyncCallID optional.Option[int64]

+ CreatedAt time.Time

+ CurrentState optional.Option[schema.RefKey]

+ DestinationState optional.Option[schema.RefKey]

+ Fsm schema.RefKey

+ ID int64

+ Key string

+ Status FsmStatus

+ type FsmStatus string

+ const FsmStatusCompleted

+ const FsmStatusFailed

+ const FsmStatusRunning

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

+ type GetCronJobsRow struct

+ DeploymentKey model.DeploymentKey

+ Key model.CronJobKey

+ Module string

+ NextExecution time.Time

+ Schedule string

+ StartTime time.Time

+ State model.CronJobState

+ Verb string

+ type GetStaleCronJobsRow struct

+ DeploymentKey model.DeploymentKey

+ Key model.CronJobKey

+ Module string

+ NextExecution time.Time

+ Schedule string

+ StartTime time.Time

+ State model.CronJobState

+ Verb string

+ type IngressRoute struct

+ DeploymentID int64

+ Method string

+ Module string

+ Path string

+ Verb string

+ type Lease struct

+ CreatedAt time.Time

+ ExpiresAt time.Time

+ ID int64

+ IdempotencyKey uuid.UUID

+ Key leases.Key

+ Metadata []byte

+ type Module struct

+ ID int64

+ Language string

+ Name string

+ type ModuleConfiguration struct

+ CreatedAt time.Time

+ ID int64

+ Module optional.Option[string]

+ Name string

+ Value []byte

+ type NullAsyncCallState struct

+ AsyncCallState AsyncCallState

+ Valid bool

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

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

+ type NullControllerState struct

+ ControllerState ControllerState

+ Valid bool

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

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

+ type NullCronJobState struct

+ CronJobState CronJobState

+ Valid bool

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

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

+ type NullEventType struct

+ EventType EventType

+ Valid bool

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

+ func (ns NullEventType) 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 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 NullTopicSubscriptionState struct

+ TopicSubscriptionState TopicSubscriptionState

+ Valid bool

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

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

+ type Origin string

+ const OriginCron

+ const OriginIngress

+ const OriginPubsub

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

+ type Querier interface

+ CreateCronJob func(ctx context.Context, arg CreateCronJobParams) 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 struct

+ func New(db DBTX) *Queries

+ func (q *Queries) CreateCronJob(ctx context.Context, arg CreateCronJobParams) 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)

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

+ type Request struct

+ ID int64

+ Key model.RequestKey

+ Origin Origin

+ SourceAddr string

+ type Runner struct

+ Created time.Time

+ DeploymentID optional.Option[int64]

+ Endpoint string

+ ID int64

+ Key model.RunnerKey

+ Labels []byte

+ LastSeen time.Time

+ ModuleName optional.Option[string]

+ ReservationTimeout optional.Option[time.Time]

+ State RunnerState

+ type RunnerState string

+ const RunnerStateAssigned

+ const RunnerStateDead

+ const RunnerStateIdle

+ const RunnerStateReserved

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

+ type StartCronJobsRow struct

+ DeploymentKey model.DeploymentKey

+ HasMinReplicas bool

+ Key model.CronJobKey

+ Module string

+ NextExecution time.Time

+ Schedule string

+ StartTime time.Time

+ State model.CronJobState

+ Updated bool

+ Verb string

+ type Topic struct

+ CreatedAt time.Time

+ Head optional.Option[int64]

+ ID int64

+ Key model.TopicKey

+ ModuleID int64

+ Name string

+ Type string

+ type TopicEvent struct

+ CreatedAt time.Time

+ ID int64

+ Key model.TopicEventKey

+ Payload []byte

+ TopicID int64

+ type TopicSubscriber struct

+ Backoff time.Duration

+ CreatedAt time.Time

+ DeploymentID int64

+ ID int64

+ Key model.SubscriberKey

+ MaxBackoff time.Duration

+ RetryAttempts int32

+ Sink schema.RefKey

+ TopicSubscriptionsID int64

+ type TopicSubscription struct

+ CreatedAt time.Time

+ Cursor optional.Option[int64]

+ DeploymentID int64

+ ID int64

+ Key model.SubscriptionKey

+ ModuleID int64

+ Name string

+ State TopicSubscriptionState

+ TopicID int64

+ type TopicSubscriptionState string

+ const TopicSubscriptionStateExecuting

+ const TopicSubscriptionStateIdle

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