queue

Documentation

Index

• Constants
• func NewJobBuilder(unitType string, granularitySec int64, payloadJSONString string) *jobBuilder
• type QueueSender
• type RabbitMQSender
  • func NewRabbitMQSender(conn *amqp.Connection) *RabbitMQSender
  • func (sender *RabbitMQSender) SendJsonString(queueName, jsonStr string) error

Constants

const (
	DEFAULT_PUBLISH_RETRY_TIME              = 3
	DEFAULT_PUBLISH_RETRY_INTERVAL_MS int64 = 500
)

Functions

func NewJobBuilder

func NewJobBuilder(unitType string, granularitySec int64, payloadJSONString string) *jobBuilder

Types

type QueueSender

type QueueSender interface {
	SendJsonString(queueName, jsonStr string) error
	// contains filtered or unexported methods
}

type RabbitMQSender

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

func NewRabbitMQSender

func NewRabbitMQSender(conn *amqp.Connection) *RabbitMQSender

func (*RabbitMQSender) SendJsonString

func (sender *RabbitMQSender) SendJsonString(queueName, jsonStr string) error