dispatcher

Documentation

Index

• type Dispatcher
  • func NewDispatcher(endpoint string, tOpts transport.Options, ext message.Extensions) *Dispatcher
  • func (d *Dispatcher) Connect() error
  • func (d *Dispatcher) Disconnect() error
  • func (d *Dispatcher) Publish(subscription string, authToken string, data message.Data) (err error)
  • func (d *Dispatcher) SetTransport(t transport.Transport)
  • func (d *Dispatcher) Subscribe(channel string, authToken string) (*subscription.Subscription, error)
  • func (d *Dispatcher) Unsubscribe(sub *subscription.Subscription) error

Types

type Dispatcher

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

func NewDispatcher

func NewDispatcher(endpoint string, tOpts transport.Options, ext message.Extensions) *Dispatcher

func (*Dispatcher) Connect

func (d *Dispatcher) Connect() error

todo allow multiple transports

func (*Dispatcher) Disconnect

func (d *Dispatcher) Disconnect() error

func (*Dispatcher) Publish

func (d *Dispatcher) Publish(subscription string, authToken string, data message.Data) (err error)

func (*Dispatcher) SetTransport

func (d *Dispatcher) SetTransport(t transport.Transport)

func (*Dispatcher) Subscribe

func (d *Dispatcher) Subscribe(channel string, authToken string) (*subscription.Subscription, error)

func (*Dispatcher) Unsubscribe

func (d *Dispatcher) Unsubscribe(sub *subscription.Subscription) error