server

Documentation

Index

• Constants
• func ConsumeMessage(ctx context.Context, d rabbitmq.RabbitDelivery) error
• func Run(ctx context.Context)
• func RunMigrations(log logger.Logger, db *sql.DB, databaseName string) error

Constants

const (
	RABBITMQ_QUEUE_NAME = "test_queue"

	DB_DRIVER_NAME = "postgres"
)

Functions

func ConsumeMessage

func ConsumeMessage(ctx context.Context, d rabbitmq.RabbitDelivery) error

Example of consume You can provide any logic in this callback for each received message

Requeue received message If it was requeued already - just Ack this

func Run

func Run(ctx context.Context)

func RunMigrations

func RunMigrations(log logger.Logger, db *sql.DB, databaseName string) error