priorityblocker

Documentation

Index

• type Blocker
  • func NewBlocker(ticketChan <-chan struct{}) *Blocker
  • func (b *Blocker) Block(flag string)
  • func (b *Blocker) Close()
  • func (b *Blocker) GetPriority(flag string) Priority
  • func (b *Blocker) Run()
  • func (b *Blocker) SetPriority(flag string, p Priority)
• type Priority

Types

type Blocker

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

Blocker provides a function which can block some process. Unblock strategy bases on Priority. The higher the priority, the earlier it will be unblocked. Unblocking is done by consuming tickets. If ticket chan is nil when new a Blocker, Blocker will keep printing tickets itself.

func NewBlocker

func NewBlocker(ticketChan <-chan struct{}) *Blocker

NewBlocker create a new Blocker instance.

func (*Blocker) Block

func (b *Blocker) Block(flag string)

Block the process, until a ticket with the priority of the flag consumed.

func (*Blocker) Close

func (b *Blocker) Close()

Close the blocker.

func (*Blocker) GetPriority

func (b *Blocker) GetPriority(flag string) Priority

GetPriority query the priority of the flag. If never set, will return PriorityLevel5.

func (*Blocker) Run

func (b *Blocker) Run()

Run start a goroutine to print tickets.

func (*Blocker) SetPriority

func (b *Blocker) SetPriority(flag string, p Priority)

SetPriority set the priority of the flag.

type Priority

type Priority uint8

Priority for blocking with blocker.

const (
	PriorityLevel0 Priority = iota
	PriorityLevel1
	PriorityLevel2
	PriorityLevel3
	PriorityLevel4
	PriorityLevel5
	PriorityLevel6
	PriorityLevel7
	PriorityLevel8
	PriorityLevel9
)