server

Documentation

Index

• type Config
• type Dependencies
• type UserServer
  • func MakeUserServer(d Dependencies) UserServer
  • func (UserServer) AuthMatcher() selector.Matcher
  • func (s UserServer) Create(ctx context.Context, req *pb.CreateUserRequest) (_ *pb.CreateUserResponse, err error)
  • func (s UserServer) Delete(ctx context.Context, req *pb.DeleteUserRequest) (_ *emptypb.Empty, err error)
  • func (s UserServer) Get(ctx context.Context, req *pb.GetUserRequest) (_ *pb.GetUserResponse, err error)
  • func (s UserServer) GetSecret(ctx context.Context, req *pb.GetUserSecretRequest) (_ *pb.GetUserSecretResponse, err error)
  • func (s UserServer) GetStream(req *pb.GetUsersRequest, stream pb.UserService_GetStreamServer) (err error)
  • func (s UserServer) Update(ctx context.Context, req *pb.UpdateUserRequest) (_ *emptypb.Empty, err error)
  • func (s UserServer) ValidateRequestInterceptor() grpc.UnaryServerInterceptor

Types

type Config

type Config struct {
	VerifyClientCert bool
}

type Dependencies

type Dependencies struct {
	Storage storage.Storage
	Broker  event.Broker
	Logger  logging.Logger
	Tracer  trace.Tracer
	Config  Config
}

type UserServer

type UserServer struct {
	pb.UnimplementedUserServiceServer
	// contains filtered or unexported fields
}

func MakeUserServer

func MakeUserServer(d Dependencies) UserServer

func (UserServer) AuthMatcher

func (UserServer) AuthMatcher() selector.Matcher

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

func (UserServer) Create

func (s UserServer) Create(ctx context.Context, req *pb.CreateUserRequest) (_ *pb.CreateUserResponse, err error)

func (UserServer) Delete

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

func (UserServer) Get

func (s UserServer) Get(ctx context.Context, req *pb.GetUserRequest) (_ *pb.GetUserResponse, err error)

func (UserServer) GetSecret

func (s UserServer) GetSecret(ctx context.Context, req *pb.GetUserSecretRequest) (_ *pb.GetUserSecretResponse, err error)

func (UserServer) GetStream

func (s UserServer) GetStream(req *pb.GetUsersRequest, stream pb.UserService_GetStreamServer) (err error)

func (UserServer) Update

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

func (UserServer) ValidateRequestInterceptor

func (s UserServer) ValidateRequestInterceptor() grpc.UnaryServerInterceptor