A golang library for managing kinesis stream processing