pubsub

Documentation

Index

• type Channel
• type Message
• type PubSub
  • func New(l logger.Logger, pubsubType string, address string, user string, ...) (PubSub, error)

Types

type Channel

type Channel interface {
	Read(model interface{}) (<-chan interface{}, <-chan error)
	Close() error
}

Channel is channel interface.

type Message

type Message struct {
	Type string
	ID   int
}

Message is pubsub message model.

type PubSub

type PubSub interface {
	Publish(topic string, data interface{}) error
	Subscribe(topic string) (interface{}, error)
	Close() error
}

PubSub is pubsub interface.

func New

func New(l logger.Logger, pubsubType string, address string, user string, password string) (PubSub, error)

New to create new pubsub client.