bus

Documentation

Index

• Constants
• type Publisher
  • func NewPublisher(addr []string) *Publisher
  • func (b *Publisher) Pub(ctx context.Context, record *operate.OperateLog) error
• type Subscriber
  • func NewSubscriber(addr []string) *Subscriber
  • func (b *Subscriber) Sub(ctx context.Context)

Constants

const (
	OPERATE_LOG_TOPIC = "log.operate"
)

Types

type Publisher

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

发布者

func NewPublisher

func NewPublisher(addr []string) *Publisher

func (*Publisher) Pub

func (b *Publisher) Pub(ctx context.Context, record *operate.OperateLog) error

往总线上发布数据

type Subscriber

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

订阅者 应该放在那里启动, 服务启动的时候就启动

func NewSubscriber

func NewSubscriber(addr []string) *Subscriber

func (*Subscriber) Sub

func (b *Subscriber) Sub(ctx context.Context)

订阅总线数据