Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  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
- API
  
  Reference documentation for the pkg.go.dev API
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

services

package module

Go to main page

Versions in this module

v0

v0.1.0

Jul 13, 2021

Changes in this version

+ var DefaultSignals = []os.Signal

+ var ErrAlreadyListening = errors.New("service already listening")

+ type ManagerOption = func(*ResourceStarter)

+ func WithReporter(reporter Reporter) ManagerOption

+ type ResourceService interface

+ Start func(ctx context.Context) error

+ Stop func(ctx context.Context) error

+ type ResourceServiceRetrier struct

+ func (retrier *ResourceServiceRetrier) Name() string

+ func (retrier *ResourceServiceRetrier) Start(ctx context.Context) error

+ func (retrier *ResourceServiceRetrier) Stop(ctx context.Context) error

+ type ResourceStarter struct

+ func NewManager(opts ...ManagerOption) *ResourceStarter

+ func (starter *ResourceStarter) Start(ctx context.Context, services ...ResourceService) (errResult error)

+ func (starter *ResourceStarter) Stop(ctx context.Context) (errResult error)

+ func (starter *ResourceStarter) WithReporter(reporter Reporter) *ResourceStarter

type RetrierBuilder

+ func (builder *RetrierBuilder) Backoff(value backoff.BackOff) *RetrierBuilder

+ type ServerService interface

+ Close func(ctx context.Context) error

+ Listen func(ctx context.Context) error

+ type ServerStarter struct

+ func NewServerStarter(listener signals.Listener) ServerStarter

+ func (starter *ServerStarter) Close(_ context.Context) error

+ func (starter *ServerStarter) Listen(ctx context.Context, services ...ServerService) []error

v0.0.1

Mar 2, 2021

Changes in this version

+ var ErrExhaustedAttempts = errors.New("exhausted attempts")

+ var ErrNotStartable = errors.New("service is not Startable")

+ var ErrTimeout = errors.New("timeout")

+ func Bootstrap(req BootstrapRequest)

+ type BootstrapRequest struct

+ Run func()

+ Services []Service

+ SetupStarter func(*Starter)

+ Signals []os.Signal

+ type Configurable interface

+ Load func() error

+ type Reporter interface

+ AfterLoad func(Configurable, error)

+ AfterStart func(Service, error)

+ AfterStop func(Service, error)

+ BeforeLoad func(Configurable)

+ BeforeStart func(Service)

+ BeforeStop func(Service)

+ SignalReceived func(os.Signal)

+ type RetrierBuilder struct

+ func Retrier() *RetrierBuilder

+ func (builder *RetrierBuilder) Build(service Service) Service

+ func (builder *RetrierBuilder) Reporter(value RetrierReporter) *RetrierBuilder

+ func (builder *RetrierBuilder) Timeout(value time.Duration) *RetrierBuilder

+ func (builder *RetrierBuilder) Tries(value int) *RetrierBuilder

+ func (builder *RetrierBuilder) WaitBetweenTries(value time.Duration) *RetrierBuilder

+ type RetrierReporter interface

+ AfterGiveUp func(Service, int, error)

+ BeforeRetry func(Service, int)

+ type Service interface

+ Name func() string

+ Stop func() error

+ type ServiceRetrier struct

+ func (retrier *ServiceRetrier) Name() string

+ func (retrier *ServiceRetrier) StartWithContext(ctx context.Context) error

+ func (retrier *ServiceRetrier) Stop() error

+ type Startable interface

+ Start func() error

+ type StartableWithContext interface

+ StartWithContext func(context.Context) error

+ type Starter struct

+ func NewStarter(services ...Service) *Starter

+ func (s *Starter) ListenSignals(listener signals.Listener) error

+ func (s *Starter) Start() error

+ func (s *Starter) Stop() error

+ func (s *Starter) WithReporter(reporter Reporter) *Starter

+ func (s *Starter) WithStartingChannel(ch chan bool) *Starter