daemons

Documentation

Index

• type NumberPrinter
  • func (n *NumberPrinter) Startup()
• type PriceConsumer
  • func (p *PriceConsumer) Startup()
• type PriceUpdate

Types

type NumberPrinter

type NumberPrinter struct {
	shezmu.BaseDaemon
}

NumberPrinter is a daemon that prints numbers once in a while.

func (*NumberPrinter) Startup

func (n *NumberPrinter) Startup()

Startup sets up panic handler and starts enqueuing number printing jobs.

type PriceConsumer

type PriceConsumer struct {
	consumer.Consumer
}

PriceConsumer consumes price update messages and prints them to the console.

func (*PriceConsumer) Startup

func (p *PriceConsumer) Startup()

Startup creates a new subscription for ProductPriceUpdates topic.

type PriceUpdate

type PriceUpdate struct {
	Product string  `json:"product"`
	Amount  float64 `json:"amount"`
}

PriceUpdate describes a price update message.