queue

Documentation

Index

• Variables
• type PolicyQueueHandle
• type Queue
  • func (c *Queue[T]) List() (ret []T)
  • func (c *Queue[T]) Pop() (T, bool)
  • func (c *Queue[T]) Push(item T) (ok bool)
• type TaskQueueHandle

Variables

var PolicyQueue = &Queue[PolicyQueueHandle]{
	queue: queue.New(),
}

PolicyQueue 存放待处理policy队列

var TaskQueue = &Queue[TaskQueueHandle]{
	queue: queue.New(),
}

Types

type PolicyQueueHandle

type PolicyQueueHandle struct {
	ID       uint   `json:"id"`
	HandleID string `json:"handle_id"`
}

type Queue

type Queue[T PolicyQueueHandle | TaskQueueHandle] struct {
	// contains filtered or unexported fields
}

func (*Queue[T]) List

func (c *Queue[T]) List() (ret []T)

func (*Queue[T]) Pop

func (c *Queue[T]) Pop() (T, bool)

func (*Queue[T]) Push

func (c *Queue[T]) Push(item T) (ok bool)

type TaskQueueHandle

type TaskQueueHandle struct {
	ID       uint   `json:"id"`
	PolicyID uint   `json:"policy_id"`
	HandleID string `json:"handle_id"`
}