queue

package
v0.1.5 Latest Latest
Warning

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

Go to latest
Published: Jan 20, 2024 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source
const HoldingElements = 10000

Variables

This section is empty.

Functions

This section is empty.

Types

type CheckableZero

type CheckableZero interface {
	IsZero() bool
}

type Queue

type Queue[T CheckableZero] interface {
	SendMessage(data T) error
	ReceiveMessage() (T, error)
	CreateReceiver() <-chan T
	AddReceiver() <-chan T
}

func CreateQueue

func CreateQueue[T CheckableZero](sess *session.Session, cfgs *aws.Config, queueName string) (Queue[T], error)

Jump to

Keyboard shortcuts

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