Versions in this module Expand all Collapse all v0 v0.0.3 Nov 25, 2022 v0.0.1 Nov 25, 2022 Changes in this version + type Info struct + Name string + Queue Queue + type JSON = json.RawMessage + type MemoryQueue struct + Queue chan JSON + func NewMemoryQueue() *MemoryQueue + func (m *MemoryQueue) Read() (JSON, error) + func (m *MemoryQueue) Write(item JSON) error + type MemoryService struct + Queues map[string]Queue + QueuesMutex sync.RWMutex + 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 interface + Read func() (JSON, error) + Write func(JSON) error + type Service interface + CreateQueue func(name string) (Queue, error) + DeleteQueue func(name string) error + GetQueue func(name string) (Queue, error) + ListQueues func() ([]string, error)
Go to main page