controller

Documentation

Index

• Variables
• type Article
  • func NewArticle(ctl *Controller, article *gateway.Article) *Article
  • func (a *Article) AddTag(ctx context.Context, req *connect.Request[articlev1.AddTagRequest]) (*connect.Response[articlev1.AddTagResponse], error)
  • func (a *Article) Delete(ctx context.Context, req *connect.Request[articlev1.DeleteRequest]) (*connect.Response[articlev1.DeleteResponse], error)
  • func (a *Article) List(ctx context.Context, req *connect.Request[articlev1.ListRequest]) (*connect.Response[articlev1.ListResponse], error)
  • func (a *Article) ListTag(ctx context.Context, req *connect.Request[articlev1.ListTagRequest]) (*connect.Response[articlev1.ListTagResponse], error)
  • func (a *Article) Read(ctx context.Context, req *connect.Request[articlev1.ReadRequest]) (*connect.Response[articlev1.ReadResponse], error)
  • func (a *Article) Share(ctx context.Context, req *connect.Request[articlev1.ShareRequest]) (*connect.Response[articlev1.ShareResponse], error)
• type Controller
  • func New(cache *redis.Client) *Controller
  • func (ctl *Controller) Authorize(ctx context.Context, header http.Header) (model.Auth, error)
  • func (ctl *Controller) GetSession(header http.Header) (string, error)
• type Health
  • func NewHealth() *Health
  • func (h *Health) Check(ctx context.Context, req *connect.Request[healthv1.CheckRequest]) (*connect.Response[healthv1.CheckResponse], error)
• type User
  • func NewUser(ctl *Controller, create port.CoreUserCreate) *User
  • func (us *User) Create(ctx context.Context, req *connect.Request[userv1.CreateRequest]) (*connect.Response[userv1.CreateResponse], error)
  • func (us *User) Update(ctx context.Context, req *connect.Request[userv1.UpdateRequest]) (*connect.Response[userv1.UpdateResponse], error)
• type Version
  • func NewVersion(version string) *Version
  • func (h *Version) Confirm(ctx context.Context, req *connect.Request[versionv1.ConfirmRequest]) (*connect.Response[versionv1.ConfirmResponse], error)

Variables

var ErrInternal = status.New(
	codes.Internal,
	"internal server",
).Err()

var ErrInvalidArgument = status.New(
	codes.InvalidArgument,
	"bad request",
).Err()

var ErrUnauthorized = status.New(
	codes.Unauthenticated,
	"unauthorized",
).Err()

Types

type Article

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

func NewArticle

func NewArticle(
	ctl *Controller,
	article *gateway.Article,
) *Article

func (*Article) AddTag

func (a *Article) AddTag(
	ctx context.Context,
	req *connect.Request[articlev1.AddTagRequest],
) (*connect.Response[articlev1.AddTagResponse], error)

func (*Article) Delete

func (a *Article) Delete(
	ctx context.Context,
	req *connect.Request[articlev1.DeleteRequest],
) (*connect.Response[articlev1.DeleteResponse], error)

func (*Article) List

func (a *Article) List(
	ctx context.Context,
	req *connect.Request[articlev1.ListRequest],
) (*connect.Response[articlev1.ListResponse], error)

func (*Article) ListTag

func (a *Article) ListTag(
	ctx context.Context,
	req *connect.Request[articlev1.ListTagRequest],
) (*connect.Response[articlev1.ListTagResponse], error)

func (*Article) Read

func (a *Article) Read(
	ctx context.Context,
	req *connect.Request[articlev1.ReadRequest],
) (*connect.Response[articlev1.ReadResponse], error)

func (*Article) Share

func (a *Article) Share(
	ctx context.Context,
	req *connect.Request[articlev1.ShareRequest],
) (*connect.Response[articlev1.ShareResponse], error)

type Controller

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

func New

func New(
	cache *redis.Client,
) *Controller

func (*Controller) Authorize

func (ctl *Controller) Authorize(ctx context.Context, header http.Header) (model.Auth, error)

func (*Controller) GetSession

func (ctl *Controller) GetSession(header http.Header) (string, error)

type Health

type Health struct{}

func NewHealth

func NewHealth() *Health

func (*Health) Check

func (h *Health) Check(
	ctx context.Context,
	req *connect.Request[healthv1.CheckRequest],
) (*connect.Response[healthv1.CheckResponse], error)

type User

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

func NewUser

func NewUser(
	ctl *Controller,
	create port.CoreUserCreate,
) *User

func (*User) Create

func (us *User) Create(
	ctx context.Context,
	req *connect.Request[userv1.CreateRequest],
) (*connect.Response[userv1.CreateResponse], error)

func (*User) Update

func (us *User) Update(
	ctx context.Context,
	req *connect.Request[userv1.UpdateRequest],
) (*connect.Response[userv1.UpdateResponse], error)

type Version

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

func NewVersion

func NewVersion(
	version string,
) *Version

func (*Version) Confirm

func (h *Version) Confirm(
	ctx context.Context,
	req *connect.Request[versionv1.ConfirmRequest],
) (*connect.Response[versionv1.ConfirmResponse], error)