test

Documentation

Index

• Variables
• func NewBaselimeTracerConfig() *tracer.Config
• func NewCmdConfig(flag string) (*cmd.Config, error)
• func NewCompressor(err error) compressor.Compressor
• func NewGRPCClient(lc fx.Lifecycle, logger *zap.Logger, tcfg *transport.Config, ...) *grpc.ClientConn
• func NewGRPCServer(lc fx.Lifecycle, logger *zap.Logger, cfg *tracer.Config, ...) *tg.Server
• func NewHTTPClient(lc fx.Lifecycle, logger *zap.Logger, cfg *tracer.Config, ...) *http.Client
• func NewHTTPClientWithRoundTripper(lc fx.Lifecycle, logger *zap.Logger, cfg *tracer.Config, ...) *http.Client
• func NewHTTPServer(lc fx.Lifecycle, logger *zap.Logger, cfg *tracer.Config, ...) *th.Server
• func NewHook() *hooks.Config
• func NewInsecureDebugConfig() *debug.Config
• func NewInsecureTransportConfig() *transport.Config
• func NewLogger(lc fx.Lifecycle) *zap.Logger
• func NewMarshaller(err error) marshaller.Marshaller
• func NewMeter(lc fx.Lifecycle) metric.Meter
• func NewOTLPMetricsConfig() *metrics.Config
• func NewOTLPTracerConfig() *tracer.Config
• func NewPGConfig() *pg.Config
• func NewPrometheusMetricsConfig() *metrics.Config
• func NewRedisCache(lc fx.Lifecycle, cfg *redis.Config, logger *zap.Logger, meter metric.Meter) (*cache.Cache, error)
• func NewRedisClient(lc fx.Lifecycle, cfg *redis.Config, logger *zap.Logger) gr.Client
• func NewRedisConfig(host, compressor, marshaller string) *redis.Config
• func NewRetry() *retry.Config
• func NewRistrettoCache(lc fx.Lifecycle, meter metric.Meter) ristretto.Cache
• func NewSecureClientConfig() *security.Config
• func NewSecureDebugConfig() *debug.Config
• func NewSecureGRPCClient(lc fx.Lifecycle, logger *zap.Logger, tcfg *transport.Config, ...) *grpc.ClientConn
• func NewSecureTransportConfig() *transport.Config
• func NewTracer(lc fx.Lifecycle) trace.Tracer
• func Port() string
• func RegisterTransport(lc fx.Lifecycle, gs *tg.Server, hs *th.Server)
• func Test(ctx context.Context) meta.Valuer
• func WithTest(ctx context.Context, value meta.Valuer) context.Context
• type Config
• type Generator
  • func NewGenerator(token string, err error) *Generator
  • func (g *Generator) Generate(ctx context.Context) (context.Context, []byte, 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) (context.Context, error)

Variables

var Compressor = compressor.NewFactory()

Compressor for tests.

var Environment = env.Environment("dev")

Environment for test.

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

ErrInvalidToken ...

var Marshaller = marshaller.NewFactory()

Marshaller for tests.

var Mux = th.NewServeMux()

Mux ...

var Version = version.Version("1.0.0")

Version for test.

Functions

func NewBaselimeTracerConfig

func NewBaselimeTracerConfig() *tracer.Config

NewBaselimeTracerConfig 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(
	lc fx.Lifecycle, logger *zap.Logger,
	tcfg *transport.Config, ocfg *tracer.Config,
	cred credentials.PerRPCCredentials,
	meter metric.Meter,
) *grpc.ClientConn

NewGRPCClient for test.

func NewGRPCServer

func NewGRPCServer(
	lc fx.Lifecycle, logger *zap.Logger, cfg *tracer.Config, tcfg *transport.Config,
	verifyAuth bool, meter metric.Meter,
	unary []grpc.UnaryServerInterceptor, stream []grpc.StreamServerInterceptor,
) *tg.Server

NewGRPCServer for test.

func NewHTTPClient

func NewHTTPClient(lc fx.Lifecycle, logger *zap.Logger, cfg *tracer.Config, tcfg *transport.Config, meter metric.Meter) *http.Client

NewHTTPClient for test.

func NewHTTPClientWithRoundTripper

func NewHTTPClientWithRoundTripper(lc fx.Lifecycle, logger *zap.Logger, cfg *tracer.Config, tcfg *transport.Config, rt http.RoundTripper, meter metric.Meter) *http.Client

NewHTTPClientWithRoundTripper for test.

func NewHTTPServer

func NewHTTPServer(lc fx.Lifecycle, logger *zap.Logger, cfg *tracer.Config, tcfg *transport.Config, meter metric.Meter, handlers []negroni.Handler) *th.Server

NewHTTPServer for test.

func NewHook

func NewHook() *hooks.Config

NewHook for test.

func NewInsecureDebugConfig

func NewInsecureDebugConfig() *debug.Config

NewInsecureDebugConfig for test.

func NewInsecureTransportConfig

func NewInsecureTransportConfig() *transport.Config

NewInsecureTransportConfig 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 NewMeter

func NewMeter(lc fx.Lifecycle) metric.Meter

NewMeter for test.

func NewOTLPMetricsConfig

func NewOTLPMetricsConfig() *metrics.Config

NewOTLPMetricsConfig for test.

func NewOTLPTracerConfig

func NewOTLPTracerConfig() *tracer.Config

NewOTLPTracerConfig for test.

func NewPGConfig

func NewPGConfig() *pg.Config

NewPGConfig for test.

func NewPrometheusMetricsConfig

func NewPrometheusMetricsConfig() *metrics.Config

NewPrometheusMetricsConfig for test.

func NewRedisCache

func NewRedisCache(lc fx.Lifecycle, cfg *redis.Config, logger *zap.Logger, meter metric.Meter) (*cache.Cache, error)

NewRedisCache for test.

func NewRedisClient

func NewRedisClient(lc fx.Lifecycle, cfg *redis.Config, logger *zap.Logger) gr.Client

NewRedisClient for test.

func NewRedisConfig

func NewRedisConfig(host, compressor, marshaller string) *redis.Config

NewRedisConfig for test.

func NewRetry

func NewRetry() *retry.Config

NewRetry for test.

func NewRistrettoCache

func NewRistrettoCache(lc fx.Lifecycle, meter metric.Meter) ristretto.Cache

NewRistrettoCache for test.

func NewSecureClientConfig

func NewSecureClientConfig() *security.Config

NewSecureClientConfig for test.

func NewSecureDebugConfig

func NewSecureDebugConfig() *debug.Config

NewInsecureDebugConfig for test.

func NewSecureGRPCClient

func NewSecureGRPCClient(
	lc fx.Lifecycle, logger *zap.Logger,
	tcfg *transport.Config, ocfg *tracer.Config,
	meter metric.Meter,
) *grpc.ClientConn

NewSecureGRPCClient for test.

func NewSecureTransportConfig

func NewSecureTransportConfig() *transport.Config

NewSecureTransportConfig for test.

func NewTracer

func NewTracer(lc fx.Lifecycle) trace.Tracer

NewTracer for test.

func Port

func Port() string

Port for test.

func RegisterTransport

func RegisterTransport(lc fx.Lifecycle, gs *tg.Server, hs *th.Server)

RegisterTransport for test.

func Test

func Test(ctx context.Context) meta.Valuer

Test retrieves sample info.

func WithTest

func WithTest(ctx context.Context, value meta.Valuer) context.Context

WithTest stores sample info.

Types

type Config

type Config struct {
	Events         *events.Config `yaml:"events,omitempty" json:"events,omitempty" toml:"events,omitempty"`
	*config.Config `yaml:",inline" json:",inline" toml:",inline"`
}

Config for test.

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) (context.Context, []byte, error)

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) (context.Context, error)