queue

Documentation

Index

• Constants
• type QueueAdapter
  • func NewQueueAdapter() (*QueueAdapter, error)
  • func (q *QueueAdapter) PublishOnUserUpdated(msg string) error

Constants

const UserUpdatedChannel = "user_updates"

Types

type QueueAdapter

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

func NewQueueAdapter

func NewQueueAdapter() (*QueueAdapter, error)

func (*QueueAdapter) PublishOnUserUpdated

func (q *QueueAdapter) PublishOnUserUpdated(msg string) error