server

Documentation

Index

• func Run(ctx context.Context, opts ...Option)
• type Config
• type Option
  • func WithCanonicalHost(hostname string) Option
  • func WithCertificate(certFilename, keyFilename string) Option
  • func WithHTTPListenPort(port int) Option
  • func WithHTTPServer(h http.Handler) Option
  • func WithLogger(l *zap.Logger) Option
  • func WithMetricsListenPort(port int) Option
  • func WithRPCListenPort(port int) Option
  • func WithRPCServer(fn RPCRegistration) Option
  • func WithServiceName(serviceName string) Option
  • func WithZipkinTracer() Option
• type RPCRegistration

Functions

func Run

func Run(ctx context.Context, opts ...Option)

Types

type Config

type Config struct {
	Insecure          bool
	Compress          bool // if true, add compression handling to messages
	UseZipkin         bool // if true, add zipkin tracing
	CertFilename      string
	KeyFilename       string
	HTTPListenPort    int
	RPCListenPort     int
	MetricsListenPort int
	Handler           http.Handler
	Hostname          string // if present, enforce canonical hostnames
	RPCRegister       RPCRegistration
	// contains filtered or unexported fields
}

type Option

type Option func(*Config) error

func WithCanonicalHost

func WithCanonicalHost(hostname string) Option

func WithCertificate

func WithCertificate(certFilename, keyFilename string) Option

func WithHTTPListenPort

func WithHTTPListenPort(port int) Option

func WithHTTPServer

func WithHTTPServer(h http.Handler) Option

func WithLogger

func WithLogger(l *zap.Logger) Option

func WithMetricsListenPort

func WithMetricsListenPort(port int) Option

func WithRPCListenPort

func WithRPCListenPort(port int) Option

func WithRPCServer

func WithRPCServer(fn RPCRegistration) Option

func WithServiceName

func WithServiceName(serviceName string) Option

func WithZipkinTracer

func WithZipkinTracer() Option

type RPCRegistration

type RPCRegistration func(*grpc.Server) error