test

Documentation

Index

• Variables
• func NewBaselimeTracerConfig() *tracer.Config
• func NewCmdConfig(flag string) (*cmd.Config, error)
• func NewCompressor(err error) compressor.Compressor
• func NewDebugConfig() *debug.Config
• func NewDefaultTracerConfig() *tracer.Config
• func NewGRPCClient(ctx context.Context, lc fx.Lifecycle, logger *zap.Logger, ...) *grpc.ClientConn
• func NewGRPCServer(lc fx.Lifecycle, logger *zap.Logger, cfg *tracer.Config, ...) *tgrpc.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, ...) *shttp.Server
• func NewHook() *hooks.Config
• func NewInsecureTransportConfig() *transport.Config
• func NewLogger(lc fx.Lifecycle) *zap.Logger
• func NewMarshaller(err error) marshaller.Marshaller
• 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) gr.Client
• func NewRedisConfig(host string) *redis.Config
• func NewRetry() *retry.Config
• func NewRistrettoCache(lc fx.Lifecycle, meter metric.Meter) ristretto.Cache
• func NewSecureClientConfig() *security.Config
• func NewSecureGRPCClient(ctx context.Context, lc fx.Lifecycle, logger *zap.Logger, ...) *grpc.ClientConn
• func NewSecureTransportConfig() *transport.Config
• func Port() string
• func RegisterTransport(lc fx.Lifecycle, gs *tgrpc.Server, hs *shttp.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 Environment = env.Environment("dev")

Environment for test.

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

ErrInvalidToken ...

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 NewDebugConfig

func NewDebugConfig() *debug.Config

NewDebugConfig for test.

func NewDefaultTracerConfig

func NewDefaultTracerConfig() *tracer.Config

NewDefaultTracerConfig for test.

func NewGRPCClient

func NewGRPCClient(
	ctx context.Context, 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,
) *tgrpc.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) *shttp.Server

NewHTTPServer for test.

func NewHook

func NewHook() *hooks.Config

NewHook 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 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, meter metric.Meter) *cache.Cache

NewRedisCache for test.

func NewRedisClient

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

NewRedisClient for test.

func NewRedisConfig

func NewRedisConfig(host 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 NewSecureGRPCClient

func NewSecureGRPCClient(
	ctx context.Context, 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 Port

func Port() string

Port for test.

func RegisterTransport

func RegisterTransport(lc fx.Lifecycle, gs *tgrpc.Server, hs *shttp.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)