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

types

package

Go to main page

Versions in this module

v1

v1.0.5

Oct 28, 2024

Changes in this version

+ type LeaseKey struct

v1.0.4

Sep 24, 2024

v1.0.3

Sep 19, 2024

v1.0.2

Aug 30, 2024

v1.0.1

Aug 16, 2024

Changes in this version

type Stager

+ CheckConsistency func(ctx context.Context, db StagingQuerier, muts []Mutation, followerRead bool) (int, error)

v1.0.0

May 31, 2024

v0

v0.0.0

May 31, 2024

Changes in this version

+ const CustomUpsert

+ const ToastedColumnPlaceholder

+ var ErrCancelSingleton = errors.New("singleton requested cancellation")

+ type AcceptOptions struct

+ TargetQuerier TargetQuerier

+ func (o *AcceptOptions) Copy() *AcceptOptions

+ type Accumulator interface

+ Accumulate func(table ident.Table, mut Mutation) error

+ type AccumulatorFunc func(ident.Table, Mutation) error

+ func (f AccumulatorFunc) Accumulate(table ident.Table, mut Mutation) error

+ type AnyPool interface

+ Info func() *PoolInfo

+ type Authenticator interface

+ Check func(ctx context.Context, schema ident.Schema, token string) (ok bool, _ error)

+ type Batch interface

+ Copy func() B

+ CopyInto func(acc Accumulator) error

+ Count func() int

+ Empty func() B

+ type ColData struct

+ DefaultExpr string

+ Ignored bool

+ Name ident.Ident

+ Parse func(any) (any, error)

+ Primary bool

+ Type string

+ func (d ColData) Equal(o ColData) bool

+ type Counter interface

+ Add func(float64)

+ type DLQ interface

+ Enqueue func(ctx context.Context, tx TargetQuerier, mut Mutation) error

+ type DLQs interface

+ Get func(ctx context.Context, target ident.Schema, name string) (DLQ, error)

+ type Deadlines = *ident.Map[time.Duration]

+ type Lease interface

+ Context func() context.Context

+ Release func()

+ type LeaseBusyError struct

+ Expiration time.Time

+ func IsLeaseBusy(err error) (busy *LeaseBusyError, ok bool)

+ func (e *LeaseBusyError) Error() string

+ type Leases interface

+ Acquire func(ctx context.Context, name string) (Lease, error)

+ Singleton func(ctx context.Context, name string, fn func(ctx context.Context) error)

+ type Memo interface

+ Get func(ctx context.Context, tx StagingQuerier, key string) ([]byte, error)

+ Put func(ctx context.Context, tx StagingQuerier, key string, value []byte) error

+ type MultiAcceptor interface

+ AcceptMultiBatch func(context.Context, *MultiBatch, *AcceptOptions) error

+ func CountingAcceptor(delegate MultiAcceptor, errors Counter, received Counter, successes Counter) MultiAcceptor

+ func OrderedAcceptorFrom(acc TableAcceptor, watchers Watchers) MultiAcceptor

+ type MultiBatch struct

+ ByTime map[hlc.Time]*TemporalBatch

+ Data []*TemporalBatch

+ func (b *MultiBatch) Accumulate(table ident.Table, mut Mutation) error

+ func (b *MultiBatch) Copy() *MultiBatch

+ func (b *MultiBatch) CopyInto(acc Accumulator) error

+ func (b *MultiBatch) Count() int

+ func (b *MultiBatch) Empty() *MultiBatch

+ func (b *MultiBatch) Len() int

+ func (b *MultiBatch) Less(i, j int) bool

+ func (b *MultiBatch) Swap(i, j int)

+ type Mutation struct

+ Before json.RawMessage

+ Data json.RawMessage

+ Key json.RawMessage

+ Meta map[string]any

+ Time hlc.Time

+ func Flatten[B any](batch Batch[B]) []Mutation

+ func (m Mutation) IsDelete() bool

+ type PoolInfo struct

+ ConnectionString string

+ ErrCode func(err error) (string, bool)

+ HintNoFTS func(table ident.Table) *ident.Hinted[ident.Table]

+ IsDeferrable func(err error) bool

+ Product Product

+ ShouldRetry func(err error) bool

+ Version string

+ func (i *PoolInfo) Info() *PoolInfo

+ type Product int

+ const ProductCockroachDB

+ const ProductMariaDB

+ const ProductMySQL

+ const ProductOracle

+ const ProductPostgreSQL

+ const ProductUnknown

+ func (i Product) String() string

+ func (p Product) ExpandSchema(s ident.Schema) (ident.Schema, error)

+ type SchemaData struct

+ Columns *ident.TableMap[[]ColData]

+ Order [][]ident.Table

+ func (s *SchemaData) OriginalName(tbl ident.Table) (ident.Table, bool)

+ type SourcePool struct

+ type Stager interface

+ MarkApplied func(ctx context.Context, db StagingQuerier, muts []Mutation) error

+ Retire func(ctx context.Context, db StagingQuerier, end hlc.Time) error

+ Stage func(ctx context.Context, db StagingQuerier, muts []Mutation) error

+ StageIfExists func(ctx context.Context, db StagingQuerier, muts []Mutation) ([]Mutation, error)

+ type Stagers interface

+ Get func(ctx context.Context, target ident.Table) (Stager, error)

+ Read func(ctx *stopper.Context, q *StagingQuery) (<-chan *StagingCursor, error)

+ type StagingCursor struct

+ Batch *TemporalBatch

+ Error error

+ Fragment bool

+ Jump bool

+ Progress hlc.Range

+ func (c *StagingCursor) String() string

+ type StagingPool struct

+ type StagingQuerier interface

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

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

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

+ type StagingQuery struct

+ Bounds *notify.Var[hlc.Range]

+ FragmentSize int

+ Group *TableGroup

+ type TableAcceptor interface

+ AcceptTableBatch func(context.Context, *TableBatch, *AcceptOptions) error

+ type TableBatch struct

+ Data []Mutation

+ Table ident.Table

+ Time hlc.Time

+ func (b *TableBatch) Accumulate(table ident.Table, mut Mutation) error

+ func (b *TableBatch) Copy() *TableBatch

+ func (b *TableBatch) CopyInto(acc Accumulator) error

+ func (b *TableBatch) Count() int

+ func (b *TableBatch) Empty() *TableBatch

+ type TableGroup struct

+ Enclosing ident.Schema

+ Name ident.Ident

+ Tables []ident.Table

+ func (g *TableGroup) Copy() *TableGroup

+ func (g *TableGroup) Schema() (ident.Schema, error)

+ func (g *TableGroup) String() string

+ type TargetPool struct

+ type TargetQuerier interface

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

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

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

+ type TargetStatements struct

+ type TargetTx interface

+ Commit func() error

+ Rollback func() error

+ type TemporalAcceptor interface

+ AcceptTemporalBatch func(context.Context, *TemporalBatch, *AcceptOptions) error

+ type TemporalBatch struct

+ Data ident.TableMap[*TableBatch]

+ Time hlc.Time

+ func (b *TemporalBatch) Accumulate(table ident.Table, mut Mutation) error

+ func (b *TemporalBatch) Copy() *TemporalBatch

+ func (b *TemporalBatch) CopyInto(acc Accumulator) error

+ func (b *TemporalBatch) Count() int

+ func (b *TemporalBatch) Empty() *TemporalBatch

+ type Watcher interface

+ Get func() *SchemaData

+ Refresh func(context.Context, *TargetPool) error

+ Watch func(table ident.Table) (_ <-chan []ColData, cancel func(), _ error)

+ type Watchers interface

+ Get func(db ident.Schema) (Watcher, error)