kinesisutil

Documentation

Index

• func Connect(accountAccessKeyID, accountSecretAccessKey, region string, ...) (*kinesis.Kinesis, error)
• func Create(ctx context.Context, client *kinesis.Kinesis, streamName string) error
• func Delete(ctx context.Context, client *kinesis.Kinesis, streamName string) error
• func Describe(ctx context.Context, client *kinesis.Kinesis, streamName string) (*kinesis.DescribeStreamOutput, error)
• func GetRecord(client *kinesis.Kinesis, shardIterator *string) (*kinesis.GetRecordsOutput, error)
• func GetShardIterator(ctx context.Context, client *kinesis.Kinesis, streamName *string) (*kinesis.GetShardIteratorOutput, error)
• func Publish(ctx context.Context, client *kinesis.Kinesis, streamName string, msg []byte, ...) error

Functions

func Connect

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

Connect creates a new Kinesis-Streaming connection

func Create

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

Create function creates kinesis stream

func Delete

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

Delete function deletes kinesis stream by its name

func Describe

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

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

GetRecord retrieves one stream record by specified shard iterator

func GetShardIterator

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

GetShardIterator returns "latest" shard iterator for specified stream

func Publish

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

Publish publishes msg to Kinesis stream