producer

Documentation

Index

• type Message
• type Module
• type Notification
• type Producer
  • func NewProducer(options *ProducerOptions) *Producer
  • func (p *Producer) RegisterModule(path string)
  • func (p *Producer) Say(message string)
  • func (p *Producer) Start() error
• type ProducerOptions
  • func LoadEnv() *ProducerOptions
• type User

Types

type Message

type Message struct {
	User      User
	Text      string
	Timestamp time.Time
}

type Module

type Module interface {
	Init(p *Producer)
	Exec(n *Notification)
}

type Notification

type Notification struct {
	Message Message
	Channel string
}

type Producer

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

func NewProducer

func NewProducer(options *ProducerOptions) *Producer

func (*Producer) RegisterModule

func (p *Producer) RegisterModule(path string)

func (*Producer) Say

func (p *Producer) Say(message string)

func (*Producer) Start

func (p *Producer) Start() error

type ProducerOptions

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

func LoadEnv

func LoadEnv() *ProducerOptions

type User

type User struct {
	DisplayName string
	Name        string
}