redis

Documentation

Index

• type InMemoryPostsLimit
• type PostRepository
  • func NewPostRepository(rdb *redis.Client, inmemoryLimit InMemoryPostsLimit) *PostRepository
  • func (r PostRepository) GetPosts(ctx context.Context, followerID uuid.UUID, offset, limit int64) (posts []domain.Post, err error)
  • func (r PostRepository) UpdateFollowerPosts(ctx context.Context, followerID uuid.UUID, posts []domain.Post) (err error)

Types

type InMemoryPostsLimit

type InMemoryPostsLimit int

type PostRepository

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

func NewPostRepository

func NewPostRepository(
	rdb *redis.Client,
	inmemoryLimit InMemoryPostsLimit,
) *PostRepository

func (PostRepository) GetPosts

func (r PostRepository) GetPosts(
	ctx context.Context,
	followerID uuid.UUID,
	offset, limit int64,
) (posts []domain.Post, err error)

func (PostRepository) UpdateFollowerPosts

func (r PostRepository) UpdateFollowerPosts(
	ctx context.Context,
	followerID uuid.UUID,
	posts []domain.Post,
) (err error)