ds

package
v0.0.0-...-6438891 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 19, 2023 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type EventQueue

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

func NewEventQueue

func NewEventQueue() *EventQueue

func (*EventQueue) Close

func (q *EventQueue) Close()

func (*EventQueue) Read

func (q *EventQueue) Read() any

func (*EventQueue) Write

func (q *EventQueue) Write(item any)

type Job

type Job struct {
	Key        string
	Expiration time.Time
}

func NewJob

func NewJob(key string, expiration time.Time) *Job

type TimeHeap

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

func NewTimeHeap

func NewTimeHeap() *TimeHeap

func (*TimeHeap) Get

func (th *TimeHeap) Get(key string) *Job

func (*TimeHeap) IsEmpty

func (th *TimeHeap) IsEmpty() bool

func (*TimeHeap) Peek

func (th *TimeHeap) Peek() *Job

func (*TimeHeap) Pop

func (th *TimeHeap) Pop() *Job

func (*TimeHeap) Push

func (th *TimeHeap) Push(job *Job)

func (*TimeHeap) Remove

func (th *TimeHeap) Remove(key string)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL