Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BaseEvent ¶
type BaseEvent struct {
// contains filtered or unexported fields
}
BaseEvent provides common fields for events.
func NewBaseEvent ¶
NewBaseEvent creates a new BaseEvent with a unique ID and current timestamp.
type JsonCoder ¶ added in v0.2.17
type JsonCoder struct{}
JsonCoder implements eventbus.Coder for JSON.
func NewJsonCoder ¶ added in v0.2.17
func NewJsonCoder() *JsonCoder
NewJsonCoder creates a new JsonCoder.
type ProtoCoder ¶ added in v0.2.17
type ProtoCoder struct{}
ProtoCoder implements eventbus.Coder for Protobuf messages.
func NewProtoCoder ¶ added in v0.2.17
func NewProtoCoder() *ProtoCoder
NewProtoCoder creates a new ProtoCoder.
func (*ProtoCoder) Decode ¶ added in v0.2.17
func (c *ProtoCoder) Decode(data []byte, v interface{}) error
func (*ProtoCoder) Encode ¶ added in v0.2.17
func (c *ProtoCoder) Encode(v interface{}) ([]byte, error)
Click to show internal directories.
Click to hide internal directories.