queue

type Consumer interface {
	StartListen(ctx context.Context, handler HandlerFunc)
}

type HandlerFunc func(ctx context.Context, messages []*Message) error

type Message struct {
	Value        []byte
	Time         time.Time
	WorkspaceID  string
	TraceContext map[string]string
}

type Producer interface {
	Enqueue(ctx context.Context, message *Message) error
}

type Queue interface {
	Producer
	Consumer
	Stats() map[string]interface{}
}