kinesis

Documentation

Index

• func New(opts *backend.Opts) (backend.Backend, error)
• type BackendImpl
  • func (b *BackendImpl) Check(topic string) error
  • func (b *BackendImpl) Close() error
  • func (b *BackendImpl) Publish(topic string, data []byte) error
  • func (b *BackendImpl) Subscribe(topic string, cb backend.Handler)

Functions

func New

func New(opts *backend.Opts) (backend.Backend, error)

New returns a kinesis backend with the corresponding AWS config initialized. Certain configuratino attributes specific to aws-sdk-go must be defined by the user of the adapter via environment variables.

Types

type BackendImpl

type BackendImpl struct {

	// AWS clients
	Kinesis  kinesisiface.KinesisAPI
	DynamoDB dynamodbiface.DynamoDBAPI
	// contains filtered or unexported fields
}

func (*BackendImpl) Check

func (b *BackendImpl) Check(topic string) error

func (*BackendImpl) Close

func (b *BackendImpl) Close() error

func (*BackendImpl) Publish

func (b *BackendImpl) Publish(topic string, data []byte) error

func (*BackendImpl) Subscribe

func (b *BackendImpl) Subscribe(topic string, cb backend.Handler)