kinesisutil

package

v1.8.0 Latest Latest Go to latest Published: Jul 30, 2021 License: Apache-2.0 Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

func Connect(accountAccessKeyID, accountSecretAccessKey, region string, logger *zap.SugaredLogger) (*kinesis.Kinesis, error)

Connect creates a new Kinesis-Streaming connection.

func Create(ctx context.Context, client *kinesis.Kinesis, streamName string, streamShards int64) error

Create function creates kinesis stream.

func Delete(ctx context.Context, client *kinesis.Kinesis, streamName string) error

Delete function deletes kinesis stream by its name.

func Describe(ctx context.Context, client *kinesis.Kinesis, streamName string) (*kinesis.DescribeStreamOutput, error)

Describe accepts kinesis client and stream name and returns kinesis stream description.

func GetRecord(client *kinesis.Kinesis, shardIterator *string) (*kinesis.GetRecordsOutput, error)

GetRecord retrieves one stream record by specified shard iterator.

func GetShardIterators(ctx context.Context, client *kinesis.Kinesis, streamName *string) ([]*string, error)

GetShardIterators returns "latest" shard iterator for specified stream.

func Publish(ctx context.Context, client *kinesis.Kinesis, streamName string, msg []byte, logger *zap.SugaredLogger) error

Publish publishes msg to Kinesis stream.

func WaitUntilActive(ctx context.Context, client *kinesis.Kinesis, streamName string) error

Wait function periodically checks Kinesis stream status and returns if it's "Active"

This section is empty.