Documentation ¶
Index ¶
Constants ¶
View Source
const BufferedNetwork string = "buffnet"
Variables ¶
This section is empty.
Functions ¶
func RegisterGRPCServerFlags ¶
func RegisterGRPCServerFlags(flags *pflag.FlagSet, config *GRPCServerConfig, flagPrefix, serviceName, defaultAddr string, defaultEnabled bool)
RegisterGRPCServerFlags adds the following flags for use with GrpcServerFromFlags: - "$PREFIX-addr" - "$PREFIX-tls-cert-path" - "$PREFIX-tls-key-path" - "$PREFIX-max-conn-age"
func RegisterHTTPServerFlags ¶
func RegisterHTTPServerFlags(flags *pflag.FlagSet, config *HTTPServerConfig, flagPrefix, serviceName, defaultAddr string, defaultEnabled bool)
RegisterHTTPServerFlags adds the following flags for use with HttpServerFromFlags: - "$PREFIX-addr" - "$PREFIX-tls-cert-path" - "$PREFIX-tls-key-path" - "$PREFIX-enabled"
Types ¶
type DialFunc ¶
type DialFunc func(ctx context.Context, opts ...grpc.DialOption) (*grpc.ClientConn, error)
type GRPCServerConfig ¶
type GRPCServerConfig struct { Address string Network string TLSCertPath string TLSKeyPath string MaxConnAge time.Duration Enabled bool BufferSize int ClientCAPath string MaxWorkers uint32 // contains filtered or unexported fields }
func (*GRPCServerConfig) Complete ¶
func (c *GRPCServerConfig) Complete(level zerolog.Level, svcRegistrationFn func(server *grpc.Server), opts ...grpc.ServerOption) (RunnableGRPCServer, error)
Complete takes a set of default options and returns a completed server
type HTTPServerConfig ¶
type HTTPServerConfig struct { Address string TLSCertPath string TLSKeyPath string Enabled bool // contains filtered or unexported fields }
func (*HTTPServerConfig) Complete ¶
func (c *HTTPServerConfig) Complete(level zerolog.Level, handler http.Handler) (RunnableHTTPServer, error)
type NetDialFunc ¶ added in v1.6.0
type RunnableGRPCServer ¶
type RunnableGRPCServer interface { WithOpts(opts ...grpc.ServerOption) RunnableGRPCServer Listen(ctx context.Context) func() error DialContext(ctx context.Context, opts ...grpc.DialOption) (*grpc.ClientConn, error) NetDialContext(ctx context.Context, s string) (net.Conn, error) Insecure() bool GracefulStop() }
type RunnableHTTPServer ¶
type RunnableHTTPServer interface { ListenAndServe() error Close() }
Click to show internal directories.
Click to hide internal directories.