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

swo

package

Go to main page

Versions in this module

v0

v0.33.0

Nov 19, 2024

Changes in this version

+ func NewAppPGXPool(oldURL, nextURL string, maxOpen, maxIdle int) (*pgxpool.Pool, error)

type Config

+ MaxIdle int

+ MaxOpen int

type Manager

+ func (m *Manager) Pool() *pgxpool.Pool

v0.33.0-rc.0

Nov 19, 2024

v0.32.0

Feb 9, 2024

v0.31.1

Sep 6, 2023

v0.31.0

Aug 25, 2023

Changes in this version

+ type Config struct

+ CanExec bool

+ Logger *log.Logger

+ NewDBURL string

+ OldDBURL string

+ type ConnInfo struct

+ ID uuid.UUID

+ Type ConnType

+ Version string

+ func ParseConnInfo(s string) (*ConnInfo, error)

+ func (c ConnInfo) String() string

+ type ConnType byte

+ const ConnTypeMainApp

+ const ConnTypeMainMgr

+ const ConnTypeNextApp

+ const ConnTypeNextMgr

+ func (t ConnType) IsNext() bool

+ func (t ConnType) IsValid() bool

+ type Connector struct

+ func NewConnector(dbcOld, dbcNew driver.Connector) *Connector

+ func (drv *Connector) Connect(ctx context.Context) (driver.Conn, error)

+ func (drv *Connector) Driver() driver.Driver

+ type Executor struct

+ func NewExecutor(mgr *Manager) *Executor

+ func (e *Executor) Cancel()

+ func (e *Executor) Exec(ctx context.Context) error

+ func (e *Executor) Sync(ctx context.Context) error

+ type Manager struct

+ MainDBInfo *swoinfo.DB

+ NextDBInfo *swoinfo.DB

+ func NewManager(cfg Config) (*Manager, error)

+ func (m *Manager) ConnInfo(ctx context.Context) (counts []swoinfo.ConnCount, err error)

+ func (m *Manager) DB() *sql.DB

+ func (m *Manager) Reset(ctx context.Context) error

+ func (m *Manager) SetPauseResumer(app lifecycle.PauseResumer)

+ func (m *Manager) StartExecute(ctx context.Context) error

+ func (m *Manager) Status() Status

+ type Node struct

+ CanExec bool

+ ID uuid.UUID

+ NewValid bool

+ OldValid bool

+ Status string

+ type Status struct

+ MainDBID uuid.UUID

+ MainDBVersion string

+ NextDBID uuid.UUID

+ NextDBVersion string

+ type WithFunc struct

+ func NewWithFunc(withFn func(ctx context.Context, useFn func(V)) error) *WithFunc[V]

+ func (w *WithFunc[V]) Begin(ctx context.Context) (v V, err error)

+ func (w *WithFunc[V]) Cancel()

v0.31.0-rc.0

Jul 19, 2023