dynamodb

Documentation

Index

• func NewDynamoDB(db repo.IRepo) common.ISource[option.Options]
• type DynamoDB
  • func (d *DynamoDB) GetCouchbaseIndexesQuery(bucket string, scope string, collection string) ([]common.Index, error)
  • func (d *DynamoDB) Init(opts *option.Options, documentKey common.ICBDocumentKey) error
  • func (d *DynamoDB) StreamData(ctx context.Context, mChan chan map[string]interface{}) error

Functions

func NewDynamoDB

func NewDynamoDB(db repo.IRepo) common.ISource[option.Options]

Types

type DynamoDB

type DynamoDB struct {
	CopyIndexes bool
	// contains filtered or unexported fields
}

func (*DynamoDB) GetCouchbaseIndexesQuery

func (d *DynamoDB) GetCouchbaseIndexesQuery(bucket string, scope string, collection string) ([]common.Index, error)

func (*DynamoDB) Init

func (d *DynamoDB) Init(opts *option.Options, documentKey common.ICBDocumentKey) error

func (*DynamoDB) StreamData

func (d *DynamoDB) StreamData(ctx context.Context, mChan chan map[string]interface{}) error