MCPcopy Create free account

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

Functions816 in github.com/One-com/gone

MethodPanicln
(v ...interface{})
log/interfaces.go:31
FunctionParse
Parse instruct the adapter to try parse the stdlib log message to pick out fields
log/stdgw.go:60
MethodParseInto
ParseInto on will Unmarshal the SubConfig JSON data into the provided interface If called on a nil value (no JSON data) will return ErrEmptySubConfig
jconf/subconfig.go:68
MethodParseInto
ParseInto on will Unmarshal the SubConfig JSON data into the provided interface If called on a nil value (no JSON data) will do nothing.
jconf/subconfig.go:78
FunctionPeer
Peer is the address of the statsd UDP server
metric/sink/statsd/statsd.go:51
FunctionPinRequestsWith
PinRequestsWith will - if provided a cache implementation - allow the Round Robin upstream to remember where it send requests with a similar routing k
http/vtransport/upstream/rr/rrupstream.go:223
FunctionPrefix
Prefix - Compatible with the standard library
log/root.go:175
FunctionPrefix
Prefix is prepended with "prefix." to all metric names
metric/sink/statsd/statsd.go:43
MethodPrefix
Prefix - same as for flags
log/swapper.go:69
MethodPrefix
Prefix compatible with the standard lib logger
log/compat.go:108
MethodPrefix
To support stdlib query functions
log/format.go:131
FunctionPrint
Print - Compatible with the standard library
log/root.go:262
MethodPrintLevel
PrintLevel returns the current log level of Print*() methods
log/gonelog.go:315
MethodPrintf
Printf compatible with the standard lib logger
log/compat.go:80
FunctionQuarantine
Quarantine configures the quarantine period for failed servers.
http/vtransport/upstream/rr/rrupstream.go:213
MethodRead
(bs []byte)
http/rrwriter/responselogger.go:146
MethodRead
(b []byte)
netutil/reaper/conn.go:139
FunctionReadyCallback
ReadyCallback sets a function to be called when all servers have started without error
daemon/run.go:110
MethodRecord
(mtype int, name string, value interface{})
metric/sink.go:39
MethodRecord
Record records a value directly at the sink of this flusher. optionally flusing the sink.
metric/flusher.go:224
MethodRecord
Record a value with the sink
metric/sink/statsd/statsd.go:99
MethodRecord
(mtype int, name string, value interface{})
metric/sink/statsd/statsd.go:105
MethodRecordNumeric64
(mtype int, name string, value num64.Numeric64)
metric/sink.go:42
MethodRecordNumeric64
RecordNumeric64 records a value directly at the sink of this flusher. optionally flusing the sink.
metric/flusher.go:235
MethodRecordNumeric64
Record a Numeric64 value with the sink
metric/sink/statsd/statsd.go:126
MethodRecordNumeric64
(mtype int, name string, value num64.Numeric64)
metric/sink/statsd/statsd.go:132
FunctionRegisterCommand
RegisterCommand registers an implementation of the Command interface under a command name
daemon/ctrl/ctrl.go:50
FunctionRegisterCounter
-------------------------------------------------------------- RegisterCounter is equivalent to Register(NewCounter(), opts) with the default Client.
metric/client.go:268
FunctionRegisterGauge
RegisterGauge is equivalent to Register(NewGauge(), opts) with the default Client.
metric/client.go:275
FunctionRegisterHistogram
RegisterHistogram is equivalent to Register(NewHistogram(), opts) with the default Client.
metric/client.go:289
MethodRegisterSet
(name string, opts ...MOption)
metric/client.go:259
FunctionRegisterTimer
RegisterTimer is equivalent to Register(NewTimer(), opts) with the default Client.
metric/client.go:282
MethodRelease
Release puts the net.Conn back to the pool instead of closing it.
netutil/pool/conn.go:13
MethodReleaseContext
ReleaseContext implements the VirtualUpstream interface.
http/vtransport/upstream/rr/rrupstream.go:260
FunctionReload
Reload tells Run() to instatiate new servers and continue serving with them.
daemon/run.go:420
FunctionReplaceProcess
ReplaceProcess calls StartProcess, after setting up environment variables instructing the new process to signal the process calling ReplaceProcess for
sd/process.go:95
FunctionReplaceProcess
ReplaceProcess spawns a new version of the program. sig is the UNIX signal to send to terminate the parent once we're up and running
daemon/run.go:450
FunctionRetries
Retries creates a RetryPolicy which will at most retry the request "retries" times. and at most repeat the backend host pool "maxRepeat" times. Per de
http/vtransport/vtransport.go:91
MethodRetries
()
http/vtransport/upstream/rr/rrupstream.go:28
MethodRoundTrip
RoundTrip implements the http.RoundTripper interface.
http/vtransport/vtransport.go:121
FunctionRun
Run takes a set of RunOptions. The only mandatory option is InstantiateServers. The servers will be managed and via Serve() and can be controlled with
daemon/run.go:158
FunctionRunSignalHandler
RunSignalHandler spawns a go-routine which will call the provided Actions when receiving the corresponding signals.
signals/signals.go:49
FunctionSdNotifyOnReady
SdNotifyOnReady makes Run() notify systemd with STATUS=READY when all servers have started. If mainpid is true, the MAINPID of the current process is
daemon/run.go:125
MethodServe
(ctx context.Context)
example.go:53
MethodServe
(ctx context.Context)
daemon/server.go:74
MethodServe
(ctx context.Context)
daemon/legacy.go:29
MethodServe
Serve implement the gone/daemon/srv.Server interface. It is synchronous (does not implement Wait). All connections should exit ASAP when Shutdown is c
daemon/ctrl/ctrl.go:215
MethodServeHTTP
(w http.ResponseWriter, req *http.Request)
http/handlers/accesslog/loghandler.go:105
MethodSet
(key string, value int, ttl time.Duration)
http/vtransport/vtransport_test.go:49
MethodSet
Set will update the gauge value
metric/gauge.go:56
MethodSet
Set sets the gauge value
metric/gauge.go:94
MethodSet
Set updates the gauge's value.
metric/gauge.go:125
MethodSet
(val string)
hugorm/hugorm_test.go:257
MethodSet
(key string, value interface{})
hugorm/hugorm.go:277
FunctionSetDefaultOptions
SetDefaultOptions sets options on the default metric client
metric/client.go:70
FunctionSetDefaultSink
SetDefaultSink sets the sink for the default metics client The default client has no sink set initially. You need to set it calling this function.
metric/client.go:95
MethodSetFlags
(flag int)
log/swapper.go:76
MethodSetFlags
SetFlags compatible with the standard lib logger
log/compat.go:113
MethodSetFlags
(flag int)
log/interfaces.go:56
MethodSetFlags
SetFlags creates a HandlerOption to set flags. This is a method wrapper around FlagsOpt to be able to have the swapper call it genericly on different
log/format.go:163
FunctionSetLevel
SetLevel set the Logger log level. returns success
log/root.go:145
FunctionSetLogger
SetLogger sets a custom log function.
daemon/log.go:30
MethodSetOutput
(w io.Writer)
log/swapper.go:103
MethodSetOutput
(w io.Writer)
log/writers.go:83
MethodSetOutput
SetOutput compatible with the standard lib logger
log/compat.go:139
MethodSetOutput
(w io.Writer)
log/interfaces.go:58
MethodSetOutput
SetOutput creates a HandlerOption to se the output writer This is a method wrapper to be able to have the swapper call it genericly on different forma
log/format.go:179
MethodSetPrefix
(prefix string)
log/swapper.go:94
MethodSetPrefix
SetPrefix compatible with the standard lib logger
log/compat.go:134
MethodSetPrefix
(prefix string)
log/interfaces.go:57
MethodSetPrefix
SetPrefix creates a HandlerOption to set the formating prefix This is a method wrapper to be able to have the swapper call it genericly on different f
log/format.go:171
FunctionSetPrintLevel
SetPrintLevel sets the log level used by Print*() calls. If the second argument is true, Println(), Printf(), Print() will respect the Logger log leve
log/root.go:153
MethodSetTimeStamp
SetTimeStamp sets a timestamp. This can be used to store a starttime for a request and return it after the request is done. It is not go-routine safe.
http/rrwriter/responselogger.go:93
FunctionSetUnixSocketUnlinkPolicy
SetUnixSocketUnlinkPolicy decides how the sd library will deal with stale UNIX socket file when you create a new listening Unix socket which is not in
sd/net.go:68
FunctionSetenv
Based on https://github.com/frankban/quicktest/blob/577841610793d24f99e31cc2c0ef3a541fefd7c7/patch.go#L34-L64 Licensed under the MIT license Copyright
hugorm/internal/testutil/env.go:17
MethodShortUsage
()
example.go:186
MethodShortUsage
()
daemon/ctrl/example/server.go:114
MethodShortUsage
()
daemon/ctrl/example/accesslog.go:34
MethodShortUsage
()
daemon/ctrl/example/main.go:141
MethodShutdown
(ctx context.Context)
daemon/server.go:96
MethodShutdown
(ctx context.Context)
daemon/legacy.go:79
FunctionShutdownTimeout
ShutdownTimeout is an option to Run() to control the default timeout value for graceful shutdowns. This is used when OS signals or similar crude inter
daemon/run.go:96
FunctionSignalParentOnReady
SignalParentOnReady sets a ReadyCallback which signals the parent process to terminate.
daemon/run.go:117
FunctionSignalParentTermination
SignalParentTermination signals any parent who have asked to be terminated via the ENV
sd/process.go:114
MethodSize
Size returns the written response size.
http/rrwriter/responselogger.go:104
MethodSize
()
http/rrwriter/responselogger.go:152
FunctionStart
Start the default Client if stopped.
metric/client.go:118
FunctionStartTimer
StartTimer allows to put a timer on a Conn, and via time.AfterFunc have a function called. The provided afterfunc is called with the net.Conn created
netutil/reaper/conn.go:42
MethodStatus
Status returns the http status of the written request.
http/rrwriter/responselogger.go:99
FunctionStop
Stop the global default metrics Client
metric/client.go:142
FunctionStopTimer
StopTimer stops any timer on the connection. StopTimer is go-routine safe.
netutil/reaper/conn.go:63
FunctionSyncReload
SyncReload makes Run() Wait() for all servers before starting the next generation om Reload()
daemon/run.go:103
MethodTarget
()
http/vtransport/upstream/rr/rrupstream.go:24
FunctionTargets
Targets sets the backend URLs for the Round Robin upstream
http/vtransport/upstream/rr/rrupstream.go:87
FunctionTestAll
(t *testing.T)
log/compat_test.go:74
FunctionTestBackendFail
(t *testing.T)
http/vtransport/vtransport_test.go:170
FunctionTestDefault
func TestBasics(t *testing.T) { SetConfigFile("/tmp/config.yaml") filename, err := v.getConfigFile() assert.Equal(t, "/tmp/config.yaml", filename)
hugorm/hugorm_test.go:331
FunctionTestDefaultPost
func TestUnmarshalExact(t *testing.T) { vip := New() target := &testUnmarshalExtra{} vip.SetConfigType("yaml") r := bytes.NewReader(yamlExampleWi
hugorm/hugorm_test.go:381
FunctionTestDuration
(t *testing.T)
jconf/duration_test.go:25
FunctionTestEmptyEnv
(t *testing.T)
hugorm/hugorm_test.go:467
← previousnext →601–700 of 816, ranked by callers