storages

Documentation

Overview

TODO: make subscription publishing related to tx commit instead to be done on the fly

Index

• type History
  • func (h History) LogWith(l interface{ ... })
• type Memory
  • func NewMemory() *Memory
  • func (s *Memory) AddEvent(event MemoryEvent)
  • func (s *Memory) BeginTx(ctx context.Context) (context.Context, error)
  • func (s *Memory) CommitTx(ctx context.Context) error
  • func (s *Memory) Create(ctx context.Context, ptr interface{}) error
  • func (s *Memory) DeleteAll(ctx context.Context, T interface{}) error
  • func (s *Memory) DeleteByID(ctx context.Context, T interface{}, id string) error
  • func (s *Memory) DisableEventLogging()
  • func (s *Memory) EntityTypeNameFor(T interface{}) string
  • func (s *Memory) Events() []MemoryEvent
  • func (s *Memory) FindAll(ctx context.Context, T interface{}) frameless.Iterator
  • func (s *Memory) FindByID(ctx context.Context, ptr interface{}, id string) (_found bool, _err error)
  • func (s *Memory) History() History
  • func (s *Memory) InTx(ctx context.Context, fn func(tx *MemoryTransaction) error) error
  • func (s *Memory) RollbackTx(ctx context.Context) error
  • func (s *Memory) SubscribeToCreate(T interface{}, subscriber resources.Subscriber) (resources.Subscription, error)
  • func (s *Memory) SubscribeToDeleteAll(T interface{}, subscriber resources.Subscriber) (resources.Subscription, error)
  • func (s *Memory) SubscribeToDeleteByID(T interface{}, subscriber resources.Subscriber) (resources.Subscription, error)
  • func (s *Memory) SubscribeToUpdate(T interface{}, subscriber resources.Subscriber) (resources.Subscription, error)
  • func (s *Memory) Update(ctx context.Context, ptr interface{}) error
• type MemoryEvent
• type MemoryEventManager
• type MemoryEventViewer
• type MemoryTransaction
  • func (tx *MemoryTransaction) AddEvent(event MemoryEvent)
  • func (tx MemoryTransaction) Events() []MemoryEvent
  • func (tx MemoryTransaction) View() StorageEventView
• type StorageEventView

Types

type History

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

History will return a list of the event history of the

func (History) LogWith

func (h History) LogWith(l interface{ Log(args ...interface{}) })

type Memory

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

Memory is an event source principles based development in memory storage, that allows easy debugging and tracing during development for fast and descriptive feedback loops.

func NewMemory

func NewMemory() *Memory

func (*Memory) AddEvent

func (s *Memory) AddEvent(event MemoryEvent)

func (*Memory) BeginTx

func (s *Memory) BeginTx(ctx context.Context) (context.Context, error)

func (*Memory) CommitTx

func (s *Memory) CommitTx(ctx context.Context) error

func (*Memory) Create

func (s *Memory) Create(ctx context.Context, ptr interface{}) error

func (*Memory) DeleteAll

func (s *Memory) DeleteAll(ctx context.Context, T interface{}) error

func (*Memory) DeleteByID

func (s *Memory) DeleteByID(ctx context.Context, T interface{}, id string) error

func (*Memory) DisableEventLogging

func (s *Memory) DisableEventLogging()

func (*Memory) EntityTypeNameFor

func (s *Memory) EntityTypeNameFor(T interface{}) string

func (*Memory) Events

func (s *Memory) Events() []MemoryEvent

func (*Memory) FindAll

func (s *Memory) FindAll(ctx context.Context, T interface{}) frameless.Iterator

func (*Memory) FindByID

func (s *Memory) FindByID(ctx context.Context, ptr interface{}, id string) (_found bool, _err error)

func (*Memory) History

func (s *Memory) History() History

func (*Memory) InTx

func (s *Memory) InTx(ctx context.Context, fn func(tx *MemoryTransaction) error) error

func (*Memory) RollbackTx

func (s *Memory) RollbackTx(ctx context.Context) error

func (*Memory) SubscribeToCreate

func (s *Memory) SubscribeToCreate(T interface{}, subscriber resources.Subscriber) (resources.Subscription, error)

func (*Memory) SubscribeToDeleteAll

func (s *Memory) SubscribeToDeleteAll(T interface{}, subscriber resources.Subscriber) (resources.Subscription, error)

func (*Memory) SubscribeToDeleteByID

func (s *Memory) SubscribeToDeleteByID(T interface{}, subscriber resources.Subscriber) (resources.Subscription, error)

func (*Memory) SubscribeToUpdate

func (s *Memory) SubscribeToUpdate(T interface{}, subscriber resources.Subscriber) (resources.Subscription, error)

func (*Memory) Update

func (s *Memory) Update(ctx context.Context, ptr interface{}) error

type MemoryEvent

type MemoryEvent struct {
	T              interface{}
	EntityTypeName string
	Event          string
	ID             string
	Entity         interface{}
	Trace          []string
}

type MemoryEventManager

type MemoryEventManager interface {
	AddEvent(MemoryEvent)
	MemoryEventViewer
}

type MemoryEventViewer

type MemoryEventViewer interface {
	Events() []MemoryEvent
}

type MemoryTransaction

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

func (*MemoryTransaction) AddEvent

func (tx *MemoryTransaction) AddEvent(event MemoryEvent)

func (MemoryTransaction) Events

func (tx MemoryTransaction) Events() []MemoryEvent

func (MemoryTransaction) View

func (tx MemoryTransaction) View() StorageEventView

type StorageEventView

type StorageEventView map[string]map[string]interface{} // entity type name => id => entity