queue

Documentation

Index

• Variables
• func NewPressureQueue(keyFunc KeyFunc) *pressurequeue
• type ActionType
• type Event
  • func (event Event) GetReputCount() int
• type EventQueue
• type KeyFunc

Variables

var ErrQueueClosed = errors.New("queue is closed")

Functions

func NewPressureQueue

func NewPressureQueue(keyFunc KeyFunc) *pressurequeue

Types

type ActionType

type ActionType string

const (
	Added   ActionType = "Added"
	Updated ActionType = "Updated"
	Deleted ActionType = "Deleted"
)

type Event

type Event struct {
	Action ActionType
	Object interface{}
	// contains filtered or unexported fields
}

func (Event) GetReputCount

func (event Event) GetReputCount() int

type EventQueue

type EventQueue interface {
	Add(obj interface{}) error
	Update(obj interface{}) error
	Delete(obj interface{}) error

	Pop() (*Event, error)
	Done(event *Event) error

	Len() int
	DiscardAndRetain(retain int) bool

	Close()
}

type KeyFunc

type KeyFunc func(obj interface{}) (string, error)