cachecontracts

Documentation

Index

• type Cache
• type EntityRepository
  • func (c EntityRepository[Entity, ID]) Benchmark(b *testing.B)
  • func (c EntityRepository[Entity, ID]) Spec(s *testcase.Spec)
  • func (c EntityRepository[Entity, ID]) Test(t *testing.T)
• type Manager
  • func (c Manager[Entity, ID]) Benchmark(b *testing.B)
  • func (c Manager[Entity, ID]) ManagerSubject() testcase.Var[ManagerSubject[Entity, ID]]
  • func (c Manager[Entity, ID]) Spec(s *testcase.Spec)
  • func (c Manager[Entity, ID]) Test(t *testing.T)
• type ManagerSubject
• type Repository
  • func (c Repository[Entity, ID]) Benchmark(b *testing.B)
  • func (c Repository[Entity, ID]) Spec(s *testcase.Spec)
  • func (c Repository[Entity, ID]) Test(t *testing.T)
• type SpySource
  • func (stub *SpySource[Entity, ID]) FindByID(ctx context.Context, id ID) (_ent Entity, _found bool, _err error)

Types

type Cache

type Cache[Entity, ID any] interface {
	crud.Creator[Entity]
	crud.Finder[Entity, ID]
	crud.Updater[Entity]
	crud.Deleter[ID]
	pubsub.CreatorPublisher[Entity]
	pubsub.UpdaterPublisher[Entity]
	pubsub.DeleterPublisher[ID]
}

type EntityRepository

type EntityRepository[Entity, ID any] struct {
	MakeSubject func(testing.TB) (cache.EntityRepository[Entity, ID], comproto.OnePhaseCommitProtocol)
	MakeContext func(testing.TB) context.Context
	MakeEntity  func(testing.TB) Entity
}

func (EntityRepository[Entity, ID]) Benchmark

func (c EntityRepository[Entity, ID]) Benchmark(b *testing.B)

func (EntityRepository[Entity, ID]) Spec

func (c EntityRepository[Entity, ID]) Spec(s *testcase.Spec)

func (EntityRepository[Entity, ID]) Test

func (c EntityRepository[Entity, ID]) Test(t *testing.T)

type Manager

type Manager[Entity, ID any] struct {
	MakeSubject func(testing.TB) ManagerSubject[Entity, ID]
	MakeContext func(testing.TB) context.Context
	MakeEntity  func(testing.TB) Entity
}

func (Manager[Entity, ID]) Benchmark

func (c Manager[Entity, ID]) Benchmark(b *testing.B)

func (Manager[Entity, ID]) ManagerSubject

func (c Manager[Entity, ID]) ManagerSubject() testcase.Var[ManagerSubject[Entity, ID]]

func (Manager[Entity, ID]) Spec

func (c Manager[Entity, ID]) Spec(s *testcase.Spec)

func (Manager[Entity, ID]) Test

func (c Manager[Entity, ID]) Test(t *testing.T)

type ManagerSubject

type ManagerSubject[Entity, ID any] struct {
	Cache         Cache[Entity, ID]
	Source        cache.Source[Entity, ID]
	CommitManager comproto.OnePhaseCommitProtocol
}

type Repository

type Repository[Entity, ID any] struct {
	MakeSubject func(testing.TB) cache.Repository[Entity, ID]
	MakeContext func(testing.TB) context.Context
	MakeEntity  func(testing.TB) Entity
}

func (Repository[Entity, ID]) Benchmark

func (c Repository[Entity, ID]) Benchmark(b *testing.B)

func (Repository[Entity, ID]) Spec

func (c Repository[Entity, ID]) Spec(s *testcase.Spec)

func (Repository[Entity, ID]) Test

func (c Repository[Entity, ID]) Test(t *testing.T)

type SpySource

type SpySource[Entity, ID any] struct {
	cache.Source[Entity, ID]
	// contains filtered or unexported fields
}

func (*SpySource[Entity, ID]) FindByID

func (stub *SpySource[Entity, ID]) FindByID(ctx context.Context, id ID) (_ent Entity, _found bool, _err error)