supervisor

Documentation

Index

• Constants
• type Config
• type Delayed
  • func NewDelayed(service Service, delay time.Duration) *Delayed
  • func (d *Delayed) Start(ctx context.Context) error
  • func (d *Delayed) Wait() <-chan error
• type Service
• type Supervisor
  • func New(logger log.Logger) *Supervisor
  • func (s *Supervisor) Start(ctx context.Context) error
  • func (s *Supervisor) Wait() <-chan error
  • func (s *Supervisor) Watch(services ...Service)

Constants

const LoggerTag = "SUPERVISOR"

Types

type Config

type Config interface {
	Services(log.Logger) (Service, error)
}

type Delayed

type Delayed struct {
	// contains filtered or unexported fields
}

Delayed is a service that delays the start of another service.

func NewDelayed

func NewDelayed(service Service, delay time.Duration) *Delayed

NewDelayed returns a new Delayed service.

func (*Delayed) Start

func (d *Delayed) Start(ctx context.Context) error

Start implements the Service interface.

func (*Delayed) Wait

func (d *Delayed) Wait() <-chan error

Wait implements the Service interface.

type Service

type Service interface {
	// Start starts the service.
	Start(ctx context.Context) error

	// Wait returns a channel that is blocked while service is running.
	// When the service is stopped, the channel will be closed. If an error
	// occurs, an error will be sent to the channel before closing it.
	Wait() <-chan error
}

Service that could be managed by Supervisor.

type Supervisor

type Supervisor struct {
	// contains filtered or unexported fields
}

Supervisor manages long-running services that implement the Service interface. If any of the managed services fail, all other services are stopped. This ensures that all services are running or none.

func New

func New(logger log.Logger) *Supervisor

New returns a new instance of *Supervisor.

func (*Supervisor) Start

func (s *Supervisor) Start(ctx context.Context) error

Start starts all watched services. It can be invoked only once, otherwise it panics.

func (*Supervisor) Wait

func (s *Supervisor) Wait() <-chan error

Wait returns a channel that is blocked until at least one service is running. When all services are stopped, the channel will be closed. If an error occurs in any of the services, it will be sent to the channel before closing it. If multiple service crash, only the first error is returned.

func (*Supervisor) Watch

func (s *Supervisor) Watch(services ...Service)

Watch add one or more services to a supervisor. Services must be added before invoking the Start method, otherwise it panics.