queue

type Callback func(topic, message string)

type Consumer interface {
	Consumer(ctx context.Context, callback Callback, topics ...string)
	Close()
}

type ConsumerWithRedis struct {
	// contains filtered or unexported fields
}

type PublishWithRedis struct {
	// contains filtered or unexported fields
}

type Publisher interface {
	Publish(ctx context.Context, topic string, message interface{})
}