eventbus

package module

Go to main page

Versions in this module

v0

v0.2.0

Jun 2, 2020

Changes in this version

type Bus

+ func (bus *Bus) HasCallback(topic string) bool

+ func (bus *Bus) Publish(topic string, args ...interface{})

+ func (bus *Bus) Subscribe(topic string, fn interface{}) error

+ func (bus *Bus) SubscribeAsync(topic string, fn interface{}, transactional bool) error

+ func (bus *Bus) SubscribeOnce(topic string, fn interface{}) error

+ func (bus *Bus) SubscribeOnceAsync(topic string, fn interface{}) error

+ func (bus *Bus) Unsubscribe(topic string, handler interface{}) error

+ func (bus *Bus) WaitAsync()

v0.1.0

Jun 3, 2019

Changes in this version

+ func HasCallback(topic string) bool

+ func Publish(topic string, args ...interface{})

+ func SubscribeAsync(topic string, fn interface{}, transactional bool) error

+ func SubscribeOnceAsync(topic string, fn interface{}) error

+ func Unsubscribe(topic string, handler interface{}) error

+ func WaitAsync()

type SubscribeType

+ const SubscribeTypeOnce

+ const SubscribeTypePermanent

v0.0.1

Mar 15, 2017

Changes in this version

+ const PublishService

+ const RegisterService

+ type Bus interface

+ func New() Bus

+ type BusController interface

+ HasCallback func(topic string) bool

+ WaitAsync func()

+ type BusPublisher interface

+ Publish func(topic string, args ...interface{})

+ type BusSubscriber interface

+ Subscribe func(topic string, fn interface{}) error

+ SubscribeAsync func(topic string, fn interface{}, transactional bool) error

+ SubscribeOnce func(topic string, fn interface{}) error

+ SubscribeOnceAsync func(topic string, fn interface{}) error

+ Unsubscribe func(topic string, handler interface{}) error

+ type Client struct

+ func NewClient(address, path string, eventBus Bus) *Client

+ func (client *Client) EventBus() Bus

+ func (client *Client) Start() error

+ func (client *Client) Stop()

+ func (client *Client) Subscribe(topic string, fn interface{}, serverAddr, serverPath string)

+ func (client *Client) SubscribeOnce(topic string, fn interface{}, serverAddr, serverPath string)

+ type ClientArg struct

+ Args []interface{}

+ Topic string

+ type ClientService struct

+ func (service *ClientService) PushEvent(arg *ClientArg, reply *bool) error

+ type EventBus struct

+ func (bus *EventBus) HasCallback(topic string) bool

+ func (bus *EventBus) Publish(topic string, args ...interface{})

+ func (bus *EventBus) Subscribe(topic string, fn interface{}) error

+ func (bus *EventBus) SubscribeAsync(topic string, fn interface{}, transactional bool) error

+ func (bus *EventBus) SubscribeOnce(topic string, fn interface{}) error

+ func (bus *EventBus) SubscribeOnceAsync(topic string, fn interface{}) error

+ func (bus *EventBus) Unsubscribe(topic string, handler interface{}) error

+ func (bus *EventBus) WaitAsync()

+ type NetworkBus struct

+ func NewNetworkBus(address, path string) *NetworkBus

+ func (networkBus *NetworkBus) EventBus() Bus

+ func (networkBus *NetworkBus) Start() error

+ func (networkBus *NetworkBus) Stop()

+ type NetworkBusService struct

+ type Server struct

+ func NewServer(address, path string, eventBus Bus) *Server

+ func (server *Server) EventBus() Bus

+ func (server *Server) HasClientSubscribed(arg *SubscribeArg) bool

+ func (server *Server) Start() error

+ func (server *Server) Stop()

+ type ServerService struct

+ func (service *ServerService) Register(arg *SubscribeArg, success *bool) error

+ type SubscribeArg struct

+ ClientAddr string

+ ClientPath string

+ ServiceMethod string

+ SubscribeType SubscribeType

+ Topic string

+ type SubscribeType int

+ const Subscribe

+ const SubscribeOnce

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL