Documentation ¶
Index ¶
- func NewBytesMessage() component.Message
- func NewInterfaceMessage() component.Message
- type BytesMessage
- func (m BytesMessage) GetAttribute(attr string) interface{}
- func (m BytesMessage) GetData() interface{}
- func (m *BytesMessage) Release()
- func (m *BytesMessage) SetAttribute(attr string, value interface{})
- func (m *BytesMessage) SetData(data interface{})
- func (m BytesMessage) Status() *component.Report
- type InterfaceMessage
- func (m InterfaceMessage) GetAttribute(attr string) interface{}
- func (m InterfaceMessage) GetData() interface{}
- func (m *InterfaceMessage) Release()
- func (m *InterfaceMessage) SetAttribute(attr string, value interface{})
- func (m *InterfaceMessage) SetData(data interface{})
- func (m InterfaceMessage) Status() *component.Report
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewBytesMessage ¶
NewBytesMessage creates a new instance of BytesMessage
func NewInterfaceMessage ¶
NewInterfaceMessage creates a new instance of InterfaceMessage
Types ¶
type BytesMessage ¶
type BytesMessage struct {
// contains filtered or unexported fields
}
BytesMessage is a message implementation which wraps an array of bytes
func (BytesMessage) GetAttribute ¶
func (m BytesMessage) GetAttribute(attr string) interface{}
GetAttribute returns the attribute value for a given key
func (BytesMessage) GetData ¶
func (m BytesMessage) GetData() interface{}
GetData get the bytes array stored by the previous handler
func (*BytesMessage) Release ¶
func (m *BytesMessage) Release()
Release free resources associated to the message
func (*BytesMessage) SetAttribute ¶
func (m *BytesMessage) SetAttribute(attr string, value interface{})
SetAttribute sets the attribute value for a given key
func (*BytesMessage) SetData ¶
func (m *BytesMessage) SetData(data interface{})
SetData receives an interface that should be an array of bytes
func (BytesMessage) Status ¶
func (m BytesMessage) Status() *component.Report
Status returns a report of the data being processes by a worker
type InterfaceMessage ¶
type InterfaceMessage struct {
// contains filtered or unexported fields
}
InterfaceMessage is a message implementation which can contains anything
func (InterfaceMessage) GetAttribute ¶
func (m InterfaceMessage) GetAttribute(attr string) interface{}
GetAttribute returns the attribute value for a given key
func (InterfaceMessage) GetData ¶
func (m InterfaceMessage) GetData() interface{}
GetData get the bytes array stored by the previous handler
func (*InterfaceMessage) Release ¶
func (m *InterfaceMessage) Release()
Release free resources associated to the message
func (*InterfaceMessage) SetAttribute ¶
func (m *InterfaceMessage) SetAttribute(attr string, value interface{})
SetAttribute sets the attribute value for a given key
func (*InterfaceMessage) SetData ¶
func (m *InterfaceMessage) SetData(data interface{})
SetData receives an interface that should be an array of bytes
func (InterfaceMessage) Status ¶
func (m InterfaceMessage) Status() *component.Report
Status returns a report of the data being processes by a worker