memory

Documentation

Index

• Variables
• type InMemory
  • func NewRepository() *InMemory
  • func (repo *InMemory) Delete(_ context.Context, agg aggregate.Aggregate[string]) error
  • func (repo *InMemory) Exists(_ context.Context, agg aggregate.Aggregate[string]) (bool, error)
  • func (repo *InMemory) ExistsVersion(_ context.Context, agg aggregate.Aggregate[string], version aggregate.Version) (bool, error)
  • func (repo *InMemory) Load(_ context.Context, agg aggregate.Aggregate[string]) error
  • func (repo *InMemory) LoadVersion(_ context.Context, agg aggregate.Aggregate[string], version aggregate.Version) error
  • func (repo *InMemory) Save(_ context.Context, agg aggregate.Aggregate[string]) error
  • func (repo *InMemory) Search(_ context.Context, opts ...aggregate.SearchOption) ([]aggregate.Aggregate[string], error)

Variables

var (
	ErrInvalidAggregateChangeID = errors.New("invalid aggregate change id")
)

Types

type InMemory

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

func NewRepository

func NewRepository() *InMemory

func (*InMemory) Delete

func (repo *InMemory) Delete(_ context.Context, agg aggregate.Aggregate[string]) error

func (*InMemory) Exists

func (repo *InMemory) Exists(_ context.Context, agg aggregate.Aggregate[string]) (bool, error)

func (*InMemory) ExistsVersion

func (repo *InMemory) ExistsVersion(_ context.Context, agg aggregate.Aggregate[string], version aggregate.Version) (bool, error)

func (*InMemory) Load

func (repo *InMemory) Load(_ context.Context, agg aggregate.Aggregate[string]) error

func (*InMemory) LoadVersion

func (repo *InMemory) LoadVersion(_ context.Context, agg aggregate.Aggregate[string], version aggregate.Version) error

func (*InMemory) Save

func (repo *InMemory) Save(_ context.Context, agg aggregate.Aggregate[string]) error

func (*InMemory) Search

func (repo *InMemory) Search(_ context.Context, opts ...aggregate.SearchOption) ([]aggregate.Aggregate[string], error)