Documentation
¶
Index ¶
- Constants
- Variables
- func Address() string
- func ErrorsInternalProtobufSayHello(_ context.Context, _ *v1.SayHelloRequest) (*v1.SayHelloResponse, error)
- func ErrorsNotMappedProtobufSayHello(_ context.Context, _ *v1.SayHelloRequest) (*v1.SayHelloResponse, error)
- func ErrorsProtobufSayHello(_ context.Context, _ *v1.SayHelloRequest) (*v1.SayHelloResponse, error)
- func FilePath(path string) string
- func NewAES() *aes.Config
- func NewCacheConfig(kind, compressor, encoder, secret string) *cache.Config
- func NewCompressor(err error) compress.Compressor
- func NewEd25519() *ed25519.Config
- func NewEncoder(err error) encoding.Encoder
- func NewHMAC() *hmac.Config
- func NewHook() *hooks.Config
- func NewInputConfig(set *flag.FlagSet) *cmd.InputConfig
- func NewInsecureConfig() *tls.Config
- func NewInsecureDebugConfig() *debug.Config
- func NewInsecureTransportConfig() *transport.Config
- func NewJSONLoggerConfig() *logger.Config
- func NewLimiterConfig(kind, interval string, tokens uint64) *limiter.Config
- func NewLogger(lc fx.Lifecycle, config *logger.Config) *logger.Logger
- func NewMeter(lc fx.Lifecycle, c *metrics.Config) *metrics.Meter
- func NewMeterProvider(lc fx.Lifecycle, config *metrics.Config) metric.MeterProvider
- func NewOTLPLoggerConfig() *logger.Config
- func NewOTLPMeter(lc fx.Lifecycle) *metrics.Meter
- func NewOTLPMeterProvider(lc fx.Lifecycle) metric.MeterProvider
- func NewOTLPMetricsConfig() *metrics.Config
- func NewOTLPTracerConfig() *tracer.Config
- func NewOutputConfig(set *flag.FlagSet) *cmd.OutputConfig
- func NewPGConfig() *pg.Config
- func NewPrometheusMeter(lc fx.Lifecycle) *metrics.Meter
- func NewPrometheusMeterProvider(lc fx.Lifecycle) metric.MeterProvider
- func NewPrometheusMetricsConfig() *metrics.Config
- func NewRSA() *rsa.Config
- func NewRetry() *retry.Config
- func NewSSH() *ssh.Config
- func NewSecureDebugConfig() *debug.Config
- func NewSecureTransportConfig() *transport.Config
- func NewTLSClientConfig() *tls.Config
- func NewTLSConfig(c, k string) *tls.Config
- func NewTLSServerConfig() *tls.Config
- func NewTextLoggerConfig() *logger.Config
- func NewTintLoggerConfig() *logger.Config
- func NewToken(kind string) *token.Config
- func NewTracer(lc fx.Lifecycle, config *tracer.Config) *tracer.Tracer
- func Path(path string) string
- func RegisterHandlers[Res any](path string, h content.Handler[Res])
- func RegisterRequestHandlers[Req any, Res any](path string, h content.RequestHandler[Req, Res])
- func RestRequestProtobuf(_ context.Context, r *v1.SayHelloRequest) (*v1.SayHelloResponse, error)
- func StatusURL(status string) string
- func SuccessProtobufSayHello(_ context.Context, r *v1.SayHelloRequest) (*v1.SayHelloResponse, error)
- func Test(ctx context.Context) meta.Value
- func Timeout() (context.Context, context.CancelFunc)
- func WithTest(ctx context.Context, value meta.Value) context.Context
- type BadReaderWriter
- type Cache
- type Client
- type EmptyHandler
- type ErrCache
- type ErrReaderCloser
- type ErrResponseWriter
- type ErrServer
- type Generator
- type InvalidMeter
- func (InvalidMeter) Float64Counter(string, ...metric.Float64CounterOption) (metric.Float64Counter, error)
- func (InvalidMeter) Float64Gauge(string, ...metric.Float64GaugeOption) (metric.Float64Gauge, error)
- func (InvalidMeter) Float64Histogram(string, ...metric.Float64HistogramOption) (metric.Float64Histogram, error)
- func (InvalidMeter) Float64ObservableCounter(string, ...metric.Float64ObservableCounterOption) (metric.Float64ObservableCounter, error)
- func (InvalidMeter) Float64ObservableGauge(string, ...metric.Float64ObservableGaugeOption) (metric.Float64ObservableGauge, error)
- func (InvalidMeter) Float64ObservableUpDownCounter(string, ...metric.Float64ObservableUpDownCounterOption) (metric.Float64ObservableUpDownCounter, error)
- func (InvalidMeter) Float64UpDownCounter(string, ...metric.Float64UpDownCounterOption) (metric.Float64UpDownCounter, error)
- func (InvalidMeter) Int64Counter(string, ...metric.Int64CounterOption) (metric.Int64Counter, error)
- func (InvalidMeter) Int64Gauge(string, ...metric.Int64GaugeOption) (metric.Int64Gauge, error)
- func (InvalidMeter) Int64Histogram(string, ...metric.Int64HistogramOption) (metric.Int64Histogram, error)
- func (InvalidMeter) Int64ObservableCounter(string, ...metric.Int64ObservableCounterOption) (metric.Int64ObservableCounter, error)
- func (InvalidMeter) Int64ObservableGauge(string, ...metric.Int64ObservableGaugeOption) (metric.Int64ObservableGauge, error)
- func (InvalidMeter) Int64ObservableUpDownCounter(string, ...metric.Int64ObservableUpDownCounterOption) (metric.Int64ObservableUpDownCounter, error)
- func (InvalidMeter) Int64UpDownCounter(string, ...metric.Int64UpDownCounterOption) (metric.Int64UpDownCounter, error)
- func (InvalidMeter) RegisterCallback(metric.Callback, ...metric.Observable) (metric.Registration, error)
- type NoopServer
- type Page
- type Request
- type Response
- func ErrorNotMappedSayHello(_ context.Context, _ *Request) (*Response, error)
- func ErrorSayHello(_ context.Context, _ *Request) (*Response, error)
- func NoContent(_ context.Context, _ *Request) (*Response, error)
- func RestContent(ctx context.Context) (*Response, error)
- func RestError(_ context.Context) (*Response, error)
- func RestInvalidStatusCode(ctx context.Context) (*Response, error)
- func RestNoContent(_ context.Context) (*Response, error)
- func RestRequestContent(ctx context.Context, req *Request) (*Response, error)
- func RestRequestError(_ context.Context, _ *Request) (*Response, error)
- func RestRequestInvalidStatusCode(ctx context.Context, _ *Request) (*Response, error)
- func RestRequestNoContent(_ context.Context, _ *Request) (*Response, error)
- func SuccessSayHello(ctx context.Context, r *Request) (*Response, error)
- type Server
- type Service
- type Shutdowner
- type Todo
- type Verifier
- type World
- func (w *World) EventsContext(ctx context.Context) context.Context
- func (w *World) InsecureDebugHost() string
- func (w *World) InsecureServerHost() string
- func (w *World) OpenDatabase() (*mssqlx.DBs, error)
- func (w *World) Register()
- func (w *World) RegisterEvents(ctx context.Context)
- func (w *World) ResponseWithBody(ctx context.Context, protocol, address, method, path string, ...) (*http.Response, string, error)
- func (w *World) ResponseWithNoBody(ctx context.Context, protocol, address, method, path string, ...) (*http.Response, error)
- func (w *World) SecureDebugHost() string
- func (w *World) SecureServerHost() string
- type WorldOption
- func WithWorldCompression() WorldOption
- func WithWorldDebug() WorldOption
- func WithWorldGRPC() WorldOption
- func WithWorldHTTP() WorldOption
- func WithWorldLimiter(config *limiter.Config) WorldOption
- func WithWorldLogger(logger *logger.Logger) WorldOption
- func WithWorldLoggerConfig(config string) WorldOption
- func WithWorldPGConfig(config *pg.Config) WorldOption
- func WithWorldRest() WorldOption
- func WithWorldRoundTripper(rt http.RoundTripper) WorldOption
- func WithWorldSecure() WorldOption
- func WithWorldTelemetry(kind string) WorldOption
- func WithWorldToken(generator token.Generator, verifier token.Verifier) WorldOption
Constants ¶
const ( // ID for test. ID = env.ID("1234567890") // Name for test. Name = env.Name("test") // Version for test. Version = env.Version("1.0.0") // Environment for test. Environment = env.Environment("dev") )
Variables ¶
var ( // ErrGenerate for test. ErrGenerate = errors.New("token error") // ErrInvalid for test. ErrInvalid = errors.New("invalid match") // ErrFailed for test. ErrFailed = errors.New("failed") // ErrInternal for test. ErrInternal = &internalError{} )
var ( // FileSystem for test. //go:embed views/*.tmpl //go:embed static/*.txt FileSystem embed.FS // Layout for test. Layout = mvc.NewLayout("views/full.tmpl", "views/partial.tmpl") // Model for test. Model = Page{ Title: "My TODO list", Todos: []Todo{ {Title: "Task 1", Done: false}, {Title: "Task 2", Done: true}, {Title: "Task 3", Done: true}, }, } )
var ( // FS used for tests. FS = os.NewFS() // ErrFS for tests. ErrFS *os.FS // Exit for tests. Exit = os.NewExitFunc() )
var Compressor = compress.NewMap(compress.MapParams{ Zstd: zstd.NewCompressor(), S2: s2.NewCompressor(), Snappy: snappy.NewCompressor(), None: none.NewCompressor(), })
Compressor for tests.
var Content = content.NewContent(Encoder)
Content for tests.
var Encoder = encoding.NewMap(encoding.MapParams{ JSON: json.NewEncoder(), YAML: yaml.NewEncoder(), TOML: toml.NewEncoder(), ProtoBinary: proto.NewBinary(), ProtoText: proto.NewText(), ProtoJSON: proto.NewJSON(), GOB: gob.NewEncoder(), Bytes: bytes.NewEncoder(), })
Encoder for tests.
var PEM = pem.NewDecoder(FS)
PEM for test.
var Pool = sync.NewBufferPool()
BufferPool for test.
UserAgent for test.
var Validator = validator.NewValidator()
Validator for testing.
Functions ¶
func ErrorsInternalProtobufSayHello ¶ added in v1.594.0
func ErrorsInternalProtobufSayHello(_ context.Context, _ *v1.SayHelloRequest) (*v1.SayHelloResponse, error)
ErrorsInternalProtobufSayHello for test.
func ErrorsNotMappedProtobufSayHello ¶
func ErrorsNotMappedProtobufSayHello(_ context.Context, _ *v1.SayHelloRequest) (*v1.SayHelloResponse, error)
ErrorsNotMappedProtobufSayHello for test.
func ErrorsProtobufSayHello ¶
func ErrorsProtobufSayHello(_ context.Context, _ *v1.SayHelloRequest) (*v1.SayHelloResponse, error)
ErrorsProtobufSayHello for test.
func NewCacheConfig ¶
NewCacheConfig for test.
func NewInputConfig ¶
func NewInputConfig(set *flag.FlagSet) *cmd.InputConfig
NewInputConfig for test.
func NewInsecureDebugConfig ¶
NewInsecureDebugConfig for test.
func NewInsecureTransportConfig ¶
NewInsecureTransportConfig for test.
func NewJSONLoggerConfig ¶ added in v1.473.0
NewJSONLoggerConfig for test.
func NewLimiterConfig ¶
NewLimiterConfig for test.
func NewMeterProvider ¶
NewMeterProvider for test.
func NewOTLPLoggerConfig ¶ added in v1.461.0
NewOTLPLoggerConfig for test.
func NewOTLPMeterProvider ¶
func NewOTLPMeterProvider(lc fx.Lifecycle) metric.MeterProvider
NewOTLPMeterProvider for test.
func NewOTLPMetricsConfig ¶
NewOTLPMetricsConfig for test.
func NewOutputConfig ¶
func NewOutputConfig(set *flag.FlagSet) *cmd.OutputConfig
NewOutputConfig for test.
func NewPrometheusMeter ¶
NewPrometheusMeter for test.
func NewPrometheusMeterProvider ¶
func NewPrometheusMeterProvider(lc fx.Lifecycle) metric.MeterProvider
NewPrometheusMeterProvider for test.
func NewPrometheusMetricsConfig ¶
NewPrometheusMetricsConfig for test.
func NewSecureDebugConfig ¶
NewInsecureDebugConfig for test.
func NewSecureTransportConfig ¶
NewSecureTransportConfig for test.
func NewTextLoggerConfig ¶ added in v1.473.0
NewTextLoggerConfig for test.
func NewTintLoggerConfig ¶ added in v1.550.0
NewTintLoggerConfig for test.
func RegisterHandlers ¶
RegisterHandlers for test.
func RegisterRequestHandlers ¶
func RegisterRequestHandlers[Req any, Res any](path string, h content.RequestHandler[Req, Res])
RegisterRequestHandlers for test.
func RestRequestProtobuf ¶ added in v1.595.0
func RestRequestProtobuf(_ context.Context, r *v1.SayHelloRequest) (*v1.SayHelloResponse, error)
RestRequestProtobuf for test.
func SuccessProtobufSayHello ¶
func SuccessProtobufSayHello(_ context.Context, r *v1.SayHelloRequest) (*v1.SayHelloResponse, error)
SuccessProtobufSayHello for test.
Types ¶
type BadReaderWriter ¶ added in v1.539.0
type BadReaderWriter struct{}
BadReaderWriter for test.
func (*BadReaderWriter) Exists ¶ added in v1.540.0
func (rw *BadReaderWriter) Exists() bool
Exists for test.
func (*BadReaderWriter) Kind ¶ added in v1.539.0
func (rw *BadReaderWriter) Kind() string
Kind for test.
func (*BadReaderWriter) Read ¶ added in v1.539.0
func (rw *BadReaderWriter) Read() ([]byte, error)
Read for test.
type Client ¶
type Client struct { Lifecycle fx.Lifecycle Logger *logger.Logger Tracer *tracer.Config Transport *transport.Config TLS *tls.Config ID id.Generator RoundTripper http.RoundTripper Meter *metrics.Meter Generator token.Generator Compression bool }
Client for test.
func (*Client) NewGRPC ¶
func (c *Client) NewGRPC() *grpc.ClientConn
type EmptyHandler ¶
type EmptyHandler struct{}
EmptyHandler for test.
func (*EmptyHandler) ServeHTTP ¶
func (*EmptyHandler) ServeHTTP(rw http.ResponseWriter, r *http.Request, next http.HandlerFunc)
type ErrResponseWriter ¶
type ErrResponseWriter struct {
Code int
}
ErrResponseWriter for test.
func (*ErrResponseWriter) Header ¶
func (w *ErrResponseWriter) Header() http.Header
Header is always empty.
func (*ErrResponseWriter) Write ¶
func (w *ErrResponseWriter) Write([]byte) (int, error)
Write returns ErrFailed.
func (*ErrResponseWriter) WriteHeader ¶
func (w *ErrResponseWriter) WriteHeader(code int)
WriteHeader stored the code in the field Code.
type Generator ¶
type Generator struct {
// contains filtered or unexported fields
}
Generator for test.
type InvalidMeter ¶
InvalidMeter for test.
func (InvalidMeter) Float64Counter ¶
func (InvalidMeter) Float64Counter(string, ...metric.Float64CounterOption) (metric.Float64Counter, error)
func (InvalidMeter) Float64Gauge ¶
func (InvalidMeter) Float64Gauge(string, ...metric.Float64GaugeOption) (metric.Float64Gauge, error)
func (InvalidMeter) Float64Histogram ¶
func (InvalidMeter) Float64Histogram(string, ...metric.Float64HistogramOption) (metric.Float64Histogram, error)
func (InvalidMeter) Float64ObservableCounter ¶
func (InvalidMeter) Float64ObservableCounter(string, ...metric.Float64ObservableCounterOption) (metric.Float64ObservableCounter, error)
func (InvalidMeter) Float64ObservableGauge ¶
func (InvalidMeter) Float64ObservableGauge(string, ...metric.Float64ObservableGaugeOption) (metric.Float64ObservableGauge, error)
func (InvalidMeter) Float64ObservableUpDownCounter ¶
func (InvalidMeter) Float64ObservableUpDownCounter(string, ...metric.Float64ObservableUpDownCounterOption) (metric.Float64ObservableUpDownCounter, error)
func (InvalidMeter) Float64UpDownCounter ¶
func (InvalidMeter) Float64UpDownCounter(string, ...metric.Float64UpDownCounterOption) (metric.Float64UpDownCounter, error)
func (InvalidMeter) Int64Counter ¶
func (InvalidMeter) Int64Counter(string, ...metric.Int64CounterOption) (metric.Int64Counter, error)
func (InvalidMeter) Int64Gauge ¶
func (InvalidMeter) Int64Gauge(string, ...metric.Int64GaugeOption) (metric.Int64Gauge, error)
func (InvalidMeter) Int64Histogram ¶
func (InvalidMeter) Int64Histogram(string, ...metric.Int64HistogramOption) (metric.Int64Histogram, error)
func (InvalidMeter) Int64ObservableCounter ¶
func (InvalidMeter) Int64ObservableCounter(string, ...metric.Int64ObservableCounterOption) (metric.Int64ObservableCounter, error)
func (InvalidMeter) Int64ObservableGauge ¶
func (InvalidMeter) Int64ObservableGauge(string, ...metric.Int64ObservableGaugeOption) (metric.Int64ObservableGauge, error)
func (InvalidMeter) Int64ObservableUpDownCounter ¶
func (InvalidMeter) Int64ObservableUpDownCounter(string, ...metric.Int64ObservableUpDownCounterOption) (metric.Int64ObservableUpDownCounter, error)
func (InvalidMeter) Int64UpDownCounter ¶
func (InvalidMeter) Int64UpDownCounter(string, ...metric.Int64UpDownCounterOption) (metric.Int64UpDownCounter, error)
func (InvalidMeter) RegisterCallback ¶
func (InvalidMeter) RegisterCallback(metric.Callback, ...metric.Observable) (metric.Registration, error)
type NoopServer ¶
type NoopServer struct{}
NoopServer for test.
func (*NoopServer) Serve ¶
func (s *NoopServer) Serve() error
func (*NoopServer) String ¶
func (s *NoopServer) String() string
type Response ¶
Response for test.
func ErrorNotMappedSayHello ¶
ErrorNotMappedSayHello for test.
func ErrorSayHello ¶
ErrorSayHello for test.
func RestInvalidStatusCode ¶ added in v1.570.0
RestInvalidStatusCode for test.
func RestNoContent ¶
RestNoContent for test.
func RestRequestContent ¶
RestRequestContent for test.
func RestRequestError ¶
RestRequestError for test.
func RestRequestInvalidStatusCode ¶ added in v1.570.0
RestRequestInvalidStatusCode for test.
func RestRequestNoContent ¶
RestRequestNoContent for test.
type Server ¶
type Server struct { Lifecycle fx.Lifecycle Meter *metrics.Meter Verifier token.Verifier Mux *http.ServeMux HTTPServer *th.Server GRPCServer *tg.Server DebugServer *debug.Server TransportConfig *transport.Config DebugConfig *debug.Config Tracer *tracer.Config Limiter *limiter.Limiter Logger *logger.Logger ID id.Generator RegisterHTTP bool RegisterGRPC bool RegisterDebug bool }
Server for test.
type Service ¶
type Service struct {
v1.UnimplementedGreeterServiceServer
}
Service ...
func (*Service) SayHello ¶
func (s *Service) SayHello(ctx context.Context, req *v1.SayHelloRequest) (*v1.SayHelloResponse, error)
SayHello ...
func (*Service) SayStreamHello ¶
func (s *Service) 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.
type World ¶
type World struct { *fxtest.Lifecycle *http.ServeMux *logger.Logger Tracer *tracer.Config PG *pg.Config *Server *Client *events.Event *eh.Receiver Cache cacher.Cache Sender client.Client Rest *rest.Client }
World for test.
func (*World) EventsContext ¶
EventsContext for world.
func (*World) InsecureDebugHost ¶ added in v1.527.0
InsecureDebugHost for world.
func (*World) InsecureServerHost ¶ added in v1.527.0
InsecureServerHost for world.
func (*World) OpenDatabase ¶
OpenDatabase for world.
func (*World) RegisterEvents ¶
RegisterEvents for world.
func (*World) ResponseWithBody ¶
func (w *World) ResponseWithBody(ctx context.Context, protocol, address, method, path string, header http.Header, body io.Reader) (*http.Response, string, error)
ResponseWithBody for the world.
func (*World) ResponseWithNoBody ¶
func (w *World) ResponseWithNoBody(ctx context.Context, protocol, address, method, path string, header http.Header, body io.Reader) (*http.Response, error)
HTTPResponseNoBody for the world.
func (*World) SecureDebugHost ¶ added in v1.527.0
SecureDebugHost for world.
func (*World) SecureServerHost ¶ added in v1.527.0
SecureServerHost for world.
type WorldOption ¶
type WorldOption interface {
// contains filtered or unexported methods
}
WorldOption for test.
func WithWorldLimiter ¶
func WithWorldLimiter(config *limiter.Config) WorldOption
WithWorldLimiter for test.
func WithWorldLogger ¶
func WithWorldLogger(logger *logger.Logger) WorldOption
WithWorldLogger for test.
func WithWorldLoggerConfig ¶ added in v1.550.0
func WithWorldLoggerConfig(config string) WorldOption
WithWorldLogger for test.
func WithWorldPGConfig ¶
func WithWorldPGConfig(config *pg.Config) WorldOption
WithWorldRedisConfig for test.
func WithWorldRoundTripper ¶
func WithWorldRoundTripper(rt http.RoundTripper) WorldOption
WithWorldRoundTripper for test.
func WithWorldTelemetry ¶
func WithWorldTelemetry(kind string) WorldOption
WithWorldTelemetry for test.
func WithWorldToken ¶
func WithWorldToken(generator token.Generator, verifier token.Verifier) WorldOption
WithWorldToken for test.