Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/One-com/gone
/ functions
Functions
816 in github.com/One-com/gone
⨍
Functions
816
◇
Types & classes
173
↓ 3 callers
Method
RegisterGauge
RegisterGauge is equivalent to Register(NewGauge(), opts) with the default Client.
metric/client.go:239
↓ 3 callers
Method
ReleaseContext
ReleaseContext tells the VirtualUpstream that the context is no longer needed
http/vtransport/vtransport.go:39
↓ 3 callers
Method
Serve
Serve is equivalent to net/http.Server.Serve() with graceful shutdown enabled.
http/graceful/graceful.go:76
↓ 3 callers
Method
Start
Start a stopped client
metric/client.go:123
↓ 3 callers
Method
SwapParent
(new *Logger)
log/swapper_15.go:73
↓ 3 callers
Method
ToggleAccessLog
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 callers
Method
activeFiles
return a copy of the active file slice
sd/file.go:76
↓ 3 callers
Function
controlServer
Launch a specific server - does not block
daemon/server.go:163
↓ 3 callers
Function
exportInternal
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 callers
Function
freePoolEvent
(e *event)
log/event.go:30
↓ 3 callers
Function
mergeMaps
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 callers
Method
realKey
Right now we don't support aliases.
hugorm/hugorm.go:144
↓ 3 callers
Function
reaperConn
(c net.Conn)
netutil/reaper/conn.go:18
↓ 3 callers
Function
recordShutdown
(rev int, server LingeringServer, cleanups []CleanupFunc, timeout time.Duration)
daemon/run.go:382
↓ 3 callers
Function
setKeyInMap
(target map[string]interface{}, path []string, value interface{})
hugorm/util.go:285
↓ 3 callers
Method
step
simply doing an increment module number of target hosts
http/vtransport/upstream/rr/rrupstream.go:325
↓ 3 callers
Function
testReaperConn
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 callers
Method
wrapConn
newConn wraps a standard net.Conn to a PoolConn net.Conn.
netutil/pool/conn.go:23
↓ 3 callers
Function
zoneToString
(zone int)
sd/filetests.go:441
↓ 2 callers
Method
Accept
()
netutil/reaper/listener.go:46
↓ 2 callers
Method
AddConfigMap
(cfg map[string]interface{})
hugorm/hugorm.go:327
↓ 2 callers
Method
DEBUGok
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 callers
Function
DefaultSubConfig
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 callers
Method
Deregister
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 callers
Method
Description
()
daemon/srv/server.go:55
↓ 2 callers
Method
Do
Do is Setlevel() - For completeness returns success
log/gonelog.go:288
↓ 2 callers
Method
ERRORok
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 callers
Method
EvWrite
(e Event, b []byte)
log/writers.go:21
↓ 2 callers
Function
EventWriterFunc
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 callers
Function
FileWith
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 callers
Method
Flush
Flush the client default so no data is left in any pipeline buffers.
metric/client.go:218
↓ 2 callers
Method
FlushMeter
flush a single meter. Sync with the Flusher mutex
metric/flusher.go:170
↓ 2 callers
Method
FlushSink
FlushSink asks the Sink attached to this flusher to flush it's internal buffers.
metric/flusher.go:245
↓ 2 callers
Method
GetValue
()
daemon/ctrl/example/server.go:40
↓ 2 callers
Function
HandlerFunc
HandlerFunc generates a Handler from a function, by calling it when Log is called.
log/handler.go:28
↓ 2 callers
Method
Int64
Int64 returns the 64-bit values as an int64
metric/num64/numeric64.go:53
↓ 2 callers
Function
IsTCPListener
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 callers
Method
Listen
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 callers
Function
ListenTCP
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 callers
Method
MarshalJSON
()
jconf/subconfig.go:16
↓ 2 callers
Method
NOTICE
NOTICE - Log a message and optional KV values at syslog NOTICE level.
log/api.go:111
↓ 2 callers
Function
NamedListenTCP
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 callers
Function
NewCounter
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 callers
Function
NewGauge
NewGauge is alias for NewGaugeUint64
metric/gauge.go:33
↓ 2 callers
Function
NewHistogram
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 callers
Function
NewTimer
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 callers
Method
Read
(bs []byte)
http/vtransport/body.go:13
↓ 2 callers
Method
Retries
Retries should return the number of retries which has been made
http/vtransport/vtransport.go:20
↓ 2 callers
Method
Sample
Sample records new event for the histogram
metric/histotimer.go:25
↓ 2 callers
Method
SetLogger
SetLogger sets a custom log function.
daemon/srv/server.go:26
↓ 2 callers
Function
SetOutput
SetOutput - Compatible with the standard library
log/root.go:190
↓ 2 callers
Method
SetSink
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 callers
Method
SetTimeStamp
(time.Time)
http/rrwriter/responselogger.go:46
↓ 2 callers
Method
Shutdown
start serving and block until exit
daemon/srv/server.go:45
↓ 2 callers
Function
SyncWriter
SyncWriter encapsulates an io.Writer in a Mutex, so only one Write operation is done at a time.
log/writers.go:65
↓ 2 callers
Method
Time
Time returns the timestamp of an event.
log/event.go:97
↓ 2 callers
Function
Unmarshal
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 callers
Method
WARN
WARN - Log a message and optional KV values at syslog WARN level.
log/api.go:103
↓ 2 callers
Method
Wait
Wait for server shutdown to finish (having killed any remaning keep-alive connections)
http/graceful/graceful.go:213
↓ 2 callers
Method
Write
(p []byte)
http/handlers/accesslog/alog_test.go:47
↓ 2 callers
Method
Write
(p []byte)
metric/test/metrictest2.go:21
↓ 2 callers
Method
WriteConfigTo
(out io.Writer)
hugorm/hugorm.go:339
↓ 2 callers
Method
_activeFiles
to be called already under mutex lock
sd/file.go:83
↓ 2 callers
Method
_cleanupLocked
()
sd/file.go:131
↓ 2 callers
Function
_statBeforeUnlink
(name string)
sd/net.go:342
↓ 2 callers
Method
append
must be called under manager mutex lock
log/manager.go:17
↓ 2 callers
Method
appendType
(t int)
metric/sink/statsd/statsd.go:182
↓ 2 callers
Method
defaultLevel
()
log/gonelog.go:350
↓ 2 callers
Method
doingDefaultLevel
()
log/gonelog.go:356
↓ 2 callers
Method
enqueue
(val uint64)
metric/event.go:85
↓ 2 callers
Method
evaluate
()
log/lazy.go:21
↓ 2 callers
Method
fixupParents
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 callers
Method
flush
(n int)
metric/sink/statsd/statsd.go:161
↓ 2 callers
Method
flushIfBufferFull
(lastSafeLen int)
metric/sink/statsd/statsd.go:155
↓ 2 callers
Method
getDoneChanLocked
()
daemon/ctrl/ctrl.go:104
↓ 2 callers
Function
initConfig
func initConfigs() { Reset() var r io.Reader SetConfigType("yaml") r = bytes.NewReader(yamlExample) unmarshalReader(r, v.config) SetConfigType(
hugorm/hugorm_test.go:176
↓ 2 callers
Function
isSameIPAddr
(a1, a2 net.Addr)
sd/filetests.go:530
↓ 2 callers
Function
killMeSoon
(s *Server, delay time.Duration)
http/graceful/graceful_test.go:12
↓ 2 callers
Method
level
()
log/gonelog.go:344
↓ 2 callers
Function
listenerFor
(s *http.Server)
http/vtransport/vtransport_test.go:152
↓ 2 callers
Function
listeningUnixSocketPath
test whether an fd refers to a listening UNIX socket and return it's path
sd/filetests.go:119
↓ 2 callers
Function
makeMyHandler
(server string)
http/vtransport/vtransport_test.go:18
↓ 2 callers
Function
maybeUnlinkUnixSocketFile
(addr *net.UnixAddr)
sd/net.go:310
↓ 2 callers
Function
newEventStream
(name string, dqf dequeueFunc)
metric/event.go:40
↓ 2 callers
Function
newFlusher
(interval time.Duration)
metric/flusher.go:44
↓ 2 callers
Function
newLogger
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 callers
Function
newSwapper
makes sure to initialize a swapper with a value
log/swapper_15.go:30
↓ 2 callers
Function
parse
(j json.RawMessage, i interface{})
jconf/subconfig.go:49
↓ 2 callers
Function
reaper
(first *conn, incomming <-chan *conn, interval time.Duration, maxMiss int64, exitCounter *uint32)
netutil/reaper/reaper.go:13
↓ 2 callers
Method
register
Register a meter in the flusher. If the meters needs to know the flusher to do autoflushing, tell it.
metric/flusher.go:188
↓ 2 callers
Method
run
Run the flusher until stopchan. The flusher is fixed to be a flusherTypeFixed.
metric/flusher.go:139
↓ 2 callers
Method
serve
(pctx context.Context, c *net.UnixConn, initialcmd []byte)
daemon/ctrl/ctrl.go:255
↓ 2 callers
Function
setenv
setenv sets or unsets an environment variable to a temporary value for the duration of the test
hugorm/internal/testutil/env.go:28
↓ 2 callers
Method
stop
()
metric/flusher.go:63
↓ 2 callers
Function
testPrint
Test using Println("hello", 23, "world") or using Printf("hello %d world", 23)
log/compat_test.go:51
↓ 2 callers
Function
tryServe
(s *http.Server, tl net.Listener)
http/vtransport/vtransport_test.go:145
↓ 2 callers
Function
unmarshalReader
(format string, in io.Reader, c map[string]interface{})
hugorm/configfile.go:65
↓ 2 callers
Method
wrap_n_handoff
(c net.Conn)
netutil/reaper/dialer.go:63
↓ 1 callers
Method
ALERTok
--- 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 callers
Method
AddConfigFile
(format, filename string)
hugorm/hugorm.go:219
← previous
next →
101–200 of 816, ranked by callers