pubsub

Documentation

Index

• type Message
  • func NewMessage(data interface{}) *Message
  • func (m *Message) Marshal() ([]byte, error)
  • func (m *Message) SetTopic(topic string)
  • func (m *Message) Unmarshal(b []byte) error
• type Pubsub

Types

type Message

type Message struct {
	Id        string    `json:"id"`
	Channel   string    `json:"channel"`
	Data      any       `json:"data"`
	CreatedAt time.Time `json:"created_at"`
}

func NewMessage

func NewMessage(data interface{}) *Message

func (*Message) Marshal

func (m *Message) Marshal() ([]byte, error)

func (*Message) SetTopic

func (m *Message) SetTopic(topic string)

func (*Message) Unmarshal

func (m *Message) Unmarshal(b []byte) error

type Pubsub

type Pubsub interface {
	Publish(ctx context.Context, topic string, data *Message) error
	Subscribe(ctx context.Context, topic string) (ch <-chan *Message, close func())
}