Functions — github.com/gliderlabs/logspout

hub / github.com/gliderlabs/logspout / functions

Functions197 in github.com/gliderlabs/logspout

⨍ Functions 197◇ Types & classes 37

↓ 22 callersFunctionGetEnvDefault

GetEnvDefault is a helper function to retrieve an env variable value OR return a default value

cfg/cfg.go:6

↓ 17 callersMethodRegister

(component Job, name string)

router/extpoints.go:262

↓ 16 callersMethodAdd

(route *Route)

router/types.go:47

↓ 14 callersFunctiondebug

(v ...interface{})

router/pump.go:42

↓ 11 callersFunctiondebug

(v ...interface{})

adapters/syslog/syslog.go:54

↓ 10 callersMethodall

()

router/extpoints.go:42

↓ 9 callersMethodClose

Close sends true to a Route.closer

↓ 9 callersFunctionnormalID

(id string)

router/pump.go:69

↓ 8 callersFunctioncreateTestTLSConfig

helper function to create TLS config while handling error

transports/tls/tls_test.go:21

↓ 7 callersMethodName

()

router/types.go:34

↓ 6 callersFunctionbacklog

()

router/pump.go:48

↓ 6 callersMethodregister

(component interface{}, name string)

router/extpoints.go:52

↓ 6 callersMethodunregister

(name string)

router/extpoints.go:73

↓ 5 callersMethodAll

()

router/extpoints.go:274

↓ 5 callersMethodRemove

(id string)

router/types.go:48

↓ 5 callersFunctionignoreContainer

(container *docker.Container)

router/pump.go:85

↓ 5 callersMethodlookup

(name string)

router/extpoints.go:35

↓ 5 callersFunctionnewExtensionPoint

(iface interface{})

router/extpoints.go:24

↓ 4 callersMethodDial

(addr string, options map[string]string)

router/types.go:22

↓ 4 callersMethodFilename

Filename returns the filename in a RouteFileStore for a given id

router/persist.go:16

↓ 4 callersMethodGetAll

()

router/types.go:46

↓ 4 callersMethodLookup

(name string)

router/extpoints.go:266

↓ 4 callersMethodRoutingFrom

RoutingFrom returns whether a container id is routing from this pump

router/pump.go:311

↓ 4 callersMethodStream

(logstream chan *Message)

router/types.go:27

↓ 4 callersFunctionassert

(err error, context string)

router/pump.go:59

↓ 4 callersFunctiongetFormat

()

adapters/syslog/syslog.go:60

↓ 4 callersFunctiongetTCPFraming

()

adapters/syslog/syslog.go:139

↓ 4 callersFunctionnewContainerPump

(container *docker.Container, stdout, stderr io.Reader)

router/pump.go:372

↓ 3 callersFunctionNewRawAdapter

NewRawAdapter returns a configured raw.Adapter

adapters/raw/raw.go:31

↓ 3 callersMethodadd

(logstream chan *Message, route *Route)

router/pump.go:411

↓ 3 callersFunctiondebug

(v ...interface{})

httpstream/httpstream.go:23

↓ 3 callersFunctiongetRetryCount

()

adapters/syslog/syslog.go:150

↓ 3 callersFunctionignoreContainerTTY

(container *docker.Container)

router/pump.go:119

↓ 3 callersFunctionmarshal

(obj interface{})

routesapi/routesapi.go:65

↓ 3 callersFunctionmarshal

(obj interface{})

router/persist.go:67

↓ 3 callersMethodmatchAll

()

router/types.go:107

↓ 3 callersMethodremove

(logstream chan *Message)

router/pump.go:417

↓ 2 callersMethodAdapterTransport

AdapterTransport returns a route's adapter transport string

router/types.go:81

↓ 2 callersMethodAdapterType

AdapterType returns a route's adapter type string

router/types.go:76

↓ 2 callersMethodAdd

Add adds a route to the RouteManager

router/routes.go:125

↓ 2 callersMethodMatchContainer

MatchContainer returns whether the Route is responsible for a given container

router/types.go:120

↓ 2 callersMethodNames

()

router/extpoints.go:282

↓ 2 callersFunctionNewSyslogAdapter

NewSyslogAdapter returnas a configured syslog.Adapter

adapters/syslog/syslog.go:171

↓ 2 callersMethodRender

Render transforms the log message using the Syslog template

adapters/syslog/syslog.go:347

↓ 2 callersMethodRoute

(route *Route, logstream chan *Message)

router/types.go:40

↓ 2 callersMethodRoutingFrom

(containerID string)

router/types.go:39

↓ 2 callersFunctioncreateTLSConfig

createTLSConfig creates the required TLS configuration that we need to establish a TLS connection

transports/tls/tls.go:96

↓ 2 callersFunctiongetHostname

()

adapters/syslog/syslog.go:71

↓ 2 callersFunctionmarshal

(obj interface{})

httpstream/httpstream.go:94

↓ 2 callersFunctionmultilineContainer

(container *docker.Container, def bool)

adapters/multiline/multiline.go:233

↓ 2 callersFunctionnormalName

(name string)

router/pump.go:65

↓ 2 callersMethodpumpLogs

(event *docker.APIEvents, backlog bool, inactivityTimeout time.Duration)

router/pump.go:204

↓ 2 callersMethodrename

(event *docker.APIEvents)

router/pump.go:157

↓ 2 callersFunctionreplaceNewLines

(str string)

adapters/multiline/multiline_test.go:230

↓ 2 callersFunctionretryExp

(fun func() error, tries uint)

adapters/syslog/syslog.go:324

↓ 2 callersMethodroute

(route *Route)

router/routes.go:160

↓ 2 callersMethodsend

(msg *Message)

router/pump.go:400

↓ 2 callersFunctionsendLogstream

(stream chan *router.Message, messages chan string, adapter router.LogAdapter, count int)

adapters/syslog/syslog_test.go:269

↓ 2 callersFunctionsetAllowTTY

()

router/pump.go:52

↓ 2 callersFunctionstartServer

(n, la string, done chan<- string)

adapters/syslog/syslog_test.go:220

↓ 2 callersMethodupdate

(event *docker.APIEvents)

router/pump.go:294

↓ 1 callersMethodAddFromURI

AddFromURI creates a new route from an URI string and adds it to the RouteManager

router/routes.go:89

↓ 1 callersMethodCloser

Closer returns a route's closerRcv

router/types.go:90

↓ 1 callersMethodContainerName

ContainerName returns the message's container name

adapters/syslog/syslog.go:429

↓ 1 callersMethodGet

Get returns *Route based on an id

router/persist.go:21

↓ 1 callersMethodGet

Get returns up to 14 color escape codes (then repeats) for each unique key

httpstream/httpstream.go:81

↓ 1 callersMethodHostname

Hostname returns the os hostname

adapters/syslog/syslog.go:419

↓ 1 callersMethodLoad

Load loads all route from a RouteStore

router/routes.go:37

↓ 1 callersMethodMatchMessage

MatchMessage returns whether the Route is responsible for a given Message

router/types.go:147

↓ 1 callersMethodMultiContainer

MultiContainer returns whether the Route is matching multiple containers or not

router/types.go:115

↓ 1 callersMethodName

Name returns the name of the pump

router/pump.go:146

↓ 1 callersMethodOverrideCloser

OverrideCloser sets a Route.closer to closer

router/types.go:98

↓ 1 callersMethodRoute

Route takes a logstream and route and passes them off to all configure LogRouters

↓ 1 callersMethodSetup

()

router/types.go:33

↓ 1 callersMethodStream

Stream sends log data to the next adapter

adapters/multiline/multiline.go:139

↓ 1 callersFunctioncheck

(t *testing.T, in string, out string)

adapters/syslog/syslog_test.go:286

↓ 1 callersFunctioncontains

(strs []string, str string)

router/types.go:157

↓ 1 callersFunctiongetFieldTemplates

(route *router.Route)

adapters/syslog/syslog.go:81

↓ 1 callersFunctiongetInactivityTimeoutFromEnv

()

router/pump.go:126

↓ 1 callersFunctionhttpStreamer

(w http.ResponseWriter, req *http.Request, logstream chan *router.Message, multi bool)

httpstream/httpstream.go:121

↓ 1 callersFunctionimplements

(component interface{})

router/extpoints.go:84

↓ 1 callersMethodisFirstLine

(message *router.Message)

adapters/multiline/multiline.go:207

↓ 1 callersMethodisLastLine

(message *router.Message)

adapters/multiline/multiline.go:220

↓ 1 callersFunctionisTCPConnection

(conn net.Conn)

adapters/syslog/syslog.go:159

↓ 1 callersFunctionlogDriverSupported

(container *docker.Container)

router/pump.go:76

↓ 1 callersFunctionnewTestClient

(rt http.RoundTripper)

router/pump_test.go:46

↓ 1 callersFunctionnormalName

(name string)

httpstream/httpstream.go:102

↓ 1 callersMethodreconnect

()

adapters/syslog/syslog.go:307

↓ 1 callersMethodretry

(buf []byte, err error)

adapters/syslog/syslog.go:267

↓ 1 callersMethodretryTemporary

(buf []byte)

adapters/syslog/syslog.go:287

↓ 1 callersFunctionrunStreamSyslog

(l net.Listener, done chan<- string, wg *sync.WaitGroup)

adapters/syslog/syslog_test.go:241

↓ 1 callersFunctionunmarshal

(input io.Reader, obj interface{})

routesapi/routesapi.go:73

↓ 1 callersFunctionunmarshal

(input io.Reader, obj interface{})

router/persist.go:75

↓ 1 callersFunctionwebsocketStreamer

(w http.ResponseWriter, req *http.Request, logstream chan *router.Message, closer chan struct{})

httpstream/httpstream.go:106

MethodAdd

Add writes a marshaled *Route to the RouteFileStore

router/persist.go:53

MethodAll

()

router/extpoints.go:148

MethodAll

()

router/extpoints.go:190

MethodAll

()

router/extpoints.go:232

next →1–100 of 197, ranked by callers