dbqueue

Documentation

Index

• type DBQueue
  • func New(dialector gorm.Dialector) (*DBQueue, error)
  • func NewMySQL(dsn string) (*DBQueue, error)
  • func NewPostgreSQL(dsn string) (*DBQueue, error)
  • func NewSQLite(dsn string) (*DBQueue, error)
  • func (s *DBQueue) ChangeMessageVisibility(queue string, visibilityTimeout time.Duration, id uint) error
  • func (s *DBQueue) ChangeMessageVisibilityBatch(queue string, visibilityTimeout time.Duration, ids []uint) error
  • func (s *DBQueue) CreateQueue(name string) error
  • func (s *DBQueue) DeleteMessage(queue string, id uint) error
  • func (s *DBQueue) DeleteMessageBatch(queue string, ids []uint) error
  • func (s *DBQueue) DeleteQueue(name string) error
  • func (s *DBQueue) PurgeQueue(queue string) error
  • func (s *DBQueue) ReceiveMessage(queue string, fun func(message Message), options ReceiveMessageOptions) error
  • func (s *DBQueue) SendMessage(queue string, message *Message) error
  • func (s *DBQueue) SendMessageBatch(queue string, messages []*Message) error
• type Message
• type ReceiveMessageOptions
  • func (r *ReceiveMessageOptions) GetMaxNumberOfMessages() int
  • func (r *ReceiveMessageOptions) GetVisibilityTimeout() time.Duration
  • func (r *ReceiveMessageOptions) GetWaitTime() time.Duration

Types

type DBQueue

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

func New

func New(dialector gorm.Dialector) (*DBQueue, error)

func NewMySQL

func NewMySQL(dsn string) (*DBQueue, error)

func NewPostgreSQL

func NewPostgreSQL(dsn string) (*DBQueue, error)

func NewSQLite

func NewSQLite(dsn string) (*DBQueue, error)

func (*DBQueue) ChangeMessageVisibility

func (s *DBQueue) ChangeMessageVisibility(queue string, visibilityTimeout time.Duration, id uint) error

func (*DBQueue) ChangeMessageVisibilityBatch

func (s *DBQueue) ChangeMessageVisibilityBatch(queue string, visibilityTimeout time.Duration, ids []uint) error

func (*DBQueue) CreateQueue

func (s *DBQueue) CreateQueue(name string) error

func (*DBQueue) DeleteMessage

func (s *DBQueue) DeleteMessage(queue string, id uint) error

func (*DBQueue) DeleteMessageBatch

func (s *DBQueue) DeleteMessageBatch(queue string, ids []uint) error

func (*DBQueue) DeleteQueue

func (s *DBQueue) DeleteQueue(name string) error

func (*DBQueue) PurgeQueue

func (s *DBQueue) PurgeQueue(queue string) error

func (*DBQueue) ReceiveMessage

func (s *DBQueue) ReceiveMessage(queue string, fun func(message Message), options ReceiveMessageOptions) error

func (*DBQueue) SendMessage

func (s *DBQueue) SendMessage(queue string, message *Message) error

func (*DBQueue) SendMessageBatch

func (s *DBQueue) SendMessageBatch(queue string, messages []*Message) error

type Message

type Message struct {
	ID              uint   `gorm:"primarykey"`
	DeduplicationID string `gorm:"unique"`
	Payload         []byte
	Priority        uint32
	Retrieval       int32
	VisibleAfter    int64
	CreatedAt       int64
}

type ReceiveMessageOptions

type ReceiveMessageOptions struct {
	MaxNumberOfMessages int
	VisibilityTimeout   time.Duration
	WaitTime            time.Duration
}

func (*ReceiveMessageOptions) GetMaxNumberOfMessages

func (r *ReceiveMessageOptions) GetMaxNumberOfMessages() int

func (*ReceiveMessageOptions) GetVisibilityTimeout

func (r *ReceiveMessageOptions) GetVisibilityTimeout() time.Duration

func (*ReceiveMessageOptions) GetWaitTime

func (r *ReceiveMessageOptions) GetWaitTime() time.Duration