xbspvs

Documentation

Index

• func GetRootContext() context.Context
• func GetWaitGroup() *sync.WaitGroup
• func WithWaitGroup(operate Operate, args ...any)
• type Daemon
  • func (daemon *Daemon) String() string
• type Operate
• type Process
• type ServerProcess
  • func (process *ServerProcess) SetServer(server *http.Server)
  • func (process *ServerProcess) Setup() error
  • func (process *ServerProcess) Start(ctx context.Context) error
• type Supervisor
  • func GetSupervisor(options *SupervisorOptions) *Supervisor
  • func (supervisor *Supervisor) Handle(process Process)
  • func (supervisor *Supervisor) RunForever()
• type SupervisorOptions

Functions

func GetRootContext

func GetRootContext() context.Context

func GetWaitGroup

func GetWaitGroup() *sync.WaitGroup

func WithWaitGroup

func WithWaitGroup(operate Operate, args ...any)

Types

type Daemon

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

func (*Daemon) String

func (daemon *Daemon) String() string

type Operate

type Operate = func(args ...any)

type Process

type Process interface {
	Setup() error
	Start(ctx context.Context) error
}

type ServerProcess

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

func (*ServerProcess) SetServer

func (process *ServerProcess) SetServer(server *http.Server)

func (*ServerProcess) Setup

func (process *ServerProcess) Setup() error

func (*ServerProcess) Start

func (process *ServerProcess) Start(ctx context.Context) error

type Supervisor

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

func GetSupervisor

func GetSupervisor(options *SupervisorOptions) *Supervisor

func (*Supervisor) Handle

func (supervisor *Supervisor) Handle(process Process)

func (*Supervisor) RunForever

func (supervisor *Supervisor) RunForever()

type SupervisorOptions

type SupervisorOptions struct {
	GracefulTimeout   *time.Duration
	HeartbeatInterval *time.Duration
}