queue

Documentation

Index

• type Queue
  • func New(qt QueueType, cfg any) (q *Queue, err error)
  • func (q *Queue) Consume(cdto chan<- QueueDto) error
  • func (q *Queue) Publish(body []byte) error
• type QueueConnection
• type QueueDto
  • func (q *QueueDto) FromJson(b []byte) error
  • func (q *QueueDto) ToJson() ([]byte, error)
• type QueueType
• type RabbitConnection
  • func (rc *RabbitConnection) Consume(cdto chan<- QueueDto) error
  • func (rc *RabbitConnection) Publish(body []byte) error
• type RabbitMQConfig

Types

type Queue

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

func New

func New(qt QueueType, cfg any) (q *Queue, err error)

func (*Queue) Consume

func (q *Queue) Consume(cdto chan<- QueueDto) error

func (*Queue) Publish

func (q *Queue) Publish(body []byte) error

type QueueConnection

type QueueConnection interface {
	Publish(body []byte) error
	Consume(chan<- QueueDto) error
}

type QueueDto

type QueueDto struct {
	Filename string `json:"filename"`
	Path     string `json:"path"`
	ID       int    `json:"id"`
}

func (*QueueDto) FromJson

func (q *QueueDto) FromJson(b []byte) error

func (*QueueDto) ToJson

func (q *QueueDto) ToJson() ([]byte, error)

type QueueType

type QueueType int

const (
	RabbitMQ QueueType = iota
)

type RabbitConnection

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

func (*RabbitConnection) Consume

func (rc *RabbitConnection) Consume(cdto chan<- QueueDto) error

func (*RabbitConnection) Publish

func (rc *RabbitConnection) Publish(body []byte) error

type RabbitMQConfig

type RabbitMQConfig struct {
	URL       string
	TopicName string
	Timeout   time.Duration
}