Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

sql

package

Go to main page

Versions in this module

v0

v0.368.1

Sep 20, 2024

v0.368.0

Sep 20, 2024

v0.367.0

Sep 19, 2024

v0.366.0

Sep 18, 2024

v0.365.0

Sep 17, 2024

v0.364.1

Sep 17, 2024

v0.364.0

Sep 16, 2024

v0.363.0

Sep 16, 2024

v0.362.1

Sep 13, 2024

v0.362.0

Sep 13, 2024

v0.361.5

Sep 12, 2024

v0.361.4

Sep 12, 2024

v0.361.3

Sep 11, 2024

v0.361.2

Sep 11, 2024

v0.361.1

Sep 11, 2024

v0.361.0

Sep 11, 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 encryption.EncryptedAsyncColumn

+ Response encryption.OptionalEncryptedAsyncColumn

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

+ LastAsyncCallID optional.Option[int64]

+ LastExecution optional.Option[time.Time]

+ ModuleName string

+ NextExecution time.Time

+ Schedule string

+ StartTime time.Time

+ Verb string

+ 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

+ VerifyAsync encryption.OptionalEncryptedAsyncColumn

+ VerifyTimeline encryption.OptionalEncryptedTimelineColumn

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

+ type FsmStatus string

+ const FsmStatusCompleted

+ const FsmStatusFailed

+ const FsmStatusRunning

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

+ type GetCronJobByKeyRow struct

+ CronJob CronJob

+ Deployment Deployment

+ type GetUnscheduledCronJobsRow struct

+ CronJob CronJob

+ Deployment Deployment

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

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

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

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

+ func New(db DBTX) *Queries

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

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

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

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

+ Endpoint string

+ ID int64

+ Key model.RunnerKey

+ Labels json.RawMessage

+ LastSeen time.Time

+ ModuleName optional.Option[string]

+ State RunnerState

+ type RunnerState string

+ const RunnerStateAssigned

+ const RunnerStateDead

+ const RunnerStateNew

+ 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 encryption.EncryptedTimelineColumn

+ 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 = sqltypes.Type

+ type UpdateCronJobExecutionParams struct

+ Key model.CronJobKey

+ LastAsyncCallID int64

+ LastExecution time.Time

+ NextExecution time.Time