msgbs

Documentation

Index

• type Article
• type Event
• type Message
• type MessageBus
• type RedisMessageBus
  • func NewRedis(pscon *redis.PubSubConn, conn *redis.Conn) *RedisMessageBus
  • func (r RedisMessageBus) Publish(evnt Event, msg Message) error
  • func (r RedisMessageBus) Receive() interface{}
  • func (r RedisMessageBus) Subscribe(evnt Event)
  • func (r RedisMessageBus) Unsubscribe(evnt Event)
• type Router
  • func NewRouter() Router
  • func (r Router) Subscribe(evnt Event, subsc SubscribeFunc)
• type SubscribeFunc
• type SubscribeServer
  • func NewSubscribeServer() SubscribeServer
  • func (s *SubscribeServer) Mount(subsc Subscriber)
  • func (s SubscribeServer) Serve(ctx context.Context)
  • func (s SubscribeServer) Shutdown(ctx context.Context)
• type Subscriber
  • func NewSubscriber(msgbs MessageBus, algr applog.AppLog) Subscriber
  • func (s Subscriber) Do(ctx context.Context, done chan interface{}, wg *sync.WaitGroup)
  • func (s Subscriber) Mount(rtr Router)
  • func (s Subscriber) Subscribe(evnt Event, subsc SubscribeFunc)

Types

type Article

type Article struct {
	ID    int64
	Title string
}

type Event

type Event string

const (
	AddArticle Event = "add_article"
)

type Message

type Message interface{}

type MessageBus

type MessageBus interface {
	Publish(Event, Message) error
	Subscribe(Event)
	Unsubscribe(Event)
	Receive() interface{}
}

type RedisMessageBus

type RedisMessageBus struct {
	PubSubConn *redis.PubSubConn
	Conn       *redis.Conn
}

func NewRedis

func NewRedis(pscon *redis.PubSubConn, conn *redis.Conn) *RedisMessageBus

func (RedisMessageBus) Publish

func (r RedisMessageBus) Publish(evnt Event, msg Message) error

func (RedisMessageBus) Receive

func (r RedisMessageBus) Receive() interface{}

func (RedisMessageBus) Subscribe

func (r RedisMessageBus) Subscribe(evnt Event)

func (RedisMessageBus) Unsubscribe

func (r RedisMessageBus) Unsubscribe(evnt Event)

type Router

type Router map[Event][]SubscribeFunc

func NewRouter

func NewRouter() Router

func (Router) Subscribe

func (r Router) Subscribe(evnt Event, subsc SubscribeFunc)

type SubscribeFunc

type SubscribeFunc func(context.Context, redis.Message) error

type SubscribeServer

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

func NewSubscribeServer

func NewSubscribeServer() SubscribeServer

func (*SubscribeServer) Mount

func (s *SubscribeServer) Mount(subsc Subscriber)

func (SubscribeServer) Serve

func (s SubscribeServer) Serve(ctx context.Context)

func (SubscribeServer) Shutdown

func (s SubscribeServer) Shutdown(ctx context.Context)

type Subscriber

type Subscriber struct {
	MessageBus MessageBus
	Router     Router
	AppLog     applog.AppLog
}

func NewSubscriber

func NewSubscriber(msgbs MessageBus, algr applog.AppLog) Subscriber

func (Subscriber) Do

func (s Subscriber) Do(
	ctx context.Context,
	done chan interface{},
	wg *sync.WaitGroup,
)

func (Subscriber) Mount

func (s Subscriber) Mount(rtr Router)

func (Subscriber) Subscribe

func (s Subscriber) Subscribe(evnt Event, subsc SubscribeFunc)