post

Documentation

Index

• func NewClient(logger log.Logger, conf *config.Config) (v1.PostServiceClient, error)
• func NewServer(logger log.Logger, repo Repository) v1.PostServiceServer
• type Post
• type Repository
  • func NewRepository(logger log.Logger, db *dbcontext.DB) Repository
• type Server
  • func (s Server) CreatePost(ctx context.Context, req *v1.CreatePostRequest) (*v1.CreatePostResponse, error)
  • func (s Server) DecrementCommentsCount(ctx context.Context, req *v1.DecrementCommentsCountRequest) (*v1.DecrementCommentsCountResponse, error)
  • func (s Server) DecrementCommentsCountCompensate(ctx context.Context, req *v1.DecrementCommentsCountRequest) (*v1.DecrementCommentsCountResponse, error)
  • func (s Server) DeletePost(ctx context.Context, req *v1.DeletePostRequest) (*v1.DeletePostResponse, error)
  • func (s Server) DeletePostCompensate(ctx context.Context, req *v1.DeletePostRequest) (*v1.DeletePostResponse, error)
  • func (s Server) GetPost(ctx context.Context, req *v1.GetPostRequest) (*v1.GetPostResponse, error)
  • func (s Server) IncrementCommentsCount(ctx context.Context, req *v1.IncrementCommentsCountRequest) (*v1.IncrementCommentsCountResponse, error)
  • func (s Server) IncrementCommentsCountCompensate(ctx context.Context, req *v1.IncrementCommentsCountRequest) (*v1.IncrementCommentsCountResponse, error)
  • func (s Server) ListPosts(ctx context.Context, req *v1.ListPostsRequest) (*v1.ListPostsResponse, error)
  • func (s Server) UpdatePost(ctx context.Context, req *v1.UpdatePostRequest) (*v1.UpdatePostResponse, error)

Functions

func NewClient

func NewClient(logger log.Logger, conf *config.Config) (v1.PostServiceClient, error)

func NewServer

func NewServer(logger log.Logger, repo Repository) v1.PostServiceServer

Types

type Post

type Post struct {
	ID            uint64         `json:"id"`
	UUID          string         `json:"uuid"`
	Title         string         `json:"title"`
	Content       string         `json:"content"`
	CommentsCount uint32         `json:"comments_count"`
	UserID        uint64         `json:"user_id"`
	CreatedAt     time.Time      `json:"created_at"`
	UpdatedAt     time.Time      `json:"updated_at"`
	DeletedAt     gorm.DeletedAt `json:"deleted_at"`
}

type Repository

type Repository interface {
	Get(ctx context.Context, id uint64) (*Post, error)
	GetWithUnscoped(ctx context.Context, id uint64) (*Post, error)
	Create(ctx context.Context, post *Post) error
	Update(ctx context.Context, post *Post) error
	UpdateWithUnscoped(ctx context.Context, post *Post) error
	Delete(ctx context.Context, id uint64) error
	DeleteByUUID(ctx context.Context, uuid string) error
	List(ctx context.Context, offset, limit int) ([]*Post, error)
	Count(ctx context.Context) (uint64, error)
}

func NewRepository

func NewRepository(logger log.Logger, db *dbcontext.DB) Repository

type Server

type Server struct {
	v1.UnimplementedPostServiceServer
	// contains filtered or unexported fields
}

func (Server) CreatePost

func (s Server) CreatePost(ctx context.Context, req *v1.CreatePostRequest) (*v1.CreatePostResponse, error)

func (Server) DecrementCommentsCount

func (s Server) DecrementCommentsCount(ctx context.Context, req *v1.DecrementCommentsCountRequest) (*v1.DecrementCommentsCountResponse, error)

func (Server) DecrementCommentsCountCompensate

func (s Server) DecrementCommentsCountCompensate(ctx context.Context, req *v1.DecrementCommentsCountRequest) (*v1.DecrementCommentsCountResponse, error)

func (Server) DeletePost

func (s Server) DeletePost(ctx context.Context, req *v1.DeletePostRequest) (*v1.DeletePostResponse, error)

func (Server) DeletePostCompensate

func (s Server) DeletePostCompensate(ctx context.Context, req *v1.DeletePostRequest) (*v1.DeletePostResponse, error)

func (Server) GetPost

func (s Server) GetPost(ctx context.Context, req *v1.GetPostRequest) (*v1.GetPostResponse, error)

func (Server) IncrementCommentsCount

func (s Server) IncrementCommentsCount(ctx context.Context, req *v1.IncrementCommentsCountRequest) (*v1.IncrementCommentsCountResponse, error)

func (Server) IncrementCommentsCountCompensate

func (s Server) IncrementCommentsCountCompensate(ctx context.Context, req *v1.IncrementCommentsCountRequest) (*v1.IncrementCommentsCountResponse, error)

func (Server) ListPosts

func (s Server) ListPosts(ctx context.Context, req *v1.ListPostsRequest) (*v1.ListPostsResponse, error)

func (Server) UpdatePost

func (s Server) UpdatePost(ctx context.Context, req *v1.UpdatePostRequest) (*v1.UpdatePostResponse, error)