queue

Documentation

Index

• Constants
• func GetGranularitySec(granularityStr string) int64
• func GetGranularityStr(granularitySec int64) string
• func GetQueueConn(queueURL string, retryItvMS int64) *amqp.Connection
• func NewJobBuilder(clusterID string, unitType string, granularitySec int64, ...) *jobBuilder
• type QueueSender
• type RabbitMQConsumer
  • func NewRabbitMQConsumer(conn *amqp.Connection) *RabbitMQConsumer
  • func (consumer *RabbitMQConsumer) ConsumeJsonString(queueName string) (<-chan amqp.Delivery, error)
  • func (consumer *RabbitMQConsumer) ReceiveJsonString(queueName string) (string, bool, error)
• type RabbitMQSender
  • func NewRabbitMQSender(queueURL string, retryItvMS int64) (*RabbitMQSender, *amqp.Connection)
  • func (sender *RabbitMQSender) SendJob(queueName string, unit *config.Unit, columns, values []string, ...) error
  • 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 GetQueueConn

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

func NewJobBuilder

func NewJobBuilder(clusterID string, unitType string, granularitySec int64,
	metricType datahub_common.MetricType, payloadJSONString string,
	extraJobInfo map[string]string) *jobBuilder

Types

type QueueSender

type QueueSender interface {
	SendJsonString(queueName, jsonStr, msgID string, timeout int64) error
	SendJob(queueName string, unit *config.Unit,
		columns, values []string, metricType datahub_common.MetricType, granularity 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) ConsumeJsonString

func (consumer *RabbitMQConsumer) ConsumeJsonString(queueName string) (<-chan amqp.Delivery, error)

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) SendJob

func (sender *RabbitMQSender) SendJob(queueName string, unit *config.Unit,
	columns, values []string, metricType datahub_common.MetricType, granularity int64) error

func (*RabbitMQSender) SendJsonString

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