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

s

package

Go to main page

Versions in this module

v0

v0.5.0

Nov 30, 2023

v0.4.0

May 17, 2023

v0.3.0

Jul 6, 2022

Changes in this version

+ const NodeSepToken

+ var HealthyReport = HealthReport

+ var WithOrder = WithStartOrder

+ func ExplainError(err error) string

+ type BuildNodesFn = func() ([]Node, CleanupResourcesFn, error)

+ func WithNodes(nodes ...Node) BuildNodesFn

+ type CleanupResourcesFn = func() error

+ type DynSupervisor struct

+ func NewDynSupervisor(ctx context.Context, name string, opts ...Opt) (DynSupervisor, error)

+ func (dyn *DynSupervisor) Spawn(nodeFn Node) (func() error, error)

+ func (dyn *DynSupervisor) Terminate() error

+ func (dyn DynSupervisor) GetName() string

+ func (dyn DynSupervisor) Wait() error

+ type ErrKVs interface

+ KVs func() map[string]interface{}

+ type Event struct

+ func (e Event) Err() error

+ func (e Event) GetCreated() time.Time

+ func (e Event) GetNodeTag() c.ChildTag

+ func (e Event) GetProcessRuntimeName() string

+ func (e Event) GetTag() EventTag

+ func (e Event) String() string

+ type EventNotifier func(Event)

+ type EventTag uint32

+ const ProcessCompleted

+ const ProcessFailed

+ const ProcessStartFailed

+ const ProcessStarted

+ const ProcessTerminated

+ func (tag EventTag) String() string

+ type HealthReport struct

+ func (hr HealthReport) GetDelayedRestartProcesses() map[string]bool

+ func (hr HealthReport) GetFailedProcesses() map[string]bool

+ func (hr HealthReport) IsHealthyReport() bool

+ type HealthcheckMonitor struct

+ func NewHealthcheckMonitor(maxAllowedFailures uint32, maxAllowedRestartDuration time.Duration) *HealthcheckMonitor

+ func (h *HealthcheckMonitor) GetHealthReport() HealthReport

+ func (h *HealthcheckMonitor) HandleEvent(ev Event)

+ func (h *HealthcheckMonitor) IsHealthy() bool

+ type Node func(SupervisorSpec) c.ChildSpec

+ func NewDynSubtree(name string, startFn func(context.Context, Spawner) error, spawnerOpts []Opt, ...) Node

+ func NewDynSubtreeWithNotifyStart(name string, runFn func(context.Context, NotifyStartFn, Spawner) error, ...) Node

+ func NewWorker(name string, startFn func(context.Context) error, opts ...c.Opt) Node

+ func NewWorkerWithNotifyStart(name string, startFn func(context.Context, NotifyStartFn) error, opts ...c.Opt) Node

+ func Subtree(subtreeSpec SupervisorSpec, opts ...c.Opt) Node

+ type NotifyStartFn = c.NotifyStartFn

+ type Opt func(*SupervisorSpec)

+ func WithNotifier(en EventNotifier) Opt

+ func WithRestartTolerance(maxErrCount uint32, errWindow time.Duration) Opt

+ func WithStartOrder(o Order) Opt

+ func WithStrategy(s Strategy) Opt

+ type Order uint32

+ const LeftToRight

+ const RightToLeft

+ type RestartToleranceReached struct

+ func NewRestartToleranceReached(tolerance restartTolerance, sourceCh c.Child, sourceErr error, lastErr error) *RestartToleranceReached

+ func (err *RestartToleranceReached) Error() string

+ func (err *RestartToleranceReached) KVs() map[string]interface{}

+ func (err *RestartToleranceReached) Unwrap() error

+ type Spawner interface

+ Spawn func(Node) (func() error, error)

+ type Strategy uint32

+ const OneForAll

+ const OneForOne

+ type Supervisor struct

+ func (sup Supervisor) GetCrashError(block bool) (bool, error)

+ func (sup Supervisor) GetName() string

+ func (sup Supervisor) Terminate() error

+ func (sup Supervisor) Wait() error

+ type SupervisorBuildError struct

+ func (err *SupervisorBuildError) Error() string

+ func (err *SupervisorBuildError) KVs() map[string]interface{}

+ type SupervisorRestartError struct

+ func (err *SupervisorRestartError) Error() string

+ func (err *SupervisorRestartError) KVs() map[string]interface{}

+ type SupervisorSpec struct

+ func NewSupervisorSpec(name string, buildNodes BuildNodesFn, opts ...Opt) SupervisorSpec

+ func (spec SupervisorSpec) GetName() string

+ func (spec SupervisorSpec) Start(startCtx context.Context) (Supervisor, error)

+ type SupervisorStartError struct

+ func (err *SupervisorStartError) Error() string

+ func (err *SupervisorStartError) KVs() map[string]interface{}

+ type SupervisorTerminationError struct

+ func (err *SupervisorTerminationError) Error() string

+ func (err *SupervisorTerminationError) KVs() map[string]interface{}

v0.2.0

Apr 12, 2021