pubsub

Documentation

Index

• type Pub
  • func (pub Pub) Name() string
  • func (pub Pub) Publish(topic string, msg []byte) error
• type Publisher
  • func NewPublisher(c PublisherConfig) Publisher
• type PublisherConfig
• type Sub
  • func (sub Sub) Name() string
  • func (sub Sub) Run()
  • func (sub Sub) Subscribe(s Subscription) error
• type Subscriber
  • func NewSubscriber(c SubscriberConfig) Subscriber
• type SubscriberConfig
• type Subscription

Types

type Pub

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

func (Pub) Name

func (pub Pub) Name() string

func (Pub) Publish

func (pub Pub) Publish(topic string, msg []byte) error

type Publisher

type Publisher interface {
	app.Service
	Publish(topic string, msg []byte) error
}

func NewPublisher

func NewPublisher(c PublisherConfig) Publisher

NewPublisher new redis publisher

type PublisherConfig

type PublisherConfig struct {
	dependencies.RedisClientConfig
}

type Sub

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

func (Sub) Name

func (sub Sub) Name() string

func (Sub) Run

func (sub Sub) Run()

func (Sub) Subscribe

func (sub Sub) Subscribe(s Subscription) error

type Subscriber

type Subscriber interface {
	app.Runner
	Subscribe(Subscription) error
}

func NewSubscriber

func NewSubscriber(c SubscriberConfig) Subscriber

NewSubscriber new redis subscriber

type SubscriberConfig

type SubscriberConfig struct {
	dependencies.RedisClientConfig
}

type Subscription

type Subscription interface {
	Topics() []string
	Handler(string, []byte)
}