restart

Documentation

Index

• type Restartable
• type Startable
• type Starter
  • func NewStarter(components ...Startable) Starter
• type Stoppable
• type Stopper
  • func NewParallelStopper(components ...Stoppable) Stopper
  • func NewSerialStopper(components ...Stoppable) Stopper

Types

type Restartable

type Restartable interface {
	Startable
	Stoppable
}

Restartable represents a startable and stopable object

type Startable

type Startable interface {
	Start()
}

Startable represents a startable object

type Starter

type Starter interface {
	Startable
	Add(components ...Startable)
}

Starter starts a group of startable objects from a data pipeline

func NewStarter

func NewStarter(components ...Startable) Starter

NewStarter returns a new starter

type Stoppable

type Stoppable interface {
	Stop()
}

Stoppable represents a stoppable object

type Stopper

type Stopper interface {
	Stoppable
	Add(components ...Stoppable)
}

Stopper stops a group of stoppable objects from a data pipeline

func NewParallelStopper

func NewParallelStopper(components ...Stoppable) Stopper

NewParallelStopper returns a new parallelStopper

func NewSerialStopper

func NewSerialStopper(components ...Stoppable) Stopper

NewSerialStopper returns a new serialGroup