queue

Documentation

Index

• Constants
• func GetGranularitySec(granularityStr string) int64
• func GetGranularityStr(granularitySec int64) string
• func GetMetricLabel(mt datahub_common.MetricType) string
• func GetQueueConn(queueURL string, retryItvMS int64) *amqp.Connection
• func NewJobBuilder(unitType string, granularitySec int64, payloadJSONString string) *jobBuilder
• type QueueSender
• type RabbitMQConsumer
  • func NewRabbitMQConsumer(conn *amqp.Connection) *RabbitMQConsumer
  • func (consumer *RabbitMQConsumer) ReceiveJsonString(queueName string) (string, bool, error)
• type RabbitMQSender
  • func NewRabbitMQSender(queueURL string, retryItvMS int64) (*RabbitMQSender, *amqp.Connection)
  • func (sender *RabbitMQSender) SendJsonString(queueName, jsonStr, msgID string, granularity int64) error

Constants

const (
	DEFAULT_PUBLISH_RETRY_TIME              = 3
	DEFAULT_PUBLISH_RETRY_INTERVAL_MS int64 = 500
	DEFAULT_CONSUME_RETRY_TIME              = 3
	DEFAULT_CONSUME_RETRY_INTERVAL_MS int64 = 500
	DEFAULT_ACK_TIMEOUT_SEC                 = 3
)

Functions

func GetGranularitySec

func GetGranularitySec(granularityStr string) int64

func GetGranularityStr

func GetGranularityStr(granularitySec int64) string

func GetMetricLabel

func GetMetricLabel(mt datahub_common.MetricType) string

func GetQueueConn

func GetQueueConn(queueURL string, retryItvMS int64) *amqp.Connection

func NewJobBuilder

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

Types

type QueueSender

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

type RabbitMQConsumer

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

func NewRabbitMQConsumer

func NewRabbitMQConsumer(conn *amqp.Connection) *RabbitMQConsumer

func (*RabbitMQConsumer) ReceiveJsonString

func (consumer *RabbitMQConsumer) ReceiveJsonString(queueName string) (
	string, bool, error)

type RabbitMQSender

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

func NewRabbitMQSender

func NewRabbitMQSender(queueURL string, retryItvMS int64) (*RabbitMQSender, *amqp.Connection)

func (*RabbitMQSender) SendJsonString

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