Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type KXReadRTDBActivity ¶
type KXReadRTDBActivity struct {
// contains filtered or unexported fields
}
KXReadRTDBActivity is an Activity that is used to deserialize messages from KXDataProc, to get changes to invoke other activities
func (*KXReadRTDBActivity) Eval ¶
func (a *KXReadRTDBActivity) Eval(context activity.Context) (done bool, err error)
Eval implements api.Activity.Eval - Logs the Message
func (*KXReadRTDBActivity) Metadata ¶
func (a *KXReadRTDBActivity) Metadata() *activity.Metadata
Metadata returns the activity's metadata
Click to show internal directories.
Click to hide internal directories.