queue

Documentation

Index

• type Info
• type JSON
• type MemoryQueue
  • func NewMemoryQueue() *MemoryQueue
  • func (m *MemoryQueue) Read() (JSON, error)
  • func (m *MemoryQueue) Write(item JSON) error
• type MemoryService
  • func NewMemoryService() *MemoryService
  • func (m *MemoryService) CreateQueue(name string) (Queue, error)
  • func (m *MemoryService) DeleteQueue(name string) error
  • func (m *MemoryService) GetQueue(name string) (Queue, error)
  • func (m *MemoryService) ListQueues() ([]string, error)
• type Queue
• type Service

Types

type Info

type Info struct {
	Name  string
	Queue Queue
}

type JSON

type JSON = json.RawMessage

type MemoryQueue

type MemoryQueue struct {
	Queue chan JSON
}

func NewMemoryQueue

func NewMemoryQueue() *MemoryQueue

func (*MemoryQueue) Read

func (m *MemoryQueue) Read() (JSON, error)

func (*MemoryQueue) Write

func (m *MemoryQueue) Write(item JSON) error

type MemoryService

type MemoryService struct {
	Queues      map[string]Queue // todo: replace by sync.Map
	QueuesMutex sync.RWMutex
}

func NewMemoryService

func NewMemoryService() *MemoryService

func (*MemoryService) CreateQueue

func (m *MemoryService) CreateQueue(name string) (Queue, error)

func (*MemoryService) DeleteQueue

func (m *MemoryService) DeleteQueue(name string) error

func (*MemoryService) GetQueue

func (m *MemoryService) GetQueue(name string) (Queue, error)

func (*MemoryService) ListQueues

func (m *MemoryService) ListQueues() ([]string, error)

type Queue

type Queue interface {
	Write(JSON) error
	Read() (JSON, error)
}

type Service

type Service interface {
	GetQueue(name string) (Queue, error)
	ListQueues() ([]string, error)
	CreateQueue(name string) (Queue, error)
	DeleteQueue(name string) error
}