kinesis

Documentation

Index

• type KinesisConfiguration
• type KinesisIngestor
  • func New() (*KinesisIngestor, error)
  • func (k *KinesisIngestor) GetEvents() error
  • func (k *KinesisIngestor) Initialize() error
  • func (k *KinesisIngestor) Shutdown(failure bool) error

Types

type KinesisConfiguration

type KinesisConfiguration struct {
	Address string `json:"address,omitempty"`
}

type KinesisIngestor

type KinesisIngestor struct {
	Address string
	Port    int
}

func New

func New() (*KinesisIngestor, error)

func (*KinesisIngestor) GetEvents

func (k *KinesisIngestor) GetEvents() error

func (*KinesisIngestor) Initialize

func (k *KinesisIngestor) Initialize() error

func (*KinesisIngestor) Shutdown

func (k *KinesisIngestor) Shutdown(failure bool) error