congestioncontrol

Documentation

Index

• Variables
• func WithSchedulerOptions(opts ...options.Option[scheduler.Scheduler]) options.Option[CongestionControl]
• type CongestionControl
  • func New(opts ...options.Option[CongestionControl]) *CongestionControl
  • func (c *CongestionControl) Block(id models.BlockID) (block *scheduler.Block, exists bool)
  • func (c *CongestionControl) LinkTo(engine *engine.Engine)
  • func (c *CongestionControl) Scheduler() *scheduler.Scheduler
  • func (c *CongestionControl) Shutdown()
• type Events

Variables

var NewEvents = event.CreateGroupConstructor(func() (newEvents *Events) {
	return &Events{
		Scheduler: scheduler.NewEvents(),
	}
})

NewEvents contains the constructor of the Events object (it is generated by a generic factory).

Functions

func WithSchedulerOptions

func WithSchedulerOptions(opts ...options.Option[scheduler.Scheduler]) options.Option[CongestionControl]

Types

type CongestionControl

type CongestionControl struct {
	Events *Events
	// contains filtered or unexported fields
}

func New

func New(opts ...options.Option[CongestionControl]) *CongestionControl

func (*CongestionControl) Block

func (c *CongestionControl) Block(id models.BlockID) (block *scheduler.Block, exists bool)

func (*CongestionControl) LinkTo

func (c *CongestionControl) LinkTo(engine *engine.Engine)

func (*CongestionControl) Scheduler

func (c *CongestionControl) Scheduler() *scheduler.Scheduler

func (*CongestionControl) Shutdown

func (c *CongestionControl) Shutdown()

type Events

type Events struct {
	Scheduler *scheduler.Events

	event.Group[Events, *Events]
}