Versions in this module Expand all Collapse all v3 v3.1.2 Jun 13, 2024 v3.1.0 Jun 11, 2024 Changes in this version + type HostInfo struct + Host string + Port int + Protocol string + func (info *HostInfo) GetHostURL() string + func (info *HostInfo) IsHostInfoEmpty() bool + type MessageBusConfig struct + Broker HostInfo + Optional map[string]string + Type string + type MessageEnvelope struct + ContentType string + CorrelationID string + ErrorCode int + Payload []byte + QueryParams map[string]string + ReceivedTopic string + RequestID string + func NewMessageEnvelope(payload []byte, ctx context.Context) MessageEnvelope + func NewMessageEnvelopeForRequest(payload []byte, queryParams map[string]string) MessageEnvelope + func NewMessageEnvelopeForResponse(payload []byte, requestId string, correlationId string, contentType string) (MessageEnvelope, error) + func NewMessageEnvelopeFromJSON(message []byte) (MessageEnvelope, error) + func NewMessageEnvelopeWithError(requestId string, errorMessage string) MessageEnvelope + type TopicChannel struct + Messages chan MessageEnvelope + Topic string
Go to main page