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

connector

package

Go to main page

Versions in this module

v1

v1.5.1

Aug 7, 2024

v1.5.0

Aug 6, 2024

Changes in this version

type Connector

+ func (c *Connector) StopTicker(name string) error

v1.4.0

Aug 1, 2024

v1.3.0

Jul 28, 2024

v1.2.0

Jul 15, 2024

v1.1.0

Jul 14, 2024

v1.0.0

Jul 9, 2024

Changes in this version

+ const LAB

+ const LOCAL

+ const PROD

+ const TESTING

+ type Connector struct

+ func New(hostname string) *Connector

+ func NewConnector() *Connector

+ func (c *Connector) Config(name string) (value string)

+ func (c *Connector) DefineConfig(name string, options ...cfg.Option) error

+ func (c *Connector) DefineCounter(name, help string, labels []string) error

+ func (c *Connector) DefineGauge(name, help string, labels []string) error

+ func (c *Connector) DefineHistogram(name, help string, buckets []float64, labels []string) error

+ func (c *Connector) Deployment() string

+ func (c *Connector) Description() string

+ func (c *Connector) DistribCache() *dlru.Cache

+ func (c *Connector) ExecuteResTemplate(name string, data any) (string, error)

+ func (c *Connector) ForceTrace(ctx context.Context)

+ func (c *Connector) GET(ctx context.Context, url string) (*http.Response, error)

+ func (c *Connector) Go(ctx context.Context, f func(ctx context.Context) (err error)) error

+ func (c *Connector) Hostname() string

+ func (c *Connector) ID() string

+ func (c *Connector) IncrementMetric(name string, val float64, labels ...string) error

+ func (c *Connector) IsStarted() bool

+ func (c *Connector) Lifetime() context.Context

+ func (c *Connector) LoadResString(ctx context.Context, stringKey string) (string, error)

+ func (c *Connector) Locality() string

+ func (c *Connector) LogDebug(ctx context.Context, msg string, fields ...log.Field)

+ func (c *Connector) LogError(ctx context.Context, msg string, fields ...log.Field)

+ func (c *Connector) LogInfo(ctx context.Context, msg string, fields ...log.Field)

+ func (c *Connector) LogWarn(ctx context.Context, msg string, fields ...log.Field)

+ func (c *Connector) MustReadResFile(name string) []byte

+ func (c *Connector) MustReadResTextFile(name string) string

+ func (c *Connector) Now(ctx context.Context) time.Time

+ func (c *Connector) NowX(ctx context.Context) timex.Timex

+ func (c *Connector) ObserveMetric(name string, val float64, labels ...string) error

+ func (c *Connector) POST(ctx context.Context, url string, body any) (*http.Response, error)

+ func (c *Connector) Parallel(jobs ...func() (err error)) error

+ func (c *Connector) Plane() string

+ func (c *Connector) Publish(ctx context.Context, options ...pub.Option) <-chan *pub.Response

+ func (c *Connector) ReadResFile(name string) ([]byte, error)

+ func (c *Connector) ReadResTextFile(name string) (string, error)

+ func (c *Connector) Request(ctx context.Context, options ...pub.Option) (*http.Response, error)

+ func (c *Connector) ResFS() service.FS

+ func (c *Connector) ResetConfig(name string) error

+ func (c *Connector) ServeResFile(name string, w http.ResponseWriter, r *http.Request) error

+ func (c *Connector) SetConfig(name string, value any) error

+ func (c *Connector) SetDeployment(deployment string) error

+ func (c *Connector) SetDescription(description string) error

+ func (c *Connector) SetHostname(hostname string) error

+ func (c *Connector) SetLocality(locality string) error

+ func (c *Connector) SetOnConfigChanged(handler service.ConfigChangedHandler) error

+ func (c *Connector) SetOnShutdown(handler service.ShutdownHandler) error

+ func (c *Connector) SetOnStartup(handler service.StartupHandler) error

+ func (c *Connector) SetPlane(plane string) error

+ func (c *Connector) SetResFS(fs service.FS) error

+ func (c *Connector) SetResFSDir(directoryPath string) error

+ func (c *Connector) SetVersion(version int) error

+ func (c *Connector) Shutdown() (err error)

+ func (c *Connector) Span(ctx context.Context) trc.Span

+ func (c *Connector) StartSpan(ctx context.Context, spanName string, opts ...trc.Option) (context.Context, trc.Span)

+ func (c *Connector) StartTicker(name string, interval time.Duration, handler service.TickerHandler) error

+ func (c *Connector) Startup() (err error)

+ func (c *Connector) Subscribe(method string, path string, handler sub.HTTPHandler, options ...sub.Option) error

+ func (c *Connector) Unsubscribe(method string, path string) error

+ func (c *Connector) Version() int

+ type HTTPHandler = sub.HTTPHandler