slotctx

package

v5.1.0+incompatible Latest Latest Go to latest Published: Dec 11, 2019 License: BSD-3-Clause, BSD-3-Clause Imports: 2 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

PrioritySlot is a slot in which only one context can thrive.

func NewPriority() *PrioritySlot

func (s *PrioritySlot) Shutdown()

Shutdown disables the slot forever.

func (s *PrioritySlot) Stop()

Stop cancels the running task if there is one.

func (s *PrioritySlot) Use(ctx context.Context, priority int) context.Context

Use derives a new context. Whichever of the argument and the incumbent are lower priority is canceled. In a tie the incumbent is canceled.

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

Slot is a slot in which only one context can thrive.

func New() *Slot

func (s *Slot) Stop()

Stop cancels the running task if there is one.

func (s *Slot) Use(ctx context.Context) context.Context

Use derives a context bound to the slot. Cancels any context previously bound to the slot.