Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

servenv

package

Go to main page

Versions in this module

v0

v0.15.10

Jul 31, 2024

v0.15.9

Jul 31, 2024

v0.15.8

Jul 31, 2024

Changes in this version

+ const Name

+ var AppVersion versionInfo

+ var ExitChan chan os.Signal

+ var GRPCServer *grpc.Server

+ var ListeningURL url.URL

+ var TestingEndtoend = false

+ var TruncateErrLen = 0

+ var TruncateUILen = 512

+ func AddStatusFuncs(fmap template.FuncMap)

+ func AddStatusPart(banner, fragment string, f func() any)

+ func AddStatusSection(banner string, f func() string)

+ func ClientCertSubstrings() string

+ func CobraPreRunE(cmd *cobra.Command, args []string) error

+ func FakeAuthStreamInterceptor(srv any, stream grpc.ServerStream, info *grpc.StreamServerInfo, ...) error

+ func FakeAuthUnaryInterceptor(ctx context.Context, req any, info *grpc.UnaryServerInfo, ...) (any, error)

+ func FireRunHooks()

+ func GRPCAuth() string

+ func GRPCCert() string

+ func GRPCCertificateAuthority() string

+ func GRPCCheckServiceMap(name string) bool

+ func GRPCKey() string

+ func GRPCPort() int

+ func GetAuthenticator(name string) func() (Authenticator, error)

+ func GetFlagSetFor(cmd string) *pflag.FlagSet

+ func GetInitStartTime() time.Time

+ func HTTPHandle(pattern string, handler http.Handler)

+ func HTTPHandleFunc(pattern string, handler func(http.ResponseWriter, *http.Request))

+ func HTTPRegisterProfile()

+ func HTTPServe(l net.Listener) error

+ func HandlePanic(component string, err *error)

+ func Init()

+ func InitServiceMap(protocol, name string)

+ func MoveFlagsToCobraCommand(cmd *cobra.Command)

+ func MovePersistentFlagsToCobraCommand(cmd *cobra.Command)

+ func MySQLServerVersion() string

+ func OnClose(f func())

+ func OnInit(f func())

+ func OnParse(f func(fs *pflag.FlagSet))

+ func OnParseFor(cmd string, f func(fs *pflag.FlagSet))

+ func OnRun(f func())

+ func OnTerm(f func())

+ func OnTermSync(f func())

+ func ParseFlags(cmd string)

+ func ParseFlagsForTests(cmd string)

+ func ParseFlagsWithArgs(cmd string) []string

+ func Port() int

+ func RegisterAuthPlugin(name string, authPlugin func() (Authenticator, error))

+ func RegisterDefaultFlags()

+ func RegisterDefaultSocketFileFlags()

+ func RegisterFlags()

+ func RegisterFlagsForTopoBinaries(registerFlags func(fs *pflag.FlagSet))

+ func RegisterFlagsWithTimeouts(tf *TimeoutFlags)

+ func RegisterGRPCServerAuthFlags()

+ func RegisterGRPCServerFlags()

+ func RegisterMySQLServerFlags(fs *pflag.FlagSet)

+ func RegisterServiceMapFlag()

+ func Run(bindAddress string, port int)

+ func RunDefault()

+ func StaticAuthUsernameFromContext(ctx context.Context) string

+ func StatusURLPath() string

+ type Authenticator interface

+ Authenticate func(ctx context.Context, fullMethod string) (context.Context, error)

+ type Exporter struct

+ func NewExporter(name, label string) *Exporter

+ func (e *Exporter) AddStatusPart(banner, frag string, f func() any)

+ func (e *Exporter) HandleFunc(url string, f func(w http.ResponseWriter, r *http.Request))

+ func (e *Exporter) Name() string

+ func (e *Exporter) NewCounter(name string, help string) *stats.Counter

+ func (e *Exporter) NewCounterDurationFunc(name string, help string, f func() time.Duration) *stats.CounterDurationFunc

+ func (e *Exporter) NewCounterFunc(name string, help string, f func() int64) *stats.CounterFunc

+ func (e *Exporter) NewCountersFuncWithMultiLabels(name, help string, labels []string, f func() map[string]int64) *stats.CountersFuncWithMultiLabels

+ func (e *Exporter) NewCountersWithMultiLabels(name, help string, labels []string) *stats.CountersWithMultiLabels

+ func (e *Exporter) NewCountersWithSingleLabel(name, help string, label string, tags ...string) *stats.CountersWithSingleLabel

+ func (e *Exporter) NewGauge(name string, help string) *stats.Gauge

+ func (e *Exporter) NewGaugeDurationFunc(name string, help string, f func() time.Duration) *stats.GaugeDurationFunc

+ func (e *Exporter) NewGaugeFloat64(name string, help string) *stats.GaugeFloat64

+ func (e *Exporter) NewGaugeFunc(name string, help string, f func() int64) *stats.GaugeFunc

+ func (e *Exporter) NewGaugesFuncWithMultiLabels(name, help string, labels []string, f func() map[string]int64) *stats.GaugesFuncWithMultiLabels

+ func (e *Exporter) NewGaugesWithMultiLabels(name, help string, labels []string) *stats.GaugesWithMultiLabels

+ func (e *Exporter) NewGaugesWithSingleLabel(name, help string, label string, tags ...string) *stats.GaugesWithSingleLabel

+ func (e *Exporter) NewHistogram(name, help string, cutoffs []int64) *stats.Histogram

+ func (e *Exporter) NewMultiTimings(name string, help string, labels []string) *MultiTimingsWrapper

+ func (e *Exporter) NewRates(name string, singleCountVar multiCountVar, samples int, interval time.Duration) *stats.Rates

+ func (e *Exporter) NewTimings(name string, help string, label string) *TimingsWrapper

+ func (e *Exporter) Publish(name string, v expvar.Var)

+ func (e *Exporter) URLPrefix() string

+ type MtlsAuthPlugin struct

+ func (ma *MtlsAuthPlugin) Authenticate(ctx context.Context, fullMethod string) (context.Context, error)

+ type MultiTimingsWrapper struct

+ func (tw *MultiTimingsWrapper) Add(names []string, elapsed time.Duration)

+ func (tw *MultiTimingsWrapper) Counts() map[string]int64

+ func (tw *MultiTimingsWrapper) Record(names []string, startTime time.Time)

+ func (tw *MultiTimingsWrapper) Reset()

+ type StaticAuthConfigEntry struct

+ Password string

+ Username string

+ type StaticAuthPlugin struct

+ func (sa *StaticAuthPlugin) Authenticate(ctx context.Context, fullMethod string) (context.Context, error)

+ type TimeoutFlags struct

+ LameduckPeriod time.Duration

+ OnCloseTimeout time.Duration

+ OnTermTimeout time.Duration

+ type TimingsWrapper struct

+ func (tw *TimingsWrapper) Add(name string, elapsed time.Duration)

+ func (tw *TimingsWrapper) Counts() map[string]int64

+ func (tw *TimingsWrapper) Record(name string, startTime time.Time)

+ func (tw *TimingsWrapper) Reset()

+ type WrappedServerStream struct

+ WrappedContext context.Context

+ func WrapServerStream(stream grpc.ServerStream) *WrappedServerStream

+ func (w *WrappedServerStream) Context() context.Context