broker

Documentation

Index

• type Broker
  • func New(config *BrokerConfig) *Broker
  • func (b *Broker) Close()
  • func (b *Broker) FromGOB64(str string) (*tgbotapi.Message, error)
  • func (b *Broker) Open(queueName string) error
  • func (b *Broker) Recieve() (<-chan amqp.Delivery, error)
  • func (b *Broker) Send(m tgbotapi.Message) error
• type BrokerConfig
  • func NewConfig() *BrokerConfig
  • func ReadConfig(path string) *BrokerConfig
  • func (c *BrokerConfig) BuildAmqpURL()

Types

type Broker

type Broker struct {
	Logger *logrus.Logger
	// contains filtered or unexported fields
}

func New

func New(config *BrokerConfig) *Broker

func (*Broker) Close

func (b *Broker) Close()

func (*Broker) FromGOB64

func (b *Broker) FromGOB64(str string) (*tgbotapi.Message, error)

func (*Broker) Open

func (b *Broker) Open(queueName string) error

func (*Broker) Recieve

func (b *Broker) Recieve() (<-chan amqp.Delivery, error)

func (*Broker) Send

func (b *Broker) Send(m tgbotapi.Message) error

type BrokerConfig

type BrokerConfig struct {
	Login    string `toml:"login"`
	Pass     string `toml:"pass"`
	Post     string `toml:"host"`
	Port     int    `toml:"port"`
	LogLevel string `toml:"log_level"`
	Debug    bool   `toml:"debug"`
	URL      string
}

func NewConfig

func NewConfig() *BrokerConfig

func ReadConfig

func ReadConfig(path string) *BrokerConfig

func (*BrokerConfig) BuildAmqpURL

func (c *BrokerConfig) BuildAmqpURL()