Documentation ¶
Index ¶
- Variables
- func GenerateRandomPort() string
- func NewCompressor(err error) compressor.Compressor
- func NewDatadogConfig() *datadog.Config
- func NewGRPCConfig() *grpc.Config
- func NewHTTPClient(logger *zap.Logger, tracer opentracing.Tracer) *http.Client
- func NewHTTPClientWithRoundTripper(logger *zap.Logger, tracer opentracing.Tracer, roundTripper http.RoundTripper) *http.Client
- func NewHTTPConfig() *http.Config
- func NewJaegerConfig() *jaeger.Config
- func NewMarshaller(err error) marshaller.Marshaller
- func NewNSQConfig() *nsq.Config
- type Generator
- type Handler
- type Server
- type Shutdowner
- type Verifier
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrInvalidToken = errors.New("invalid token")
ErrInvalidToken ...
Functions ¶
func GenerateRandomPort ¶ added in v1.26.0
func GenerateRandomPort() string
GenerateRandomPort for test.
func NewCompressor ¶ added in v1.57.3
func NewCompressor(err error) compressor.Compressor
NewCompressor for test.
func NewDatadogConfig ¶ added in v1.59.0
NewDatadogConfig for test.
func NewHTTPClient ¶ added in v1.30.0
NewHTTPClient for test.
func NewHTTPClientWithRoundTripper ¶ added in v1.30.0
func NewHTTPClientWithRoundTripper(logger *zap.Logger, tracer opentracing.Tracer, roundTripper http.RoundTripper) *http.Client
NewHTTPClientWithRoundTripper for test.
func NewJaegerConfig ¶ added in v1.52.0
NewJaegerConfig for test.
func NewMarshaller ¶ added in v1.57.3
func NewMarshaller(err error) marshaller.Marshaller
NewMarshaller for test.
Types ¶
type Generator ¶ added in v1.32.3
type Generator struct {
// contains filtered or unexported fields
}
Generator for test.
func NewGenerator ¶ added in v1.4.0
NewGenerator for test.
type Handler ¶ added in v1.14.0
type Handler struct {
// contains filtered or unexported fields
}
Handler for test.
type Server ¶
type Server struct { v1.UnimplementedGreeterServiceServer // contains filtered or unexported fields }
Server ...
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{}
func NewShutdowner ¶
func NewShutdowner() *Shutdowner
func (*Shutdowner) Shutdown ¶
func (*Shutdowner) Shutdown(...fx.ShutdownOption) error
Source Files ¶
Click to show internal directories.
Click to hide internal directories.