pubsub

Documentation

Index

• Constants
• func NewMessageRouter(logger watermill.LoggerAdapter, handlers EventHandlers, pubsub PubSub) (*message.Router, error)
• type ChatCreated
• type ChatUpdated
• type EventHandlers
  • func NewEventHandlers(ctx context.Context, logger watermill.LoggerAdapter) EventHandlers
• type EventMessageSent
• type Message
• type MessageSentHandler
  • func (h MessageSentHandler) Handle(msg *message.Message) ([]*message.Message, error)
• type PubSub

Constants

const (
	TopicMessageSent = "message-sent"
	TopicChatCreated = "chat-created"
	TopicChatUpdated = "chat-updated"
)

Functions

func NewMessageRouter

func NewMessageRouter(logger watermill.LoggerAdapter, handlers EventHandlers, pubsub PubSub) (*message.Router, error)

Types

type ChatCreated

type ChatCreated struct {
	ChatId    string    `json:"chat_id"`
	CreatedAt time.Time `json:"created_at"`
}

type ChatUpdated

type ChatUpdated struct {
	ChatId    string    `json:"chat_id"`
	UpdatedAt time.Time `json:"updated_at"`
}

type EventHandlers

type EventHandlers struct {
	MessageSent MessageSentHandler
}

func NewEventHandlers

func NewEventHandlers(ctx context.Context, logger watermill.LoggerAdapter) EventHandlers

type EventMessageSent

type EventMessageSent struct {
	Message Message   `json:"message"`
	ChatId  string    `json:"chat_id"`
	SentAt  time.Time `json:"sent_at,omitempty"`
}

type Message

type Message struct {
	AuthorId string `json:"author_id"`
	Text     string `json:"text"`
}

type MessageSentHandler

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

func (MessageSentHandler) Handle

func (h MessageSentHandler) Handle(msg *message.Message) ([]*message.Message, error)

type PubSub

type PubSub interface {
	message.Publisher
	message.Subscriber
}