rdbprojectionbase

Documentation

Index

• Constants
• type Base
  • func NewRDbBase(rdbHandle *rdb.Handle, projectionId string) *Base
  • func NewRDbBaseWithOptions(rdbHandle *rdb.Handle, projectionId string, options Options) *Base
  • func (base *Base) GetLastHandledEventHeight() (*int64, error)
  • func (base *Base) UpdateLastHandledEventHeight(rdbHandle *rdb.Handle, height int64) error
• type Options
• type Store
  • func NewStore(table string) *Store
  • func (impl *Store) GetLastHandledEventHeight(rdbHandle *rdb.Handle, projectionId string) (*int64, error)
  • func (impl *Store) UpdateLastHandledEventHeight(rdbHandle *rdb.Handle, projectionId string, height int64) error

Constants

const DEFAULT_TABLE = "projections"

Types

type Base

type Base struct {
	projection_usecase.Base
	// contains filtered or unexported fields
}

Base is a bas for projection which keeps track of last handled event height using relational database. It implements Id() and GetLastHandledEventHeight() of projection interface.

func NewRDbBase

func NewRDbBase(rdbHandle *rdb.Handle, projectionId string) *Base

Create a new Base using table name in the RDb to keep the projection handling records

func NewRDbBaseWithOptions

func NewRDbBaseWithOptions(rdbHandle *rdb.Handle, projectionId string, options Options) *Base

func (*Base) GetLastHandledEventHeight

func (base *Base) GetLastHandledEventHeight() (*int64, error)

Implements projection.GetLastHandledEventHeight()

func (*Base) UpdateLastHandledEventHeight

func (base *Base) UpdateLastHandledEventHeight(rdbHandle *rdb.Handle, height int64) error

type Options

type Options struct {
	// Pointer to the configuration
	MaybeConfigPtr interface{}

	// Customize table name in the RDb too keep the projection handling records
	MaybeTable *string
}

type Store

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

Store is an implementation of the RDbStore

func NewStore

func NewStore(table string) *Store

func (*Store) GetLastHandledEventHeight

func (impl *Store) GetLastHandledEventHeight(rdbHandle *rdb.Handle, projectionId string) (*int64, error)

GetLastHandledEventHeight returns the last handled event height, nil if no event has been handled

func (*Store) UpdateLastHandledEventHeight

func (impl *Store) UpdateLastHandledEventHeight(rdbHandle *rdb.Handle, projectionId string, height int64) error

UpdateLastHandledEventHeight update last handled event height of projection id to provided height