broker

Documentation

Index

• func CronJob(client redis.UniversalClient, broker Broker, message Message) ([]byte, error)
• func DelayJob(client redis.UniversalClient, broker Broker, message Message) ([]byte, error)
• func DeleteJob(client redis.UniversalClient, broker Broker, message Message) ([]byte, error)
• func GetJob(client redis.UniversalClient, broker Broker, message Message) ([]byte, error)
• func HandleReceive(redis redis.UniversalClient, broker Broker)
• func ReplyBack(broker Broker, delivery amqp091.Delivery, value []byte)
• type Broker
  • func CreateBroker(amqpURI string) *Broker
• type Message

Functions

func CronJob

func CronJob(client redis.UniversalClient, broker Broker, message Message) ([]byte, error)

func DelayJob

func DelayJob(client redis.UniversalClient, broker Broker, message Message) ([]byte, error)

func DeleteJob

func DeleteJob(client redis.UniversalClient, broker Broker, message Message) ([]byte, error)

func GetJob

func GetJob(client redis.UniversalClient, broker Broker, message Message) ([]byte, error)

func HandleReceive

func HandleReceive(redis redis.UniversalClient, broker Broker)

func ReplyBack

func ReplyBack(broker Broker, delivery amqp091.Delivery, value []byte)

Types

type Broker

type Broker struct {
	Connection *amqp091.Connection
	Channel    *amqp091.Channel
	// contains filtered or unexported fields
}

func CreateBroker

func CreateBroker(amqpURI string) *Broker

type Message

type Message struct {
	T string `json:"t"`
	D struct {
		Time  interface{} `json:"time"`
		Data  interface{} `json:"data"`
		Name  *string     `json:"name"`
		Route *string     `json:"route"`
	} `json:"d"`
}