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

hasql

package module

Go to main page

Versions in this module

v1

v1.1.1

Sep 10, 2023

Changes in this version

type Cluster

+ func (cl *Cluster) Err() error

+ type CollectedErrors struct

+ Errors []NodeError

+ func (e *CollectedErrors) Error() string

+ type NodeError struct

+ Addr string

+ Err error

+ OccurredAt time.Time

+ func (e *NodeError) Error() string

v1.1.0

Jun 17, 2023

v1.0.0

Nov 21, 2020

Changes in this version

type NodePicker

+ func PickNodeClosest() NodePicker

v0

v0.9.1

Sep 15, 2020

v0.9.0

Sep 12, 2020

Changes in this version

+ const DefaultUpdateInterval

+ const DefaultUpdateTimeout

+ type AliveNodes struct

+ Alive []Node

+ Primaries []Node

+ Standbys []Node

+ type Cluster struct

+ func NewCluster(nodes []Node, checkNode NodeChecker, opts ...ClusterOption) (*Cluster, error)

+ func (cl *Cluster) Alive() Node

+ func (cl *Cluster) Close() error

+ func (cl *Cluster) Node(criteria NodeStateCriteria) Node

+ func (cl *Cluster) Nodes() []Node

+ func (cl *Cluster) Primary() Node

+ func (cl *Cluster) PrimaryPreferred() Node

+ func (cl *Cluster) Standby() Node

+ func (cl *Cluster) StandbyPreferred() Node

+ func (cl *Cluster) WaitForAlive(ctx context.Context) (Node, error)

+ func (cl *Cluster) WaitForNode(ctx context.Context, criteria NodeStateCriteria) (Node, error)

+ func (cl *Cluster) WaitForPrimary(ctx context.Context) (Node, error)

+ func (cl *Cluster) WaitForPrimaryPreferred(ctx context.Context) (Node, error)

+ func (cl *Cluster) WaitForStandby(ctx context.Context) (Node, error)

+ func (cl *Cluster) WaitForStandbyPreferred(ctx context.Context) (Node, error)

+ type ClusterOption func(*Cluster)

+ func WithNodePicker(f NodePicker) ClusterOption

+ func WithTracer(tracer Tracer) ClusterOption

+ func WithUpdateInterval(d time.Duration) ClusterOption

+ func WithUpdateTimeout(d time.Duration) ClusterOption

+ type Node interface

+ Addr func() string

+ DB func() *sql.DB

+ func NewNode(addr string, db *sql.DB) Node

+ type NodeChecker func(ctx context.Context, db *sql.DB) (bool, error)

+ type NodePicker func([]Node) Node

+ func PickNodeRandom() NodePicker

+ func PickNodeRoundRobin() NodePicker

+ type NodeStateCriteria int

+ const Alive

+ const PreferPrimary

+ const PreferStandby

+ const Primary

+ const Standby

+ type Tracer struct

+ NodeAlive func(node Node)

+ NodeDead func(node Node, err error)

+ NotifiedWaiters func()

+ UpdateNodes func()

+ UpdatedNodes func(nodes AliveNodes)