MCPcopy Create free account

hub / github.com/One-com/gone / functions

Functions816 in github.com/One-com/gone

↓ 3 callersMethodRegisterGauge
RegisterGauge is equivalent to Register(NewGauge(), opts) with the default Client.
metric/client.go:239
↓ 3 callersMethodReleaseContext
ReleaseContext tells the VirtualUpstream that the context is no longer needed
http/vtransport/vtransport.go:39
↓ 3 callersMethodServe
Serve is equivalent to net/http.Server.Serve() with graceful shutdown enabled.
http/graceful/graceful.go:76
↓ 3 callersMethodStart
Start a stopped client
metric/client.go:123
↓ 3 callersMethodSwapParent
(new *Logger)
log/swapper_15.go:73
↓ 3 callersMethodToggleAccessLog
ToggleAccessLog controls which io.Writer accesslog is written to. call (nil, w) to turn accesslog on a io.Writer on. call (w, nil) to turn the accessl
http/handlers/accesslog/loghandler.go:33
↓ 3 callersMethodactiveFiles
return a copy of the active file slice
sd/file.go:76
↓ 3 callersFunctioncontrolServer
Launch a specific server - does not block
daemon/server.go:163
↓ 3 callersFunctionexportInternal
sames as Export, but allows to specify an associated lock file for UNIX sockets to support nicely replacing UNIX socket listeners.
sd/file.go:378
↓ 3 callersFunctionfreePoolEvent
(e *event)
log/event.go:30
↓ 3 callersFunctionmergeMaps
Merge source map into target This function is case sensitive - as maps are in Go. Any caseInsensitivity should have happened before calling this.
hugorm/util.go:221
↓ 3 callersMethodrealKey
Right now we don't support aliases.
hugorm/hugorm.go:144
↓ 3 callersFunctionreaperConn
(c net.Conn)
netutil/reaper/conn.go:18
↓ 3 callersFunctionrecordShutdown
(rev int, server LingeringServer, cleanups []CleanupFunc, timeout time.Duration)
daemon/run.go:382
↓ 3 callersFunctionsetKeyInMap
(target map[string]interface{}, path []string, value interface{})
hugorm/util.go:285
↓ 3 callersMethodstep
simply doing an increment module number of target hosts
http/vtransport/upstream/rr/rrupstream.go:325
↓ 3 callersFunctiontestReaperConn
running test-suite with race falg might help a bit GO_PKG_BASE:/netutil/reaper$ go test -race
netutil/reaper/nettest_test.go:18
↓ 3 callersMethodwrapConn
newConn wraps a standard net.Conn to a PoolConn net.Conn.
netutil/pool/conn.go:23
↓ 3 callersFunctionzoneToString
(zone int)
sd/filetests.go:441
↓ 2 callersMethodAccept
()
netutil/reaper/listener.go:46
↓ 2 callersMethodAddConfigMap
(cfg map[string]interface{})
hugorm/hugorm.go:327
↓ 2 callersMethodDEBUGok
DEBUGok will return whether the logger generates events at this level, and a function which will do the logging when called.
log/api.go:74
↓ 2 callersFunctionDefaultSubConfig
DefaultSubConfig returns a placeholder value which can be assigned to any field which is an OptionalSubConfig to indicate that if the value is missing
jconf/subconfig.go:45
↓ 2 callersMethodDeregister
Deregister detaches a Meter (gauge/counter/timer...) from the client. It will no longer be flushed. An error is returned if the Meter was not register
metric/client.go:168
↓ 2 callersMethodDescription
()
daemon/srv/server.go:55
↓ 2 callersMethodDo
Do is Setlevel() - For completeness returns success
log/gonelog.go:288
↓ 2 callersMethodERRORok
ERRORok will return whether the logger generates events at this level, and a function which will do the logging when called.
log/api.go:62
↓ 2 callersMethodEvWrite
(e Event, b []byte)
log/writers.go:21
↓ 2 callersFunctionEventWriterFunc
EventWriterFunc created a new EvWriter from a function taking the event and a formattet logline. Such functions need to be aware that e can be nil
log/writers.go:44
↓ 2 callersFunctionFileWith
FileWith returns any file descriptor (as an *os.File) which matches the given systemd name *and* any FileTests provided from the available pool of (in
sd/file.go:455
↓ 2 callersMethodFlush
Flush the client default so no data is left in any pipeline buffers.
metric/client.go:218
↓ 2 callersMethodFlushMeter
flush a single meter. Sync with the Flusher mutex
metric/flusher.go:170
↓ 2 callersMethodFlushSink
FlushSink asks the Sink attached to this flusher to flush it's internal buffers.
metric/flusher.go:245
↓ 2 callersMethodGetValue
()
daemon/ctrl/example/server.go:40
↓ 2 callersFunctionHandlerFunc
HandlerFunc generates a Handler from a function, by calling it when Log is called.
log/handler.go:28
↓ 2 callersMethodInt64
Int64 returns the 64-bit values as an int64
metric/num64/numeric64.go:53
↓ 2 callersFunctionIsTCPListener
IsTCPListener tests whether the *os.File is a listening TCP socket. If addr != nil it's tested whether it is bound to that address.
sd/filetests.go:294
↓ 2 callersMethodListen
Listen will be called before Serve() is called to allow the server to prepare for serving. It doesn't need to actually do network listening. it's just
daemon/server.go:26
↓ 2 callersFunctionListenTCP
ListenTCP returns a normal *net.TCPListener. It will create a new socket if there's no appropriate inherited file descriptor listening. The returned l
sd/net.go:171
↓ 2 callersMethodMarshalJSON
()
jconf/subconfig.go:16
↓ 2 callersMethodNOTICE
NOTICE - Log a message and optional KV values at syslog NOTICE level.
log/api.go:111
↓ 2 callersFunctionNamedListenTCP
NamedListenTCP is like ListenTCP, but requires the file descriptor used to have the given systemd socket name The returned listener will be Export'ed
sd/net.go:178
↓ 2 callersFunctionNewCounter
NewCounter returns a client side buffered counter (a counter is a server side maintained value). "Server side" meaning that it's reset to 0 every time
metric/counter.go:21
↓ 2 callersFunctionNewGauge
NewGauge is alias for NewGaugeUint64
metric/gauge.go:33
↓ 2 callersFunctionNewHistogram
NewHistogram creates a new persistent metric object measuring arbitrary sample values by allocating a client side FIFO buffer for recording and flushi
metric/histotimer.go:15
↓ 2 callersFunctionNewTimer
NewTimer creates a new persistent metric object measuring timing values. by allocating a client side FIFO buffer for recording and flushing measuremen
metric/histotimer.go:38
↓ 2 callersMethodRead
(bs []byte)
http/vtransport/body.go:13
↓ 2 callersMethodRetries
Retries should return the number of retries which has been made
http/vtransport/vtransport.go:20
↓ 2 callersMethodSample
Sample records new event for the histogram
metric/histotimer.go:25
↓ 2 callersMethodSetLogger
SetLogger sets a custom log function.
daemon/srv/server.go:26
↓ 2 callersFunctionSetOutput
SetOutput - Compatible with the standard library
log/root.go:190
↓ 2 callersMethodSetSink
SetSink sets the Sink factory of the client. You'll need to set a sink before any metrics will be emitted.
metric/client.go:102
↓ 2 callersMethodSetTimeStamp
(time.Time)
http/rrwriter/responselogger.go:46
↓ 2 callersMethodShutdown
start serving and block until exit
daemon/srv/server.go:45
↓ 2 callersFunctionSyncWriter
SyncWriter encapsulates an io.Writer in a Mutex, so only one Write operation is done at a time.
log/writers.go:65
↓ 2 callersMethodTime
Time returns the timestamp of an event.
log/event.go:97
↓ 2 callersFunctionUnmarshal
Unmarshal unmarshals the config into a Struct. Make sure that the tags on the fields of the structure are properly set.
hugorm/unmarshal.go:9
↓ 2 callersMethodWARN
WARN - Log a message and optional KV values at syslog WARN level.
log/api.go:103
↓ 2 callersMethodWait
Wait for server shutdown to finish (having killed any remaning keep-alive connections)
http/graceful/graceful.go:213
↓ 2 callersMethodWrite
(p []byte)
http/handlers/accesslog/alog_test.go:47
↓ 2 callersMethodWrite
(p []byte)
metric/test/metrictest2.go:21
↓ 2 callersMethodWriteConfigTo
(out io.Writer)
hugorm/hugorm.go:339
↓ 2 callersMethod_activeFiles
to be called already under mutex lock
sd/file.go:83
↓ 2 callersMethod_cleanupLocked
()
sd/file.go:131
↓ 2 callersFunction_statBeforeUnlink
(name string)
sd/net.go:342
↓ 2 callersMethodappend
must be called under manager mutex lock
log/manager.go:17
↓ 2 callersMethodappendType
(t int)
metric/sink/statsd/statsd.go:182
↓ 2 callersMethoddefaultLevel
()
log/gonelog.go:350
↓ 2 callersMethoddoingDefaultLevel
()
log/gonelog.go:356
↓ 2 callersMethodenqueue
(val uint64)
metric/event.go:85
↓ 2 callersMethodevaluate
()
log/lazy.go:21
↓ 2 callersMethodfixupParents
Ensure that there are either loggers or placeholders all the way from the specified logger to the root of the logger hierarchy.
log/manager.go:74
↓ 2 callersMethodflush
(n int)
metric/sink/statsd/statsd.go:161
↓ 2 callersMethodflushIfBufferFull
(lastSafeLen int)
metric/sink/statsd/statsd.go:155
↓ 2 callersMethodgetDoneChanLocked
()
daemon/ctrl/ctrl.go:104
↓ 2 callersFunctioninitConfig
func initConfigs() { Reset() var r io.Reader SetConfigType("yaml") r = bytes.NewReader(yamlExample) unmarshalReader(r, v.config) SetConfigType(
hugorm/hugorm_test.go:176
↓ 2 callersFunctionisSameIPAddr
(a1, a2 net.Addr)
sd/filetests.go:530
↓ 2 callersFunctionkillMeSoon
(s *Server, delay time.Duration)
http/graceful/graceful_test.go:12
↓ 2 callersMethodlevel
()
log/gonelog.go:344
↓ 2 callersFunctionlistenerFor
(s *http.Server)
http/vtransport/vtransport_test.go:152
↓ 2 callersFunctionlisteningUnixSocketPath
test whether an fd refers to a listening UNIX socket and return it's path
sd/filetests.go:119
↓ 2 callersFunctionmakeMyHandler
(server string)
http/vtransport/vtransport_test.go:18
↓ 2 callersFunctionmaybeUnlinkUnixSocketFile
(addr *net.UnixAddr)
sd/net.go:310
↓ 2 callersFunctionnewEventStream
(name string, dqf dequeueFunc)
metric/event.go:40
↓ 2 callersFunctionnewFlusher
(interval time.Duration)
metric/flusher.go:44
↓ 2 callersFunctionnewLogger
newLogger Creates a new Logger. Not exported, since applications should use GetLogger() to get Loggers with a name. Once created and the pointer is re
log/gonelog.go:98
↓ 2 callersFunctionnewSwapper
makes sure to initialize a swapper with a value
log/swapper_15.go:30
↓ 2 callersFunctionparse
(j json.RawMessage, i interface{})
jconf/subconfig.go:49
↓ 2 callersFunctionreaper
(first *conn, incomming <-chan *conn, interval time.Duration, maxMiss int64, exitCounter *uint32)
netutil/reaper/reaper.go:13
↓ 2 callersMethodregister
Register a meter in the flusher. If the meters needs to know the flusher to do autoflushing, tell it.
metric/flusher.go:188
↓ 2 callersMethodrun
Run the flusher until stopchan. The flusher is fixed to be a flusherTypeFixed.
metric/flusher.go:139
↓ 2 callersMethodserve
(pctx context.Context, c *net.UnixConn, initialcmd []byte)
daemon/ctrl/ctrl.go:255
↓ 2 callersFunctionsetenv
setenv sets or unsets an environment variable to a temporary value for the duration of the test
hugorm/internal/testutil/env.go:28
↓ 2 callersMethodstop
()
metric/flusher.go:63
↓ 2 callersFunctiontestPrint
Test using Println("hello", 23, "world") or using Printf("hello %d world", 23)
log/compat_test.go:51
↓ 2 callersFunctiontryServe
(s *http.Server, tl net.Listener)
http/vtransport/vtransport_test.go:145
↓ 2 callersFunctionunmarshalReader
(format string, in io.Reader, c map[string]interface{})
hugorm/configfile.go:65
↓ 2 callersMethodwrap_n_handoff
(c net.Conn)
netutil/reaper/dialer.go:63
↓ 1 callersMethodALERTok
--- ALERTok will return whether the logger generates events at this level, and a function which will do the logging when called.
log/api.go:56
↓ 1 callersMethodAddConfigFile
(format, filename string)
hugorm/hugorm.go:219
← previousnext →101–200 of 816, ranked by callers