Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Message ¶ added in v0.2.8
type Message struct { ProcessName string `json:"transformation_step"` Fragment desc.RemoteFragmentDesc `json:"description"` }
Message is the structure holding the lineage information of a fragment
func (*Message) Deserialize ¶ added in v0.2.8
Deserialize tries to decode a json encoded byte array into `msg`. Errors on failure
type MqTracker ¶ added in v0.2.8
type MqTracker struct { TransformationName string PipelineHash string ToLineate <-chan transmit.Serializable // desc.RemoteFragmentDesc Sender messageq.SimpleSender }
MqTracker posts lineage information to a designated message queue queue
func NewMqTracker ¶ added in v0.2.8
func NewMqTracker(processName, pipelineHash, brokerURL string, toLineate chan transmit.Serializable) MqTracker
NewMqTracker instantiates a new MqTracker
func (MqTracker) StartBlocking ¶ added in v0.2.8
func (tracker MqTracker) StartBlocking()
StartBlocking starts the main loop of the Tracker
Click to show internal directories.
Click to hide internal directories.