hosting

Documentation

Index

• Constants
• func RunWithInterrupts(ctx context.Context, host *Host) error
• type Host
  • func (host *Host) Run(ctx context.Context, serviceErrors chan<- LifecycleMessage) error
  • func (host *Host) RunAsync(ctx context.Context) (<-chan error, <-chan LifecycleMessage)
• type LifecycleMessage
• type Service

Constants

const ShutdownTimeout = time.Second * 10

Functions

func RunWithInterrupts

func RunWithInterrupts(ctx context.Context, host *Host) error

RunWithInterrupts runs the given host, and handles shutdown gracefully when a console interrupt is received.

Types

type Host

type Host struct {
	// Slice of services to run. Started in order.
	Services []Service

	// LoggerValues is key-value-pairs passed to .WithValues to initialize the logger for the host.
	LoggerValues []any

	// TimeoutFunc allows you to control the timeout behavior for testing
	TimeoutFunc func()
}

Host manages the lifetimes and starting of Services.

func (*Host) Run

func (host *Host) Run(ctx context.Context, serviceErrors chan<- LifecycleMessage) error

Run starts all services in the host, waits for them to finish, and returns an error if any of them fail or if a timeout is reached.

func (*Host) RunAsync

func (host *Host) RunAsync(ctx context.Context) (<-chan error, <-chan LifecycleMessage)

RunAsync runs the host's services asynchronously and returns two channels, one for errors and one for lifecycle messages, which can be used to monitor the progress of the services.

type LifecycleMessage

type LifecycleMessage struct {
	Name string
	Err  error
}

LifecycleMessage is a message returned when a service terminates.

type Service

type Service interface {
	// Name returns the name of the service.
	Name() string

	// Run runs the service as a blocking operation.
	Run(ctx context.Context) error
}

Service is an abstraction for a long-running subsystem of the RP.