multicast

Documentation

Index

• Variables
• type Bus
  • func NewBus(queue Queue) *Bus
  • func NewNatsBus(conn *nats.Conn) *Bus
  • func NewRedisBus(client *redis.Client) *Bus
  • func (bus *Bus) Close()
  • func (bus *Bus) Publish(ctx context.Context, message *nh.Multicast) error
  • func (bus *Bus) Subscribe(ctx context.Context, handler func(*nh.Multicast)) error
• type Publisher
• type Queue
• type Subscriber

Variables

var Channel = "nodehub:multicast"

Channel 通道名称

Types

type Bus

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

Bus push message总线

func NewBus

func NewBus(queue Queue) *Bus

NewBus 构造函数

func NewNatsBus

func NewNatsBus(conn *nats.Conn) *Bus

NewNatsBus 使用nats构造总线

func NewRedisBus

func NewRedisBus(client *redis.Client) *Bus

NewRedisBus 构造函数

client 可以使用 *redis.Client 或者 *redis.ClusterClient

当使用ClusterClient时，会采用sharded channel

func (*Bus) Close

func (bus *Bus) Close()

Close 关闭消息队列

func (*Bus) Publish

func (bus *Bus) Publish(ctx context.Context, message *nh.Multicast) error

Publish 把消息发布到消息队列

func (*Bus) Subscribe

func (bus *Bus) Subscribe(ctx context.Context, handler func(*nh.Multicast)) error

Subscribe 从消息队列订阅消息

type Publisher

type Publisher interface {
	Publish(ctx context.Context, message *nh.Multicast) error
}

Publisher 把消息发布到消息队列

type Queue

type Queue = mq.Queue

Queue 消息队列

type Subscriber

type Subscriber interface {
	Subscribe(ctx context.Context, handler func(*nh.Multicast)) error
}

Subscriber 从消息队列订阅消息