event

Documentation

Index

• func BotEventFire(ctx types.Context, eventName string, param types.KV) error
• func NewMessage(payload any) (*message.Message, error)
• func NewPublisher() (message.Publisher, error)
• func NewRouter() (*message.Router, error)
• func NewSubscriber() (message.Subscriber, error)
• func PublishMessage(ctx context.Context, topic string, payload any) error
• func SendMessage(ctx types.Context, msg types.MsgPayload) error

Functions

func BotEventFire

func BotEventFire(ctx types.Context, eventName string, param types.KV) error

func NewMessage

func NewMessage(payload any) (*message.Message, error)

func NewPublisher

func NewPublisher() (message.Publisher, error)

func NewRouter

func NewRouter() (*message.Router, error)

func NewSubscriber

func NewSubscriber() (message.Subscriber, error)

func PublishMessage

func PublishMessage(ctx context.Context, topic string, payload any) error

func SendMessage

func SendMessage(ctx types.Context, msg types.MsgPayload) error