rabbitmq

Documentation

Index

• func Consume(writer *sql.DB, callback func(*sql.DB, []byte) error)
• func Publish(data []byte) (err error)
• type RabbitMQ
• type TransferMeta

Functions

func Consume

func Consume(writer *sql.DB, callback func(*sql.DB, []byte) error)

Consume -

func Publish

func Publish(data []byte) (err error)

Publish -

Types

type RabbitMQ

type RabbitMQ struct {
	Connection   *amqp.Connection
	Channel      *amqp.Channel
	ExchangeName string
	ExchangeType string
	QueueName    string
	RoutingKey   string
}

RabbitMQ -

type TransferMeta

type TransferMeta struct {
	FileName     string
	FileSha1     string
	FileSize     int64
	FileCurAddr  string
	FileDestAddr string
}

TransferMeta -