provider

Documentation

Index

• Constants
• Variables
• type FileQueue
  • func NewFileQueue[T any](dir string, id string) (*FileQueue[T], error)
  • func (f *FileQueue[T]) Add(data T) error
  • func (f *FileQueue[T]) Remove() ([]T, error)
• type MemBasedQueue
  • func NewMemBasedQueue[T any]() (*MemBasedQueue[T], error)
  • func (f *MemBasedQueue[T]) Add(data T) error
  • func (f *MemBasedQueue[T]) Remove() ([]T, error)
• type Queue

Constants

const MaxItems = 100

Variables

var ErrQueueEmpty = errors.New("queue empty")

Types

type FileQueue

type FileQueue[T any] struct {
	// contains filtered or unexported fields
}

func NewFileQueue

func NewFileQueue[T any](dir string, id string) (*FileQueue[T], error)

func (*FileQueue[T]) Add

func (f *FileQueue[T]) Add(data T) error

func (*FileQueue[T]) Remove

func (f *FileQueue[T]) Remove() ([]T, error)

type MemBasedQueue

type MemBasedQueue[T any] struct {
	// contains filtered or unexported fields
}

func NewMemBasedQueue

func NewMemBasedQueue[T any]() (*MemBasedQueue[T], error)

func (*MemBasedQueue[T]) Add

func (f *MemBasedQueue[T]) Add(data T) error

func (*MemBasedQueue[T]) Remove

func (f *MemBasedQueue[T]) Remove() ([]T, error)

type Queue

type Queue[T any] interface {
	Add(data T) error
	Remove() ([]T, error)
}