fiber

Documentation

Index

• type Fiber
• type Scheduler
  • func NewScheduler() *Scheduler
  • func (s *Scheduler) Block(ctx context.Context, fn func(ctx context.Context))
  • func (s *Scheduler) CancelBlocked()
  • func (s *Scheduler) ForEachFiber(h func(fiber *Fiber))
  • func (s *Scheduler) NewFiber(fn func()) *Fiber
  • func (s *Scheduler) Run(main *Fiber)
  • func (s *Scheduler) SwitchToNew(f *Fiber)

Types

type Fiber

type Fiber struct {
	Data interface{}
	// contains filtered or unexported fields
}

type Scheduler

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

func NewScheduler

func NewScheduler() *Scheduler

func (*Scheduler) Block

func (s *Scheduler) Block(ctx context.Context, fn func(ctx context.Context))

func (*Scheduler) CancelBlocked

func (s *Scheduler) CancelBlocked()

func (*Scheduler) ForEachFiber

func (s *Scheduler) ForEachFiber(h func(fiber *Fiber))

func (*Scheduler) NewFiber

func (s *Scheduler) NewFiber(fn func()) *Fiber

func (*Scheduler) Run

func (s *Scheduler) Run(main *Fiber)

func (*Scheduler) SwitchToNew

func (s *Scheduler) SwitchToNew(f *Fiber)