transporters

Documentation

Index

• func NewRabbitMqTransporter(url string) (gateway.Transporter, error)
• type RabbitMqTransporter
  • func (transporter RabbitMqTransporter) PushDispatchEvent(t string, data []byte) error
  • func (transporter RabbitMqTransporter) PushEventCache(t string, data []byte) error

Functions

func NewRabbitMqTransporter

func NewRabbitMqTransporter(url string) (gateway.Transporter, error)

NewRabbitMqTransporter creates a rabbitmq transporter using a given url

Types

type RabbitMqTransporter

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

func (RabbitMqTransporter) PushDispatchEvent

func (transporter RabbitMqTransporter) PushDispatchEvent(t string, data []byte) error

PushDispatchEvent dispatches a general event to all the bot workers.

func (RabbitMqTransporter) PushEventCache

func (transporter RabbitMqTransporter) PushEventCache(t string, data []byte) error

PushEventCache dispatches a cache specific events to all the cache workers.