kinesis

Documentation

Index

• type Adapter
  • func (a *Adapter) Start(ctx context.Context, stopCh <-chan struct{}) error

Types

type Adapter

type Adapter struct {

	// StreamName is the Stream name
	StreamName string

	// Region is the Kinesis stream region
	Region string

	// SinkURI is the URI messages will be forwarded on to.
	SinkURI string

	// KCLIAMRoleARN is the pre-existing AWS IAM role to access Kinesis stream, it is required when using KIAM approach.
	KCLIAMRoleARN string

	// CredsFile is the full path of the AWS credentials file, it is required when using k8s secret approach.
	CredsFile string

	//Application consumer name
	ConsumerName string
	// contains filtered or unexported fields
}

Adapter implements the Kinesis adapter to deliver Kinesis messages from a stream to a Sink.

func (*Adapter) Start

func (a *Adapter) Start(ctx context.Context, stopCh <-chan struct{}) error

Start function