cache

Documentation

Index

• Variables
• type InMemoryPostsLimit
• type InmemoryPostRepository
• type PersistentPostRepository
• type PostRepository
  • func NewCacheablePostRepository(inmemory InmemoryPostRepository, persistent PersistentPostRepository, ...) *PostRepository
  • func (r PostRepository) CreatePost(ctx context.Context, post domain.Post) error
  • func (r PostRepository) GetPosts(ctx context.Context, authorID uuid.UUID, followerID uuid.UUID, ...) (posts []domain.Post, err error)
• type Publisher

Variables

var (
	ErrCacheIsNotSet = errors.New("cache is not set")
)

Types

type InMemoryPostsLimit

type InMemoryPostsLimit int

type InmemoryPostRepository

type InmemoryPostRepository interface {
	GetPosts(
		ctx context.Context,
		followerID uuid.UUID,
		offset, limit int64,
	) (posts []domain.Post, err error)
	UpdateFollowerPosts(
		ctx context.Context,
		followerID uuid.UUID,
		posts []domain.Post,
	) (err error)
}

type PersistentPostRepository

type PersistentPostRepository interface {
	GetPosts(
		ctx context.Context,
		authorID uuid.UUID,
		followerID uuid.UUID,
		offset, limit int,
	) (posts []domain.Post, err error)
	CreatePost(
		ctx context.Context,
		msg domain.Post,
	) error
}

type PostRepository

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

func NewCacheablePostRepository

func NewCacheablePostRepository(
	inmemory InmemoryPostRepository,
	persistent PersistentPostRepository,
	publisher Publisher,
	inMemoryLimit InMemoryPostsLimit,
) *PostRepository

func (PostRepository) CreatePost

func (r PostRepository) CreatePost(
	ctx context.Context,
	post domain.Post,
) error

func (PostRepository) GetPosts

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

type Publisher

type Publisher interface {
	PublishUpdateNewsLinesCommand(ctx context.Context, followers []uuid.UUID) error
}