bus

Documentation

Index

• type InboundMessage
• type MessageBus
  • func NewMessageBus() *MessageBus
  • func (mb *MessageBus) Close()
  • func (mb *MessageBus) ConsumeInbound(ctx context.Context) (InboundMessage, bool)
  • func (mb *MessageBus) GetHandler(channel string) (MessageHandler, bool)
  • func (mb *MessageBus) PublishInbound(msg InboundMessage)
  • func (mb *MessageBus) PublishOutbound(msg OutboundMessage)
  • func (mb *MessageBus) RegisterHandler(channel string, handler MessageHandler)
  • func (mb *MessageBus) SubscribeOutbound(ctx context.Context) (OutboundMessage, bool)
• type MessageHandler
• type OutboundMessage

Types

type InboundMessage

type InboundMessage struct {
	Channel    string            `json:"channel"`
	SenderID   string            `json:"sender_id"`
	ChatID     string            `json:"chat_id"`
	Content    string            `json:"content"`
	Media      []string          `json:"media,omitempty"`
	SessionKey string            `json:"session_key"`
	Metadata   map[string]string `json:"metadata,omitempty"`
}

type MessageBus

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

func NewMessageBus

func NewMessageBus() *MessageBus

func (*MessageBus) Close

func (mb *MessageBus) Close()

func (*MessageBus) ConsumeInbound

func (mb *MessageBus) ConsumeInbound(ctx context.Context) (InboundMessage, bool)

func (*MessageBus) GetHandler

func (mb *MessageBus) GetHandler(channel string) (MessageHandler, bool)

func (*MessageBus) PublishInbound

func (mb *MessageBus) PublishInbound(msg InboundMessage)

func (*MessageBus) PublishOutbound

func (mb *MessageBus) PublishOutbound(msg OutboundMessage)

func (*MessageBus) RegisterHandler

func (mb *MessageBus) RegisterHandler(channel string, handler MessageHandler)

func (*MessageBus) SubscribeOutbound

func (mb *MessageBus) SubscribeOutbound(ctx context.Context) (OutboundMessage, bool)

type MessageHandler

type MessageHandler func(InboundMessage) error

type OutboundMessage

type OutboundMessage struct {
	Channel string `json:"channel"`
	ChatID  string `json:"chat_id"`
	Content string `json:"content"`
}