message

Documentation

Index

• type Message
  • func (m Message) GetPayload() interface{}
  • func (m Message) GetRequestor() string
  • func (m Message) GetTopic() string
  • func (m Message) Hash() string
  • func (m Message) String() string
• type MessageBus
• type Request
• type Topic

Types

type Message

type Message struct {
	Topic     Topic
	Requestor string
	Payload   interface{}
}

func (Message) GetPayload

func (m Message) GetPayload() interface{}

func (Message) GetRequestor

func (m Message) GetRequestor() string

func (Message) GetTopic

func (m Message) GetTopic() string

func (Message) Hash

func (m Message) Hash() string

func (Message) String

func (m Message) String() string

type MessageBus

type MessageBus interface {
	Subscribe() chan Request
	Publish(msg Request)
}

type Request

type Request interface {
	GetPayload() interface{}
	GetRequestor() string
	GetTopic() string
	Hash() string
	String() string
}

type Topic

type Topic interface {
	String() string
}