shezmu

type Actor func()

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

type Daemon interface {
	// Startup implementation should:
	//
	// func (d *DaemonName) Startup() {
	//     // 1. Set up a panic handler
	//     b.HandlePanics(func() {
	//         log.Error("Oh, crap!")
	//     })
	//
	//     // 2. If the daemon is doing some IO it is a good idea to limit the
	//     // rate of its execution
	//     b.LimitRate(10, 1 * time.Second)
	//
	//     // 3. If the daemon is also a consumer we need to subscribe for
	//     // topics that would be consumed by the daemon
	//     b.Subscribe("ProductPriceUpdates", func(p PriceUpdate) {
	// 	       log.Printf("Price for %q is now $%.2f", p.Product, p.Amount)
	//     })
	// }
	Startup()

	// Shutdown implementation should clean up all daemon related stuff:
	// close channels, process the last batch of items, etc.
	Shutdown()

	// String returns the name of a daemon.
	String() string
	// contains filtered or unexported methods
}

type Logger interface {
	Printf(format string, v ...interface{})
	Println(v ...interface{})
}

type PanicHandler func(interface{})

type Publisher interface {
	Publish(topic string, msg []byte, meta interface{})
	Close()
}

type Shezmu struct {
	Subscriber  Subscriber
	Publisher   Publisher
	DaemonStats stats.Publisher
	Logger      Logger
	NumWorkers  int
	// contains filtered or unexported fields
}

type Streamer interface {
	Messages() <-chan []byte
	Close()
}

type Subscriber interface {
	Subscribe(consumerName, topic string) Streamer
}