broker

Documentation

Index

• func GetMessageQueue() chan EventMessage
• func Push(msg EventMessage)
• func PushMessage()
• func RegisterEventWorker(service micro.Service)
• type EventMessage
• type EventWorker
  • func NewEventSubPub(service micro.Service) *EventWorker
  • func (a *EventWorker) EventProcess(ctx context.Context, eventMessage *proto.MessageEntity) error
• type Message

Functions

func GetMessageQueue

func GetMessageQueue() chan EventMessage

GetMessageQueue to push

func Push

func Push(msg EventMessage)

Push ...

func PushMessage

func PushMessage()

PushMessage 推送消息到前端

func RegisterEventWorker

func RegisterEventWorker(service micro.Service)

RegisterEventWorker for status

Types

type EventMessage

type EventMessage struct {
	Topic   string
	Message *proto.MessageEntity
}

EventMessage ...

type EventWorker

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

EventWorker is an status publisher for the go-micro broker

func NewEventSubPub

func NewEventSubPub(service micro.Service) *EventWorker

NewEventSubPub creates a new broker status publisher

func (*EventWorker) EventProcess

func (a *EventWorker) EventProcess(ctx context.Context, eventMessage *proto.MessageEntity) error

EventProcess Event for MessageBus

type Message

type Message struct {
	Data EventMessage
}

Message Struct