utils

Documentation

Index

• Variables
• func AwaitConnection(dialer func() (interface{}, error), timeout time.Duration) (interface{}, error)
• func DeclareQueue(conn *amqp.Connection, queueName string) error
• func MakeRabbitChannel(config rabbit.RabbitConfig, port string) (*amqp.Channel, error)
• func PublishMessage(body []byte, c *amqp.Channel, queue string, assert *assert.Assertions) bool
• func WaitRabbit(rabbitCfg rabbit.RabbitConfig, port string, timeout time.Duration) (*amqp.Connection, error)
• type TimeoutRetryer
  • func NewRetryer(f func() (interface{}, error), deadlineTimeout time.Duration) *TimeoutRetryer
  • func (r *TimeoutRetryer) Do() (interface{}, error)

Variables

var (
	ErrDeadlineExceeded = errors.New("deadline exceeded")
)

Functions

func AwaitConnection

func AwaitConnection(dialer func() (interface{}, error), timeout time.Duration) (interface{}, error)

func DeclareQueue

func DeclareQueue(conn *amqp.Connection, queueName string) error

func MakeRabbitChannel

func MakeRabbitChannel(config rabbit.RabbitConfig, port string) (*amqp.Channel, error)

func PublishMessage

func PublishMessage(body []byte, c *amqp.Channel, queue string, assert *assert.Assertions) bool

func WaitRabbit

func WaitRabbit(rabbitCfg rabbit.RabbitConfig, port string, timeout time.Duration) (*amqp.Connection, error)

Types

type TimeoutRetryer

type TimeoutRetryer struct {
	DeadlineTimeout     time.Duration
	AttemptTimeout      time.Duration
	AttemptErrorHanlder func(err error)
	// contains filtered or unexported fields
}

func NewRetryer

func NewRetryer(f func() (interface{}, error), deadlineTimeout time.Duration) *TimeoutRetryer

func (*TimeoutRetryer) Do

func (r *TimeoutRetryer) Do() (interface{}, error)