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

observer

package

Go to main page

Versions in this module

v1

v1.3.0

Oct 25, 2024

v1.2.0

Aug 15, 2024

v1.1.0

Jun 25, 2024

Changes in this version

+ type BackendFetcher interface

+ GetBackendList func(context.Context) (map[string]*BackendInfo, error)

+ type BackendHealth struct

+ Healthy bool

+ Local bool

+ PingErr error

+ ServerVersion string

+ func (bh *BackendHealth) Equals(health BackendHealth) bool

+ func (bh *BackendHealth) String() string

+ type BackendInfo struct

+ IP string

+ Labels map[string]string

+ StatusPort uint

+ type BackendObserver interface

+ Close func()

+ Refresh func()

+ Start func(ctx context.Context)

+ Subscribe func(name string) <-chan HealthResult

+ Unsubscribe func(name string)

+ type DefaultBackendObserver struct

+ func NewDefaultBackendObserver(logger *zap.Logger, config *config.HealthCheck, backendFetcher BackendFetcher, ...) *DefaultBackendObserver

+ func (bo *DefaultBackendObserver) Close()

+ func (bo *DefaultBackendObserver) Refresh()

+ func (bo *DefaultBackendObserver) Start(ctx context.Context)

+ func (bo *DefaultBackendObserver) Subscribe(name string) <-chan HealthResult

+ func (bo *DefaultBackendObserver) Unsubscribe(name string)

+ type DefaultHealthCheck struct

+ func NewDefaultHealthCheck(httpCli *http.Client, cfg *config.HealthCheck, logger *zap.Logger) *DefaultHealthCheck

+ func (dhc *DefaultHealthCheck) Check(ctx context.Context, addr string, info *BackendInfo) *BackendHealth

+ type HealthCheck interface

+ Check func(ctx context.Context, addr string, info *BackendInfo) *BackendHealth

+ type HealthResult struct

+ func NewHealthResult(backends map[string]*BackendHealth, err error) HealthResult

+ func (hr HealthResult) Backends() map[string]*BackendHealth

+ func (hr HealthResult) Error() error

+ type PDFetcher struct

+ func NewPDFetcher(tpFetcher TopologyFetcher, logger *zap.Logger, config *config.HealthCheck) *PDFetcher

+ func (pf *PDFetcher) GetBackendList(ctx context.Context) (map[string]*BackendInfo, error)

+ type StaticFetcher struct

+ func NewStaticFetcher(staticAddrs []string) *StaticFetcher

+ func (sf *StaticFetcher) GetBackendList(context.Context) (map[string]*BackendInfo, error)

+ type TopologyFetcher interface

+ GetTiDBTopology func(ctx context.Context) (map[string]*infosync.TiDBInfo, error)