test

Documentation

Index

• Variables
• func GenerateRandomPort() string
• func NewCmdConfig(flag string) (*cmd.Config, error)
• func NewCompressor(err error) compressor.Compressor
• func NewGRPCClient(ctx context.Context, lc fx.Lifecycle, logger *zap.Logger, ...) *grpc.ClientConn
• func NewGRPCServer(lc fx.Lifecycle, logger *zap.Logger, cfg *otel.Config, tcfg *transport.Config, ...) *tgrpc.Server
• func NewHTTPClient(lc fx.Lifecycle, logger *zap.Logger, cfg *otel.Config, tcfg *transport.Config) *http.Client
• func NewHTTPClientWithRoundTripper(lc fx.Lifecycle, logger *zap.Logger, cfg *otel.Config, tcfg *transport.Config, ...) *http.Client
• func NewHTTPServer(lc fx.Lifecycle, logger *zap.Logger, cfg *otel.Config, tcfg *transport.Config) *shttp.Server
• func NewLogger(lc fx.Lifecycle) *zap.Logger
• func NewMarshaller(err error) marshaller.Marshaller
• func NewOTELConfig() *otel.Config
• func NewPGConfig() *pg.Config
• func NewRedisCache(lc fx.Lifecycle, host string, logger *zap.Logger, ...) *cache.Cache
• func NewRedisClient(lc fx.Lifecycle, host string, logger *zap.Logger) client.Client
• func NewRedisConfig(host string) *redis.Config
• func NewRistrettoCache(lc fx.Lifecycle) *ristretto.Cache
• func NewTransportConfig() *transport.Config
• func RegisterTransport(lc fx.Lifecycle, cfg *transport.Config, gs *tgrpc.Server, hs *shttp.Server)
• type Config
  • func (cfg *Config) Auth0Config() *auth0.Config
  • func (cfg *Config) GRPCConfig() *grpc.Config
  • func (cfg *Config) HTTPConfig() *http.Config
  • func (cfg *Config) NSQConfig() *nsq.Config
  • func (cfg *Config) PGConfig() *pg.Config
  • func (cfg *Config) RedisConfig() *redis.Config
  • func (cfg *Config) RistrettoConfig() *ristretto.Config
  • func (cfg *Config) TransportConfig() *transport.Config
• type Generator
  • func NewGenerator(token string, err error) *Generator
  • func (g *Generator) Generate(_ 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(_ context.Context, token []byte) (*jwt.Token, *jwt.RegisteredClaims, 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 NewCmdConfig

func NewCmdConfig(flag string) (*cmd.Config, error)

NewCmdConfig for test.

func NewCompressor

func NewCompressor(err error) compressor.Compressor

NewCompressor for test.

func NewGRPCClient

func NewGRPCClient(
	ctx context.Context, lc fx.Lifecycle, logger *zap.Logger,
	tcfg *transport.Config, ocfg *otel.Config,
	cred credentials.PerRPCCredentials,
) *grpc.ClientConn

NewGRPCClient for test.

func NewGRPCServer

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

NewGRPCServer for test.

func NewHTTPClient

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

NewHTTPClient for test.

func NewHTTPClientWithRoundTripper

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

NewHTTPClientWithRoundTripper for test.

func NewHTTPServer

func NewHTTPServer(lc fx.Lifecycle, logger *zap.Logger, cfg *otel.Config, tcfg *transport.Config) *shttp.Server

NewHTTPServer 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 NewOTELConfig

func NewOTELConfig() *otel.Config

NewOTELConfig 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 NewRedisClient

func NewRedisClient(lc fx.Lifecycle, host string, logger *zap.Logger) client.Client

NewRedisClient for test.

func NewRedisConfig

func NewRedisConfig(host string) *redis.Config

NewRedisConfig for test.

func NewRistrettoCache

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

NewRistrettoCache for test.

func NewTransportConfig

func NewTransportConfig() *transport.Config

NewTransportConfig for test.

func RegisterTransport

func RegisterTransport(lc fx.Lifecycle, cfg *transport.Config, gs *tgrpc.Server, hs *shttp.Server)

RegisterTransport for test.

Types

type Config

type Config struct{}

Config for test.

func (*Config) Auth0Config

func (cfg *Config) Auth0Config() *auth0.Config

func (*Config) GRPCConfig

func (cfg *Config) GRPCConfig() *grpc.Config

func (*Config) HTTPConfig

func (cfg *Config) HTTPConfig() *http.Config

func (*Config) NSQConfig

func (cfg *Config) NSQConfig() *nsq.Config

func (*Config) PGConfig

func (cfg *Config) PGConfig() *pg.Config

func (*Config) RedisConfig

func (cfg *Config) RedisConfig() *redis.Config

func (*Config) RistrettoConfig

func (cfg *Config) RistrettoConfig() *ristretto.Config

func (*Config) TransportConfig

func (cfg *Config) TransportConfig() *transport.Config

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(_ 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(_ context.Context, token []byte) (*jwt.Token, *jwt.RegisteredClaims, error)