Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ErrTransform represents an error during parsing message. ErrTransform = errors.New("unable to parse JSON object") // ErrInvalidTimeField represents the use an invalid time field. ErrInvalidTimeField = errors.New("invalid time field") )
Functions ¶
func TransformPayload ¶ added in v0.28.0
func TransformPayload(transformer protomfx.Transformer, msg *protomfx.Message) error
Types ¶
type Message ¶
type Message struct {
Created int64 `json:"created,omitempty" db:"created" bson:"created"`
Subtopic string `json:"subtopic,omitempty" db:"subtopic" bson:"subtopic,omitempty"`
Publisher string `json:"publisher,omitempty" db:"publisher" bson:"publisher"`
Protocol string `json:"protocol,omitempty" db:"protocol" bson:"protocol"`
Payload []byte `json:"payload,omitempty" db:"payload" bson:"payload,omitempty"`
}
Message represents a JSON messages.
Click to show internal directories.
Click to hide internal directories.