server

Documentation

Index

• type ArticleServer
  • func MakeArticleServer(d Dependencies) ArticleServer
  • func (ArticleServer) AuthMatcher() selector.Matcher
  • func (s ArticleServer) Create(ctx context.Context, req *pb.CreateArticleRequest) (_ *pb.CreateArticleResponse, err error)
  • func (s ArticleServer) Delete(ctx context.Context, req *pb.DeleteArticleRequest) (_ *emptypb.Empty, err error)
  • func (s ArticleServer) Get(ctx context.Context, req *pb.GetArticleRequest) (_ *pb.GetArticleResponse, err error)
  • func (s ArticleServer) GetStream(req *pb.GetArticlesRequest, stream pb.ArticleService_GetStreamServer) (err error)
  • func (s ArticleServer) Update(ctx context.Context, req *pb.UpdateArticleRequest) (_ *emptypb.Empty, err error)
  • func (s ArticleServer) ValidateRequestInterceptor() grpc.UnaryServerInterceptor
• type Dependencies
• type Services

Types

type ArticleServer

type ArticleServer struct {
	pb.UnimplementedArticleServiceServer
	// contains filtered or unexported fields
}

func MakeArticleServer

func MakeArticleServer(d Dependencies) ArticleServer

func (ArticleServer) AuthMatcher

func (ArticleServer) AuthMatcher() selector.Matcher

AuthMatcher returns a callback used to determine whether current gRPC path should be protected by auth middleware.

func (ArticleServer) Create

func (s ArticleServer) Create(ctx context.Context, req *pb.CreateArticleRequest) (_ *pb.CreateArticleResponse, err error)

func (ArticleServer) Delete

func (s ArticleServer) Delete(ctx context.Context, req *pb.DeleteArticleRequest) (_ *emptypb.Empty, err error)

func (ArticleServer) Get

func (s ArticleServer) Get(ctx context.Context, req *pb.GetArticleRequest) (_ *pb.GetArticleResponse, err error)

func (ArticleServer) GetStream

func (s ArticleServer) GetStream(req *pb.GetArticlesRequest, stream pb.ArticleService_GetStreamServer) (err error)

func (ArticleServer) Update

func (s ArticleServer) Update(ctx context.Context, req *pb.UpdateArticleRequest) (_ *emptypb.Empty, err error)

func (ArticleServer) ValidateRequestInterceptor

func (s ArticleServer) ValidateRequestInterceptor() grpc.UnaryServerInterceptor

type Dependencies

type Dependencies struct {
	Services   Services
	Query      storage.Getter
	Cmd        storage.Writer
	Dispatcher *dispatcher.Dispatcher
	Broker     event.Broker
	Parser     tokens.Parser
	Tracer     trace.Tracer
}

type Services

type Services struct {
	User userPb.UserServiceClient
	Auth authPb.AuthServiceClient
}