kinesis

Documentation

Index

• func New(awsSession *session.Session, streamName string, logger logger.Logger) (store.Store, error)
• type KinesisStore
  • func (s *KinesisStore) InsertWebhook(source string, record interface{}) error

Functions

func New

func New(awsSession *session.Session, streamName string, logger logger.Logger) (store.Store, error)

Types

type KinesisStore

type KinesisStore struct {
	// contains filtered or unexported fields
}

func (*KinesisStore) InsertWebhook

func (s *KinesisStore) InsertWebhook(source string, record interface{}) error