queue

Documentation

Index

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

Constants

const HoldingElements = 10000

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)