package
0.1.4
Repository: https://github.com/project-flogo/rules.git
Documentation: pkg.go.dev

# Functions

Create a new WebSocketPublisher Instance.
New creates a new kinesis publisher instance.
PublishAuditTrailItem creates Audit Trail entry and publishes it.
SetupKinesisPubSub sets up connection to kinesis and creates the stream if does not exist.

# Variables

AuditTrailChannel to receive audit trail item.
KPInstance is an instanceof Kinesis publisher.

# Structs

ConnectionConfig stores the local connection details.
Entry
Entry to record the trail of flow.

# Interfaces

KinesisPublisher interface providing basic communication methods.
WebSocketPublisher to publish data to web client.