ddbinstall

Documentation

Index

• type DB
  • func NewDB() DB
• type Stream
  • func NewStream(lambda string) Stream
• type StreamViewType
• type Streams
  • func NewStreams(viewType StreamViewType, streams ...Stream) Streams
• type Table
• type TableAbstraction
  • func NewTableAbstraction(db DB, record ssddb.DataRecord, log ss.Log) TableAbstraction
  • func (table TableAbstraction) Create(indexRecords []ssddb.IndexRecord) error
  • func (table TableAbstraction) Delete() error
  • func (table TableAbstraction) EnableStreams(streams Streams) error
  • func (table TableAbstraction) EnableTimeToLive(fieldName string) error
  • func (table TableAbstraction) GetName() string
  • func (table TableAbstraction) Log() ss.LogStream
  • func (table TableAbstraction) Wait() error
  • func (table TableAbstraction) WaitUntilNotExists() error

Types

type DB

type DB interface {
	CreateTable(dynamodb.CreateTableInput) error
	DescribeTable(dynamodb.DescribeTableInput,
	) (dynamodb.DescribeTableOutput, error)
	UpdateTable(dynamodb.UpdateTableInput) error
	UpdateTimeToLive(dynamodb.UpdateTimeToLiveInput) error
	DeleteTable(dynamodb.DeleteTableInput) error
	WaitTable(dynamodb.DescribeTableInput) error
	WaitUntilTableNotExists(dynamodb.DescribeTableInput) error
}

DB describes database interface for installer.

func NewDB

func NewDB() DB

type Stream

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

func NewStream

func NewStream(lambda string) Stream

type StreamViewType

type StreamViewType string

const (
	StreamViewTypeNone StreamViewType = ddb.StreamViewTypeKeysOnly
	StreamViewTypePrev StreamViewType = ddb.StreamViewTypeOldImage
	StreamViewTypeNew  StreamViewType = ddb.StreamViewTypeNewImage
	StreamViewTypeFull StreamViewType = ddb.StreamViewTypeNewAndOldImages
)

type Streams

type Streams struct {
	ViewType StreamViewType
	Streams  []Stream
}

func NewStreams

func NewStreams(viewType StreamViewType, streams ...Stream) Streams

type Table

type Table interface {
	GetName() string
	Log() ss.LogStream

	Create() error
	Delete() error

	Setup() error

	Wait() error
	WaitUntilNotExists() error

	InsertData() error
}

Table describes table installing interface.

type TableAbstraction

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

func NewTableAbstraction

func NewTableAbstraction(
	db DB,
	record ssddb.DataRecord,
	log ss.Log,
) TableAbstraction

func (TableAbstraction) Create

func (table TableAbstraction) Create(
	indexRecords []ssddb.IndexRecord,
) error

func (TableAbstraction) Delete

func (table TableAbstraction) Delete() error

func (TableAbstraction) EnableStreams

func (table TableAbstraction) EnableStreams(streams Streams) error

func (TableAbstraction) EnableTimeToLive

func (table TableAbstraction) EnableTimeToLive(fieldName string) error

func (TableAbstraction) GetName

func (table TableAbstraction) GetName() string

func (TableAbstraction) Log

func (table TableAbstraction) Log() ss.LogStream

func (TableAbstraction) Wait

func (table TableAbstraction) Wait() error

func (TableAbstraction) WaitUntilNotExists

func (table TableAbstraction) WaitUntilNotExists() error