sql

package

Go to main page

Versions in this module

v0

v0.360.0

Aug 30, 2024

v0.359.1

Aug 24, 2024

v0.359.0

Aug 23, 2024

Changes in this version

type CronJob

+ LastAsyncCallID optional.Option[int64]

+ LastExecution optional.Option[time.Time]

v0.358.0

Aug 23, 2024

v0.357.0

Aug 23, 2024

v0.356.0

Aug 22, 2024

v0.355.1

Aug 22, 2024

v0.355.0

Aug 21, 2024

v0.354.2

Aug 21, 2024

v0.354.1

Aug 21, 2024

Changes in this version

type EncryptionKey

+ VerifyAsync encryption.OptionalEncryptedAsyncColumn

+ VerifyTimeline encryption.OptionalEncryptedTimelineColumn

v0.354.0

Aug 20, 2024

v0.353.0

Aug 20, 2024

v0.352.0

Aug 20, 2024

v0.351.0

Aug 20, 2024

v0.350.0

Aug 20, 2024

v0.349.2

Aug 20, 2024

v0.349.1

Aug 20, 2024

v0.349.0

Aug 20, 2024

v0.348.3

Aug 19, 2024

v0.348.2

Aug 19, 2024

v0.348.1

Aug 19, 2024

v0.348.0

Aug 19, 2024

v0.347.0

Aug 19, 2024

v0.346.0

Aug 19, 2024

v0.345.2

Aug 17, 2024

v0.345.1

Aug 17, 2024

v0.343.0

Aug 17, 2024

Changes in this version

+ type Artefact struct

+ Content []byte

+ CreatedAt time.Time

+ Digest []byte

+ ID int64

+ type AsyncCall struct

+ Backoff sqltypes.Duration

+ CatchVerb optional.Option[schema.RefKey]

+ Catching bool

+ CreatedAt time.Time

+ Error optional.Option[string]

+ ID int64

+ LeaseID optional.Option[int64]

+ MaxBackoff sqltypes.Duration

+ Origin string

+ ParentRequestKey optional.Option[string]

+ RemainingAttempts int32

+ Request []byte

+ Response []byte

+ ScheduledAt time.Time

+ State AsyncCallState

+ TraceContext pqtype.NullRawMessage

+ 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 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

+ 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

+ type Deployment struct

+ CreatedAt time.Time

+ ID int64

+ Key model.DeploymentKey

+ Labels json.RawMessage

+ MinReplicas int32

+ ModuleID int64

+ Schema *schema.Module

+ type DeploymentArtefact struct

+ ArtefactID int64

+ CreatedAt time.Time

+ DeploymentID int64

+ Executable bool

+ Path string

+ type EncryptionKey struct

+ CreatedAt time.Time

+ ID int64

+ Key []byte

+ 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

+ UpdatedAt time.Time

+ type FsmNextEvent struct

+ CreatedAt time.Time

+ FsmInstanceID int64

+ ID int64

+ NextState schema.RefKey

+ Request []byte

+ RequestType Type

+ type FsmStatus string

+ const FsmStatusCompleted

+ const FsmStatusFailed

+ const FsmStatusRunning

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

+ 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 pqtype.NullRawMessage

+ type Module struct

+ ID int64

+ Language string

+ Name string

+ type ModuleConfiguration struct

+ CreatedAt time.Time

+ ID int64

+ Module optional.Option[string]

+ Name string

+ Value json.RawMessage

+ type ModuleSecret struct

+ CreatedAt time.Time

+ ID int64

+ Module optional.Option[string]

+ Name string

+ Url string

+ 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

+ GetModuleConfiguration func(ctx context.Context, module optional.Option[string], name string) (json.RawMessage, error)

+ GetModuleSecretURL func(ctx context.Context, module optional.Option[string], name string) (string, error)

+ ListModuleConfiguration func(ctx context.Context) ([]ModuleConfiguration, error)

+ ListModuleSecrets func(ctx context.Context) ([]ModuleSecret, error)

+ SetModuleConfiguration func(ctx context.Context, module optional.Option[string], name string, ...) error

+ SetModuleSecretURL func(ctx context.Context, module optional.Option[string], name string, url string) error

+ UnsetModuleConfiguration func(ctx context.Context, module optional.Option[string], name string) error

+ UnsetModuleSecret func(ctx context.Context, module optional.Option[string], name string) error

+ type Queries struct

+ func New(db DBTX) *Queries

+ func (q *Queries) GetModuleConfiguration(ctx context.Context, module optional.Option[string], name string) (json.RawMessage, error)

+ func (q *Queries) GetModuleSecretURL(ctx context.Context, module optional.Option[string], name string) (string, error)

+ func (q *Queries) ListModuleConfiguration(ctx context.Context) ([]ModuleConfiguration, error)

+ func (q *Queries) ListModuleSecrets(ctx context.Context) ([]ModuleSecret, error)

+ func (q *Queries) SetModuleConfiguration(ctx context.Context, module optional.Option[string], name string, ...) error

+ func (q *Queries) SetModuleSecretURL(ctx context.Context, module optional.Option[string], name string, url string) error

+ func (q *Queries) UnsetModuleConfiguration(ctx context.Context, module optional.Option[string], name string) error

+ func (q *Queries) UnsetModuleSecret(ctx context.Context, module optional.Option[string], name string) error

+ func (q *Queries) WithTx(tx *sql.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 json.RawMessage

+ 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 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

+ type Topic struct

+ CreatedAt time.Time

+ Head optional.Option[int64]

+ ID int64

+ Key model.TopicKey

+ ModuleID int64

+ Name string

+ Type string

+ type TopicEvent struct

+ Caller optional.Option[string]

+ CreatedAt time.Time

+ ID int64

+ Key model.TopicEventKey

+ Payload []byte

+ RequestKey optional.Option[string]

+ TopicID int64

+ TraceContext pqtype.NullRawMessage

+ type TopicSubscriber struct

+ Backoff sqltypes.Duration

+ CatchVerb optional.Option[schema.RefKey]

+ CreatedAt time.Time

+ DeploymentID int64

+ ID int64

+ Key model.SubscriberKey

+ MaxBackoff sqltypes.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

+ type Type = csql.Type

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL