types

type Consumer interface {
	Write(ctx context.Context, p []byte) error
}

type ConsumerType string

type Message struct {
	Q string
	P []byte
}

type Poller interface {
	Poll(ctx context.Context) <-chan time.Time
}

type Producer interface {
	Reader
	Subscriber
	Poller
}

type Queue struct {
	Name     string
	Consumer Consumer
	Meta     QueueMeta
}

type QueueDb struct {
	Queue    string
	Consumer string
	Meta     QueueMeta
}

type QueueEventBuilder interface {
	CreateQueueEvent(string, []byte) eventbus.Event
}

type QueueFilter struct {
	Query   string
	Deleted filter.State

	filter.Sorting
	filter.Paging
}

type QueueMessage struct {
	Queue   string
	Payload []byte
}

type QueueMessageSet []QueueMessage

type QueueMeta struct {
	PollDelay      *time.Duration `json:"poll_delay"`
	DispatchEvents bool           `json:"dispatch_events"`
}

type QueueServicer interface {
	QueueStorer
	QueueEventBuilder
}

type QueueSet map[string]*Queue

type QueueStorer interface {
	SearchQueues(context.Context, QueueFilter) ([]QueueDb, QueueFilter, error)
	CreateQueueMessage(context.Context, QueueMessage) error
	ProcessQueueMessage(context.Context, uint64, QueueMessage) error
}

type Reader interface {
	Read(ctx context.Context) ([]QueueMessage, error)
}

type Subscriber interface {
	Subscribe(ctx context.Context) <-chan interface{}
}