storages

Documentation

Overview

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

Index

• Constants
• type IDGenerator
  • func (g *IDGenerator) Register(T resources.T, genFunc func() (interface{}, error))
• 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, id interface{}) error
  • func (s *Memory) EntityTypeNameFor(T interface{}) string
  • func (s *Memory) Events() []MemoryEvent
  • func (s *Memory) FindAll(ctx context.Context, T interface{}) iterators.Interface
  • func (s *Memory) FindByID(ctx context.Context, ptr interface{}, id interface{}) (_found bool, _err error)
  • func (s *Memory) IDGenerator() *IDGenerator
  • func (s *Memory) InTx(ctx context.Context, fn func(tx *MemoryTransaction) error) error
  • func (s *Memory) LogContextHistory(l logger, ctx context.Context)
  • func (s *Memory) LogHistory(l logger)
  • func (s *Memory) LookupTx(ctx context.Context) (*MemoryTransaction, bool)
  • func (s *Memory) RollbackTx(ctx context.Context) error
  • func (s *Memory) SubscribeToCreate(ctx context.Context, T interface{}, subscriber resources.Subscriber) (resources.Subscription, error)
  • func (s *Memory) SubscribeToDeleteAll(ctx context.Context, T interface{}, subscriber resources.Subscriber) (resources.Subscription, error)
  • func (s *Memory) SubscribeToDeleteByID(ctx context.Context, T interface{}, subscriber resources.Subscriber) (resources.Subscription, error)
  • func (s *Memory) SubscribeToUpdate(ctx context.Context, 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 MemoryTableView
  • func (v MemoryTableView) FindByID(id interface{}) interface{}
• type MemoryTransaction
  • func (tx *MemoryTransaction) AddEvent(event MemoryEvent)
  • func (tx *MemoryTransaction) Events() []MemoryEvent
  • func (tx *MemoryTransaction) View() MemoryView
  • func (tx *MemoryTransaction) ViewFor(T interface{}) MemoryTableView
• type MemoryView
• type TraceElem

Constants

const (
	BeginTxEvent    = `BeginTx`
	CommitTxEvent   = `CommitTx`
	RollbackTxEvent = `RollbackTx`
	CreateEvent     = `Create`
	UpdateEvent     = `Update`
	DeleteAllEvent  = `DeleteAll`
	DeleteByIDEvent = `DeleteByID`
)

Types

type IDGenerator

type IDGenerator map[string]func() (interface{}, error)

func (*IDGenerator) Register

func (g *IDGenerator) Register(T resources.T, genFunc func() (interface{}, error))

type Memory

type Memory struct {
	Options struct {
		DisableEventLogging                  bool
		DisableAsyncSubscriptionHandling     bool
		DisableRelativePathResolvingForTrace bool
	}
	// 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, id interface{}) error

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{}) iterators.Interface

func (*Memory) FindByID

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

func (*Memory) IDGenerator

func (s *Memory) IDGenerator() *IDGenerator

func (*Memory) InTx

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

func (*Memory) LogContextHistory

func (s *Memory) LogContextHistory(l logger, ctx context.Context)

func (*Memory) LogHistory

func (s *Memory) LogHistory(l logger)

func (*Memory) LookupTx

func (s *Memory) LookupTx(ctx context.Context) (*MemoryTransaction, bool)

func (*Memory) RollbackTx

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

func (*Memory) SubscribeToCreate

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

func (*Memory) SubscribeToDeleteAll

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

func (*Memory) SubscribeToDeleteByID

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

func (*Memory) SubscribeToUpdate

func (s *Memory) SubscribeToUpdate(ctx context.Context, 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             interface{}
	Entity         interface{}
	Trace          []TraceElem
}

type MemoryEventManager

type MemoryEventManager interface {
	AddEvent(MemoryEvent)
	MemoryEventViewer
}

type MemoryEventViewer

type MemoryEventViewer interface {
	Events() []MemoryEvent
}

type MemoryTableView

type MemoryTableView map[string]interface{} // id => entity <T>

func (MemoryTableView) FindByID

func (v MemoryTableView) FindByID(id interface{}) interface{}

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() MemoryView

func (*MemoryTransaction) ViewFor

func (tx *MemoryTransaction) ViewFor(T interface{}) MemoryTableView

type MemoryView

type MemoryView map[string]MemoryTableView // entity type name => table view

type TraceElem

type TraceElem struct {
	Path string
	Line int
}