dynostream

README

dynostream

Easy to use Stream Subscriber for DynamoDB

Usage

package main

import (
	"context"
	"log"

	"github.com/0skillallluck/dynostream"
	"github.com/aws/aws-sdk-go/aws/session"
)

func main() {
	// Create a new AWS session
	sess := session.New()

	// Create a new DynoStream
	stream := dynostream.NewFromSession(sess, "my-table")

	// Create a new context for the subscription
	ctx := context.Background()

	// Subscribe to the stream
	channel, errorChannel := stream.Subscribe(ctx)

	// Handle errors
	go func(errCh <-chan error) {
		for err := range errCh {
			log.Println("Error: ", err)
		}
	}(errorChannel)

	// Handle records
	for record := range channel {
		log.Println("Record:", record)
	}
}

Documentation

Index

• type DynoStream
  • func New(db dynamodbiface.DynamoDBAPI, ...) *DynoStream
  • func NewFromSession(sess *session.Session, table string) *DynoStream
  • func (ds *DynoStream) Subscribe(ctx context.Context) (<-chan *dynamodbstreams.Record, <-chan error)

Types

type DynoStream

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

DynoStream is a struct that contains the DynamoDB and DynamoDBStreams interfaces as well as the name of the table to stream from.

func New

func New(db dynamodbiface.DynamoDBAPI, dbStreams dynamodbstreamsiface.DynamoDBStreamsAPI, table string) *DynoStream

New creates a new DynoStream struct from existing DynamoDB and DynamoDBStreams interfaces and the name of the table to stream from.

func NewFromSession

func NewFromSession(sess *session.Session, table string) *DynoStream

NewFromSession creates a new DynoStream struct from an existing AWS session and the name of the table to stream from.

func (*DynoStream) Subscribe

func (ds *DynoStream) Subscribe(ctx context.Context) (<-chan *dynamodbstreams.Record, <-chan error)

Subscribe creates a new subscription to the DynamoDB stream for the table specified in the DynoStream struct. It returns a channel of dynamodbstreams.Record structs and a channel of errors. The dynamodbstreams.Record channel will be closed when the context is closed.