pubsub

Documentation

Index

• type DataChannel
• type DataEvent
• type PublishSubscriber
  • func New() *PublishSubscriber
  • func (eb *PublishSubscriber) Close()
  • func (eb *PublishSubscriber) Publish(topic string, data interface{})
  • func (eb *PublishSubscriber) Subscribe(ctx context.Context, topic string) DataChannel

Types

type DataChannel

type DataChannel <-chan DataEvent

DataChannel is a channel which can accept an DataEvent

type DataEvent

type DataEvent struct {
	Data  interface{}
	Topic string
}

type PublishSubscriber

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

PublishSubscriber stores the information about subscribers interested for a particular topic

func New

func New() *PublishSubscriber

func (*PublishSubscriber) Close

func (eb *PublishSubscriber) Close()

func (*PublishSubscriber) Publish

func (eb *PublishSubscriber) Publish(topic string, data interface{})

func (*PublishSubscriber) Subscribe

func (eb *PublishSubscriber) Subscribe(ctx context.Context, topic string) DataChannel