Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var BUILDJSON []byte
Functions ¶
This section is empty.
Types ¶
type BuildInfo ¶
type BuildInfo struct { Service struct { Name string `json:"name"` Version string `json:"version"` CommitId string `json:"commitId"` } `json:"service"` Components []struct { Name string `json:"name"` Version string `json:"version"` CommitId string `json:"commitId"` } `json:"components"` }
var BUILDINFO BuildInfo
type Consumer ¶
type Consumer struct { Exit chan bool // contains filtered or unexported fields }
func NewConsumer ¶
type Engine ¶
type Engine interface { Execute(topic string, request Request) error AddConsumer(topic string, listener Consumer) RemoveConsumer(topic string, consunerid uuid.UUID) bool HasConsumers(topic string) bool GetConsumers(topic string) []Consumer Start() error Stop() error }
var ENGINE Engine
type MessageBody ¶
type MessageBody struct { ExternalID string Message Message Status Status // contains filtered or unexported fields }
func (*MessageBody) AsJSON ¶
func (m *MessageBody) AsJSON(object interface{}) error
func (MessageBody) FromJSONInto ¶
func (m MessageBody) FromJSONInto(object interface{}) error
func (MessageBody) GetID ¶
func (m MessageBody) GetID() uuid.UUID
type Request ¶
type Request struct { MessageBody // contains filtered or unexported fields }
func NewRequest ¶
func NewRequestWith ¶
func (*Request) GetReceiver ¶
func (*Request) GetResponder ¶
func (*Request) SetResponder ¶
type Response ¶
type Response struct {
MessageBody
}
Click to show internal directories.
Click to hide internal directories.