subscribers

Documentation

Index

• type Broadcast
• type HttpSubscriber
  • func (sub *HttpSubscriber) Subscribe(callback Broadcast)
  • func (sub *HttpSubscriber) UnSubscribe()
• type HttpSubscriberData
• type RedisSubscriber
  • func (sub *RedisSubscriber) Subscribe(callback Broadcast)
  • func (sub *RedisSubscriber) UnSubscribe()
• type Subscriber
  • func NewHttpSubscriber(express *express.Express, _options *options.Config) Subscriber
  • func NewRedisSubscriber(_options *options.Config) (Subscriber, error)

Types

type Broadcast

type Broadcast func(string, *types.Data)

type HttpSubscriber

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

func (*HttpSubscriber) Subscribe

func (sub *HttpSubscriber) Subscribe(callback Broadcast)

Subscribe to events to broadcast.

func (*HttpSubscriber) UnSubscribe

func (sub *HttpSubscriber) UnSubscribe()

Unsubscribe from events to broadcast.

type HttpSubscriberData

type HttpSubscriberData struct {
	Channels []string `json:"channels"`
	Channel  string   `json:"channel"`
	Name     string   `json:"name"`
	Data     string   `json:"data"`
	SocketId string   `json:"socket_id"`
}

type RedisSubscriber

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

func (*RedisSubscriber) Subscribe

func (sub *RedisSubscriber) Subscribe(callback Broadcast)

Subscribe to events to broadcast.

func (*RedisSubscriber) UnSubscribe

func (sub *RedisSubscriber) UnSubscribe()

Unsubscribe from events to broadcast.

type Subscriber

type Subscriber interface {
	// Subscribe to incoming events.
	Subscribe(Broadcast)

	// Unsubscribe from events to broadcast.
	UnSubscribe()
}

func NewHttpSubscriber

func NewHttpSubscriber(express *express.Express, _options *options.Config) Subscriber

Create new instance of http subscriber.

func NewRedisSubscriber

func NewRedisSubscriber(_options *options.Config) (Subscriber, error)

Create a new instance of subscriber.