test

Documentation

Index

• Variables
• func GenerateRandomPort() string
• func NewCompressor(err error) compressor.Compressor
• func NewDatadogConfig() *opentracing.Config
• func NewGRPCClient(ctx context.Context, lc fx.Lifecycle, gcfg *tgrpc.Config, logger *zap.Logger, ...) *grpc.ClientConn
• func NewGRPCConfig() *grpc.Config
• func NewGRPCServer(lc fx.Lifecycle, logger *zap.Logger, cfg *opentracing.Config, verifyAuth bool, ...) (*grpc.Server, *tgrpc.Config)
• func NewHTTPClient(lc fx.Lifecycle, logger *zap.Logger, cfg *opentracing.Config) *http.Client
• func NewHTTPClientWithRoundTripper(lc fx.Lifecycle, logger *zap.Logger, cfg *opentracing.Config, ...) *http.Client
• func NewHTTPConfig() *http.Config
• func NewHTTPServer(lc fx.Lifecycle, logger *zap.Logger, cfg *opentracing.Config) (*shttp.Server, string)
• func NewJaegerConfig() *opentracing.Config
• func NewLogger(lc fx.Lifecycle) *zap.Logger
• func NewMarshaller(err error) marshaller.Marshaller
• func NewNSQConfig() *nsq.Config
• func NewPGConfig() *pg.Config
• func NewRedisCache(lc fx.Lifecycle, host string, logger *zap.Logger, ...) *cache.Cache
• func NewRistrettoCache(lc fx.Lifecycle) *ristretto.Cache
• 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 Migrator
  • func NewMigrator() *Migrator
  • func (m *Migrator) Drop() error
  • func (m *Migrator) Up() error
• 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 (s *Shutdowner) Called() bool
  • func (s *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 ...

var Version = version.Version("1.0.0")

Version for test.

Functions

func GenerateRandomPort

func GenerateRandomPort() string

GenerateRandomPort for test.

func NewCompressor

func NewCompressor(err error) compressor.Compressor

NewCompressor for test.

func NewDatadogConfig

func NewDatadogConfig() *opentracing.Config

NewDatadogConfig for test.

func NewGRPCClient

func NewGRPCClient(
	ctx context.Context, lc fx.Lifecycle, gcfg *tgrpc.Config,
	logger *zap.Logger, cfg *opentracing.Config,
	cred credentials.PerRPCCredentials,
) *grpc.ClientConn

NewGRPCClient for test.

func NewGRPCConfig

func NewGRPCConfig() *grpc.Config

NewGRPCConfig for test.

func NewGRPCServer

func NewGRPCServer(
	lc fx.Lifecycle, logger *zap.Logger, cfg *opentracing.Config, verifyAuth bool,
	unary []grpc.UnaryServerInterceptor, stream []grpc.StreamServerInterceptor,
) (*grpc.Server, *tgrpc.Config)

NewGRPCServer for test.

func NewHTTPClient

func NewHTTPClient(lc fx.Lifecycle, logger *zap.Logger, cfg *opentracing.Config) *http.Client

NewHTTPClient for test.

func NewHTTPClientWithRoundTripper

func NewHTTPClientWithRoundTripper(lc fx.Lifecycle, logger *zap.Logger, cfg *opentracing.Config, roundTripper http.RoundTripper) *http.Client

NewHTTPClientWithRoundTripper for test.

func NewHTTPConfig

func NewHTTPConfig() *http.Config

NewHTTPConfig for test.

func NewHTTPServer

func NewHTTPServer(lc fx.Lifecycle, logger *zap.Logger, cfg *opentracing.Config) (*shttp.Server, string)

NewHTTPServer for test.

func NewJaegerConfig

func NewJaegerConfig() *opentracing.Config

NewJaegerConfig for test.

func NewLogger

func NewLogger(lc fx.Lifecycle) *zap.Logger

NewLogger for test.

func NewMarshaller

func NewMarshaller(err error) marshaller.Marshaller

NewMarshaller for test.

func NewNSQConfig

func NewNSQConfig() *nsq.Config

NewNSQConfig for test.

func NewPGConfig

func NewPGConfig() *pg.Config

NewPGConfig for test.

func NewRedisCache

func NewRedisCache(lc fx.Lifecycle, host string, logger *zap.Logger, compressor compressor.Compressor, marshaller marshaller.Marshaller) *cache.Cache

NewRedisCache for test.

func NewRistrettoCache

func NewRistrettoCache(lc fx.Lifecycle) *ristretto.Cache

NewRistrettoCache for test. nolint:gomnd

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 Migrator

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

Migrator for test.

func NewMigrator

func NewMigrator() *Migrator

NewMigrator for test.

func (*Migrator) Drop

func (m *Migrator) Drop() error

Drop the DB.

func (*Migrator) Up

func (m *Migrator) Up() error

Up to latest version.

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 {
	// contains filtered or unexported fields
}

func NewShutdowner

func NewShutdowner() *Shutdowner

func (*Shutdowner) Called

func (s *Shutdowner) Called() bool

func (*Shutdowner) Shutdown

func (s *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)