persistence

Documentation

Index

• type CacheRedis
  • func NewCacheRedis(pool *redis.Client) *CacheRedis
  • func (c *CacheRedis) Invalidate(ctx context.Context, table, key string) error
  • func (c *CacheRedis) Read(ctx context.Context, table, key string) (string, error)
  • func (c *CacheRedis) Write(ctx context.Context, table, key string, value interface{}, ...) error
• type UserAWSRepository
  • func NewUserAWSRepository(c *cognito.CognitoIdentityProvider, k domain.KernelStore) *UserAWSRepository
  • func (r *UserAWSRepository) Fetch(ctx context.Context, criteria domain.Criteria) ([]*aggregate.UserRoot, domain.PaginationToken, error)
  • func (r *UserAWSRepository) FetchOne(ctx context.Context, byUsername bool, key string) (*aggregate.UserRoot, error)
  • func (r *UserAWSRepository) HardRemove(ctx context.Context, id string) error
  • func (r *UserAWSRepository) Remove(ctx context.Context, id string) error
  • func (r *UserAWSRepository) Restore(ctx context.Context, id string) error

Types

type CacheRedis

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

func NewCacheRedis

func NewCacheRedis(pool *redis.Client) *CacheRedis

func (*CacheRedis) Invalidate

func (c *CacheRedis) Invalidate(ctx context.Context, table, key string) error

func (*CacheRedis) Read

func (c *CacheRedis) Read(ctx context.Context, table, key string) (string, error)

func (*CacheRedis) Write

func (c *CacheRedis) Write(ctx context.Context, table, key string, value interface{}, duration time.Duration) error

type UserAWSRepository

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

func NewUserAWSRepository

func NewUserAWSRepository(c *cognito.CognitoIdentityProvider, k domain.KernelStore) *UserAWSRepository

func (*UserAWSRepository) Fetch

func (r *UserAWSRepository) Fetch(ctx context.Context, criteria domain.Criteria) ([]*aggregate.UserRoot, domain.PaginationToken, error)

func (*UserAWSRepository) FetchOne

func (r *UserAWSRepository) FetchOne(ctx context.Context, byUsername bool, key string) (*aggregate.UserRoot, error)

func (*UserAWSRepository) HardRemove

func (r *UserAWSRepository) HardRemove(ctx context.Context, id string) error

func (*UserAWSRepository) Remove

func (r *UserAWSRepository) Remove(ctx context.Context, id string) error

func (*UserAWSRepository) Restore

func (r *UserAWSRepository) Restore(ctx context.Context, id string) error