messagelog

Documentation

Index

• type ErrInvalidMessage
  • func (err *ErrInvalidMessage) Error() string
• type ErrTopicNotFound
  • func (err *ErrTopicNotFound) Error() string
• type Log
  • func New() *Log
  • func (ml *Log) AddTopic(topic string, capacity int)
  • func (ml *Log) List(topic string, offset int) ([]Message, error)
  • func (ml *Log) Push(topic string, message Message) error
• type Message

Types

type ErrInvalidMessage

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

func (*ErrInvalidMessage) Error

func (err *ErrInvalidMessage) Error() string

type ErrTopicNotFound

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

func (*ErrTopicNotFound) Error

func (err *ErrTopicNotFound) Error() string

type Log

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

func New

func New() *Log

func (*Log) AddTopic

func (ml *Log) AddTopic(topic string, capacity int)

func (*Log) List

func (ml *Log) List(topic string, offset int) ([]Message, error)

func (*Log) Push

func (ml *Log) Push(topic string, message Message) error

type Message

type Message struct {
	Index       int         `json:"index"`
	Sender      string      `json:"sender" validate:"min=1"`
	ContentType string      `json:"content_type" validate:"min=1"`
	Content     interface{} `json:"content" validate:"nonnil"`
}