queue

Documentation

Index

• func NewQueue(r *Repository)
• func SqsSendMessage(ctx context.Context, app config.AppConfig, ...) error
• type Repository
  • func NewRepo(a *config.AppConfig) *Repository

Functions

func NewQueue

func NewQueue(r *Repository)

func SqsSendMessage

func SqsSendMessage(
	ctx context.Context,
	app config.AppConfig,
	queueUrl,
	messageGroupId,
	data string,
) error

Types

type Repository

type Repository struct {
	Svc     *sqs.Client
	SvcLock sync.Mutex
}

var Repo *Repository

func NewRepo

func NewRepo(a *config.AppConfig) *Repository