test

Documentation

Index

• Variables
• func GenerateRandomPort() string
• func NewGRPCConfig() *grpc.Config
• func NewHTTPClient(logger *zap.Logger, tracer opentracing.Tracer) *http.Client
• func NewHTTPClientWithRoundTripper(logger *zap.Logger, tracer opentracing.Tracer, roundTripper http.RoundTripper) *http.Client
• func NewHTTPConfig() *http.Config
• func NewJaegerConfig() *jaeger.Config
• func NewNSQConfig() *nsq.Config
• type Generator
  • func NewGenerator(token string, err error) *Generator
  • func (g *Generator) Generate(ctx context.Context) ([]byte, error)
• type Handler
  • func NewHandler(err error) *Handler
  • func (h *Handler) Handle(ctx context.Context, m *message.Message) error
  • func (h *Handler) Message() *message.Message
• type Server
  • func NewServer(verifyAuth bool) *Server
  • func (s *Server) SayHello(ctx context.Context, req *v1.SayHelloRequest) (*v1.SayHelloResponse, error)
  • func (s *Server) SayStreamHello(stream v1.GreeterService_SayStreamHelloServer) error
• type Shutdowner
  • func NewShutdowner() *Shutdowner
  • func (*Shutdowner) Shutdown(...fx.ShutdownOption) error
• type Verifier
  • func NewVerifier(token string) *Verifier
  • func (v *Verifier) Verify(ctx context.Context, token []byte) (*jwt.Token, error)

Variables

var ErrInvalidToken = errors.New("invalid token")

ErrInvalidToken ...

Functions

func GenerateRandomPort

func GenerateRandomPort() string

GenerateRandomPort for test.

func NewGRPCConfig

func NewGRPCConfig() *grpc.Config

NewGRPCConfig for test.

func NewHTTPClient

func NewHTTPClient(logger *zap.Logger, tracer opentracing.Tracer) *http.Client

NewHTTPClient for test.

func NewHTTPClientWithRoundTripper

func NewHTTPClientWithRoundTripper(logger *zap.Logger, tracer opentracing.Tracer, roundTripper http.RoundTripper) *http.Client

NewHTTPClientWithRoundTripper for test.

func NewHTTPConfig

func NewHTTPConfig() *http.Config

NewHTTPConfig for test.

func NewJaegerConfig

func NewJaegerConfig() *jaeger.Config

NewJaegerConfig for test.

func NewNSQConfig

func NewNSQConfig() *nsq.Config

NewNSQConfig for test.

Types

type Generator

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

Generator for test.

func NewGenerator

func NewGenerator(token string, err error) *Generator

NewGenerator for test.

func (*Generator) Generate

func (g *Generator) Generate(ctx context.Context) ([]byte, error)

type Handler

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

Handler for test.

func NewHandler

func NewHandler(err error) *Handler

NewHandler for test.

func (*Handler) Handle

func (h *Handler) Handle(ctx context.Context, m *message.Message) error

func (*Handler) Message

func (h *Handler) Message() *message.Message

type Server

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

Server ...

func NewServer

func NewServer(verifyAuth bool) *Server

NewServer ...

func (*Server) SayHello

func (s *Server) SayHello(ctx context.Context, req *v1.SayHelloRequest) (*v1.SayHelloResponse, error)

SayHello ...

func (*Server) SayStreamHello

func (s *Server) SayStreamHello(stream v1.GreeterService_SayStreamHelloServer) error

SayStreamHello ...

type Shutdowner

type Shutdowner struct{}

func NewShutdowner

func NewShutdowner() *Shutdowner

func (*Shutdowner) Shutdown

func (*Shutdowner) Shutdown(...fx.ShutdownOption) error

type Verifier

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

Verifier for test.

func NewVerifier

func NewVerifier(token string) *Verifier

NewVerifier for test.

func (*Verifier) Verify

func (v *Verifier) Verify(ctx context.Context, token []byte) (*jwt.Token, error)

nolint:goerr113