redisRepository

package

v0.1.1 Latest Latest Go to latest Published: Dec 19, 2023 License: AGPL-3.0 Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type RedisEntity[ID RedisEntityId] interface {
	gpa.Entity[ID]
	GetKey() string
}

type RedisEntityId interface {
	gpa.Id
	ToString() string // redis key 가 string 임.
}

type RedisRepository[E RedisEntity[ID], ID RedisEntityId] interface {
	gpa.CrudRepository[E, ID]
}

func NewRedisRepository[E RedisEntity[ID], ID RedisEntityId](ctx context.Context, pipe redis.Pipeliner) RedisRepository[E, ID]

type RedisRepositoryImpl[E RedisEntity[ID], ID RedisEntityId] struct {
	// contains filtered or unexported fields
}

func NewRedisRepositoryImpl[E RedisEntity[ID], ID RedisEntityId](ctx context.Context, pipe redis.Pipeliner) *RedisRepositoryImpl[E, ID]

func (r *RedisRepositoryImpl[E, ID]) Delete(e E) error

func (r *RedisRepositoryImpl[E, ID]) DeleteAll(e ...E) (count int64, err error)

func (r *RedisRepositoryImpl[E, ID]) DeleteAllById(id ...ID) (count int64, err error)

func (r *RedisRepositoryImpl[E, ID]) DeleteById(id ID) error

func (r *RedisRepositoryImpl[E, ID]) FindAllById(id ...ID) (res []E, err error)

func (r *RedisRepositoryImpl[E, ID]) FindById(id ID) (e E, err error)

func (r *RedisRepositoryImpl[E, ID]) Save(e E) error

func (r *RedisRepositoryImpl[E, ID]) SaveAll(e ...E) (count int64, err error)