bus

README

go-bus

go-bus is a lightweight golang library for implementing the pub/sub pattern. It supports wildcard topics as well as dynamic topic subscription.

Usage

Basic pub/sub usage:

package main

import (
	"fmt"
	"github.com/qryio/go-bus"
)

func main() {
	b := bus.New()
	sub := b.Subscribe([]string{"my", "topic"}, func(t []string, s *bus.Subscription, p interface{}) {
		fmt.Printf("%v world", p)
	})
	b.Publish([]string{"my", "topic"}, "hello")
	sub.Terminate()
}

Check out more examples

License

Code and documentation released under Apache License 2.0

Documentation

Index

• type Bus
  • func New() *Bus
  • func (b *Bus) Publish(t []string, p interface{})
  • func (b *Bus) Subscribe(t []string, h Handler) *Subscription
• type Handler
• type Subscription
  • func (s *Subscription) Terminate()

Types

type Bus

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

func New

func New() *Bus

func (*Bus) Publish

func (b *Bus) Publish(t []string, p interface{})

func (*Bus) Subscribe

func (b *Bus) Subscribe(t []string, h Handler) *Subscription

type Handler

type Handler func(t []string, s *Subscription, p interface{})

type Subscription

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

func (*Subscription) Terminate

func (s *Subscription) Terminate()