index

Documentation

Index

• type FilterIndex
  • func NewFilterIndex() *FilterIndex
  • func (index *FilterIndex) Delete(event *entity.Event) error
  • func (index *FilterIndex) FindAllByFields(fields types.Hash) (result []*entity.Event, err error)
  • func (index *FilterIndex) Insert(event *entity.Event) error
  • func (index *FilterIndex) Refresh(events []*entity.Event)
  • func (index *FilterIndex) Update(eventFrom, eventTo *entity.Event) error
• type ListIndex
  • func NewListIndex() *ListIndex
  • func (index *ListIndex) Delete(event *entity.Event) error
  • func (index *ListIndex) FindAll() []*entity.Event
  • func (index *ListIndex) Insert(event *entity.Event) error
  • func (index *ListIndex) Refresh(events []*entity.Event)
  • func (index *ListIndex) Update(eventFrom, eventTo *entity.Event) error
• type MapIndex
  • func NewMapIndex() *MapIndex
  • func (index *MapIndex) Delete(event *entity.Event) error
  • func (index *MapIndex) FindAll() (result []*entity.Event)
  • func (index *MapIndex) FindByID(uuid [16]byte) (result *entity.Event, err error)
  • func (index *MapIndex) Insert(event *entity.Event) error
  • func (index *MapIndex) Refresh(events []*entity.Event)
  • func (index *MapIndex) Update(eventFrom, eventTo *entity.Event) error

Types

type FilterIndex

type FilterIndex struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewFilterIndex

func NewFilterIndex() *FilterIndex

func (*FilterIndex) Delete

func (index *FilterIndex) Delete(event *entity.Event) error

func (*FilterIndex) FindAllByFields

func (index *FilterIndex) FindAllByFields(fields types.Hash) (result []*entity.Event, err error)

func (*FilterIndex) Insert

func (index *FilterIndex) Insert(event *entity.Event) error

func (*FilterIndex) Refresh

func (index *FilterIndex) Refresh(events []*entity.Event)

func (*FilterIndex) Update

func (index *FilterIndex) Update(eventFrom, eventTo *entity.Event) error

type ListIndex

type ListIndex struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewListIndex

func NewListIndex() *ListIndex

func (*ListIndex) Delete

func (index *ListIndex) Delete(event *entity.Event) error

func (*ListIndex) FindAll

func (index *ListIndex) FindAll() []*entity.Event

func (*ListIndex) Insert

func (index *ListIndex) Insert(event *entity.Event) error

func (*ListIndex) Refresh

func (index *ListIndex) Refresh(events []*entity.Event)

func (*ListIndex) Update

func (index *ListIndex) Update(eventFrom, eventTo *entity.Event) error

type MapIndex

type MapIndex struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewMapIndex

func NewMapIndex() *MapIndex

func (*MapIndex) Delete

func (index *MapIndex) Delete(event *entity.Event) error

func (*MapIndex) FindAll

func (index *MapIndex) FindAll() (result []*entity.Event)

func (*MapIndex) FindByID

func (index *MapIndex) FindByID(uuid [16]byte) (result *entity.Event, err error)

func (*MapIndex) Insert

func (index *MapIndex) Insert(event *entity.Event) error

func (*MapIndex) Refresh

func (index *MapIndex) Refresh(events []*entity.Event)

func (*MapIndex) Update

func (index *MapIndex) Update(eventFrom, eventTo *entity.Event) error