queue

package

v0.4.0-rc.4 Latest Latest Go to latest Published: Aug 2, 2025 License: Apache-2.0 Imports: 14 Imported by: 0

Details

This section is empty.

View Source

var (
	ErrZeroValueNotSupported = errors.New("zero value not supported")
)

This section is empty.

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

func NewSLOQueue(provider types.RouterProviderFunc, modelName string) (router *SLOQueue, err error)

func (q *SLOQueue) Dequeue(ts time.Time) (*types.RoutingContext, error)

func (q *SLOQueue) Enqueue(ctx *types.RoutingContext, currentTime time.Time) error

func (q *SLOQueue) LastError() error

func (q *SLOQueue) Len() (total int)

func (q *SLOQueue) Peek(currentTime time.Time, pods types.PodList) (*types.RoutingContext, error)

func (q *SLOQueue) Route(ctx *types.RoutingContext, pods types.PodList) (string, error)

type SimpleQueue[V comparable] struct {
	// contains filtered or unexported fields
}

func NewSimpleQueue[V comparable](initialCapacity int) *SimpleQueue[V]

func (q *SimpleQueue[V]) Cap() int

func (q *SimpleQueue[V]) Dequeue(_ time.Time) (c V, err error)

func (q *SimpleQueue[V]) Enqueue(value V, _ time.Time) error

func (q *SimpleQueue[V]) Len() int

func (q *SimpleQueue[V]) Peek(_ time.Time, _ types.PodList) (c V, err error)