consumer

Documentation

Index

• type Consumer
  • func (c *Consumer) Publish(topic string, msg []byte, meta interface{})
  • func (c *Consumer) Subscribe(topic string, fun interface{})
• type Publisher
• type Streamer
• type Subscriber

Types

type Consumer

type Consumer struct {
	shezmu.BaseDaemon
	// contains filtered or unexported fields
}

Consumer extends Shezmu's BaseDaemon with pub/sub features.

func (*Consumer) Publish

func (c *Consumer) Publish(topic string, msg []byte, meta interface{})

Publish sends a message to the publisher.

func (*Consumer) Subscribe

func (c *Consumer) Subscribe(topic string, fun interface{})

Subscribe subscriasdsdfsdgdfgdfsg sdgsdfg sdfgs dfgdfgdfg.

type Publisher

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

Publisher is the interface that wraps message publishers. Error handling should be provided by the implementation. Feel free to panic.

type Streamer

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

Streamer is the interface that wraps message consumers. Error handling should be provided by the implementation. Feel free to panic.

type Subscriber

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

Subscriber is the interface that is used by daemons to subscribe to messages.