diff --git a/doc/steward.svg b/doc/steward.svg index 637dc54..7f20246 100644 --- a/doc/steward.svg +++ b/doc/steward.svg @@ -1,2649 +1,3099 @@ - - - + + gocallvis - -command-line-arguments + +command-line-arguments cluster_focus - -steward + +steward -cluster_*github.com/RaaLabs/steward.Configuration - - -(*Configuration) +cluster_command-line-arguments + + +main -cluster_*github.com/RaaLabs/steward.errorKernel - - -(*errorKernel) +cluster_github.com/hpcloud/tail + + +tail -cluster_*github.com/RaaLabs/steward.flagNodeSlice - - -(*flagNodeSlice) +cluster_github.com/nats-io/nats.go + + +nats -cluster_*github.com/RaaLabs/steward.processes - - -(*processes) +cluster_github.com/pelletier/go-toml + + +toml -cluster_*github.com/RaaLabs/steward.ringBuffer - - -(*ringBuffer) +cluster_github.com/prometheus/client_golang/prometheus + + +prometheus -cluster_*github.com/RaaLabs/steward.server - - -(*server) +cluster_github.com/prometheus/client_golang/prometheus/collectors + + +collectors -cluster_command-line-arguments - - -main +cluster_github.com/prometheus/client_golang/prometheus/promhttp + + +promhttp -cluster_github.com/RaaLabs/steward.CommandOrEvent - - -(CommandOrEvent) - - - - -cluster_github.com/RaaLabs/steward.CommandOrEventAvailable - - -(CommandOrEventAvailable) - - - - -cluster_github.com/RaaLabs/steward.Method - - -(Method) - - - - -cluster_github.com/RaaLabs/steward.MethodsAvailable - - -(MethodsAvailable) - - - - -cluster_github.com/RaaLabs/steward.Subject - - -(Subject) - - - - -cluster_github.com/RaaLabs/steward.methodREQCliCommand - - -(methodREQCliCommand) - - - - -cluster_github.com/RaaLabs/steward.methodREQErrorLog - - -(methodREQErrorLog) - - - - -cluster_github.com/RaaLabs/steward.methodREQHello - - -(methodREQHello) - - - - -cluster_github.com/RaaLabs/steward.methodREQHttpGet - - -(methodREQHttpGet) - - - - -cluster_github.com/RaaLabs/steward.methodREQInitial - - -(methodREQInitial) - - - - -cluster_github.com/RaaLabs/steward.methodREQOpCommand - - -(methodREQOpCommand) - - - - -cluster_github.com/RaaLabs/steward.methodREQPing - - -(methodREQPing) - - - - -cluster_github.com/RaaLabs/steward.methodREQPong - - -(methodREQPong) - - - - -cluster_github.com/RaaLabs/steward.methodREQTextToConsole - - -(methodREQTextToConsole) - - - - -cluster_github.com/RaaLabs/steward.methodREQTextToFile - - -(methodREQTextToFile) - - - - -cluster_github.com/RaaLabs/steward.methodREQTextToLogFile - - -(methodREQTextToLogFile) - - - - -cluster_github.com/RaaLabs/steward.methodREQnCliCommand - - -(methodREQnCliCommand) - - - - -cluster_github.com/RaaLabs/steward.process - - -(process) - - - - -cluster_github.com/RaaLabs/steward.startup - - -(startup) - - - - -cluster_github.com/nats-io/nats.go - - -nats - - - - -cluster_*github.com/nats-io/nats.go.Conn - - -(*Conn) - - - - -cluster_*github.com/nats-io/nats.go.Subscription - - -(*Subscription) - - - - -cluster_github.com/pelletier/go-toml - - -toml - - - - -cluster_*github.com/pelletier/go-toml.Decoder - - -(*Decoder) - - - - -cluster_*github.com/pelletier/go-toml.Encoder - - -(*Encoder) - - - - -cluster_github.com/prometheus/client_golang/prometheus - - -prometheus - - - - -cluster_*github.com/prometheus/client_golang/prometheus.gauge - - -(*gauge) - - - - -cluster_github.com/prometheus/client_golang/prometheus/promhttp - - -promhttp - - - - cluster_go.etcd.io/bbolt - - -bbolt - - - - -cluster_*go.etcd.io/bbolt.Bucket - - -(*Bucket) - - - - -cluster_*go.etcd.io/bbolt.DB - - -(*DB) - - - - -cluster_*go.etcd.io/bbolt.Tx - - -(*Tx) + + +bbolt (*github.com/RaaLabs/steward.ringBuffer).dumpBucket$1$1 - -(*ringBuffer).dumpBucket$1$1 + +(*ringBuffer).dumpBucket$1$1 - + -(*github.com/RaaLabs/steward.ringBuffer).printBucketContent$1$1 - -(*ringBuffer).printBucketContent$1$1 +(*github.com/RaaLabs/steward.ringBuffer).dbUpdate$1 + +(*ringBuffer).dbUpdate$1 - + + +(*go.etcd.io/bbolt.Tx).CreateBucketIfNotExists + +(*Tx).CreateBucketIfNotExists + + + +(*github.com/RaaLabs/steward.ringBuffer).dbUpdate$1->(*go.etcd.io/bbolt.Tx).CreateBucketIfNotExists + + + + + +(*go.etcd.io/bbolt.Bucket).Put + +(*Bucket).Put + + + +(*github.com/RaaLabs/steward.ringBuffer).dbUpdate$1->(*go.etcd.io/bbolt.Bucket).Put + + + + -(github.com/RaaLabs/steward.methodREQnCliCommand).handler$1$1 - -(methodREQnCliCommand).handler$1$1 +(*github.com/RaaLabs/steward.ringBuffer).deleteKeyFromBucket$1 + +(*ringBuffer).deleteKeyFromBucket$1 + + + +(*go.etcd.io/bbolt.Tx).Bucket + +(*Tx).Bucket + + + +(*github.com/RaaLabs/steward.ringBuffer).deleteKeyFromBucket$1->(*go.etcd.io/bbolt.Tx).Bucket + + + + + +(*go.etcd.io/bbolt.Bucket).Delete + +(*Bucket).Delete + + + +(*github.com/RaaLabs/steward.ringBuffer).deleteKeyFromBucket$1->(*go.etcd.io/bbolt.Bucket).Delete + + github.com/RaaLabs/steward.newSubject - -newSubject + +newSubject - + (github.com/RaaLabs/steward.Method).GetMethodsAvailable - -GetMethodsAvailable + +(Method).GetMethodsAvailable - + github.com/RaaLabs/steward.newSubject->(github.com/RaaLabs/steward.Method).GetMethodsAvailable - - - - - -(github.com/RaaLabs/steward.methodREQCliCommand).getKind - -getKind - - - -github.com/RaaLabs/steward.newSubject->(github.com/RaaLabs/steward.methodREQCliCommand).getKind - - + + - + (github.com/RaaLabs/steward.methodREQErrorLog).getKind - -getKind + +(methodREQErrorLog).getKind - + github.com/RaaLabs/steward.newSubject->(github.com/RaaLabs/steward.methodREQErrorLog).getKind - - - - - -(github.com/RaaLabs/steward.methodREQHello).getKind - -getKind - - - -github.com/RaaLabs/steward.newSubject->(github.com/RaaLabs/steward.methodREQHello).getKind - - - - - -(github.com/RaaLabs/steward.methodREQHttpGet).getKind - -getKind - - - -github.com/RaaLabs/steward.newSubject->(github.com/RaaLabs/steward.methodREQHttpGet).getKind - - + + - + (github.com/RaaLabs/steward.methodREQInitial).getKind - -getKind + +(methodREQInitial).getKind - + github.com/RaaLabs/steward.newSubject->(github.com/RaaLabs/steward.methodREQInitial).getKind - - + + - + (github.com/RaaLabs/steward.methodREQOpCommand).getKind - -getKind + +(methodREQOpCommand).getKind - + github.com/RaaLabs/steward.newSubject->(github.com/RaaLabs/steward.methodREQOpCommand).getKind - - + + - + (github.com/RaaLabs/steward.methodREQPing).getKind - -getKind + +(methodREQPing).getKind - + github.com/RaaLabs/steward.newSubject->(github.com/RaaLabs/steward.methodREQPing).getKind - - + + - - -(github.com/RaaLabs/steward.methodREQPong).getKind - -getKind + + +(github.com/RaaLabs/steward.methodREQCliCommand).getKind + +(methodREQCliCommand).getKind - - -github.com/RaaLabs/steward.newSubject->(github.com/RaaLabs/steward.methodREQPong).getKind - - - - - -(github.com/RaaLabs/steward.methodREQTextToConsole).getKind - -getKind - - - -github.com/RaaLabs/steward.newSubject->(github.com/RaaLabs/steward.methodREQTextToConsole).getKind - - - - - -(github.com/RaaLabs/steward.methodREQTextToFile).getKind - -getKind - - - -github.com/RaaLabs/steward.newSubject->(github.com/RaaLabs/steward.methodREQTextToFile).getKind - - - - - -(github.com/RaaLabs/steward.methodREQTextToLogFile).getKind - -getKind - - + -github.com/RaaLabs/steward.newSubject->(github.com/RaaLabs/steward.methodREQTextToLogFile).getKind - - +github.com/RaaLabs/steward.newSubject->(github.com/RaaLabs/steward.methodREQCliCommand).getKind + + + + + +(github.com/RaaLabs/steward.methodREQToConsole).getKind + +(methodREQToConsole).getKind + + + +github.com/RaaLabs/steward.newSubject->(github.com/RaaLabs/steward.methodREQToConsole).getKind + + + + + +(github.com/RaaLabs/steward.methodREQHttpGet).getKind + +(methodREQHttpGet).getKind + + + +github.com/RaaLabs/steward.newSubject->(github.com/RaaLabs/steward.methodREQHttpGet).getKind + + + + + +(github.com/RaaLabs/steward.methodREQToFile).getKind + +(methodREQToFile).getKind + + + +github.com/RaaLabs/steward.newSubject->(github.com/RaaLabs/steward.methodREQToFile).getKind + + + + + +(github.com/RaaLabs/steward.methodREQToFileAppend).getKind + +(methodREQToFileAppend).getKind + + + +github.com/RaaLabs/steward.newSubject->(github.com/RaaLabs/steward.methodREQToFileAppend).getKind + + + + + +(github.com/RaaLabs/steward.methodREQnCliCommandCont).getKind + +(methodREQnCliCommandCont).getKind + + + +github.com/RaaLabs/steward.newSubject->(github.com/RaaLabs/steward.methodREQnCliCommandCont).getKind + + - + (github.com/RaaLabs/steward.methodREQnCliCommand).getKind - -getKind + +(methodREQnCliCommand).getKind github.com/RaaLabs/steward.newSubject->(github.com/RaaLabs/steward.methodREQnCliCommand).getKind - - + + + + + +(github.com/RaaLabs/steward.methodREQToSocket).getKind + +(methodREQToSocket).getKind + + + +github.com/RaaLabs/steward.newSubject->(github.com/RaaLabs/steward.methodREQToSocket).getKind + + + + + +(github.com/RaaLabs/steward.methodREQHello).getKind + +(methodREQHello).getKind + + + +github.com/RaaLabs/steward.newSubject->(github.com/RaaLabs/steward.methodREQHello).getKind + + + + + +(github.com/RaaLabs/steward.methodREQTailFile).getKind + +(methodREQTailFile).getKind + + + +github.com/RaaLabs/steward.newSubject->(github.com/RaaLabs/steward.methodREQTailFile).getKind + + + + + +(github.com/RaaLabs/steward.methodREQPong).getKind + +(methodREQPong).getKind + + + +github.com/RaaLabs/steward.newSubject->(github.com/RaaLabs/steward.methodREQPong).getKind + + - + github.com/RaaLabs/steward.createErrorMsgContent - -createErrorMsgContent + +createErrorMsgContent - + github.com/RaaLabs/steward.createErrorMsgContent->github.com/RaaLabs/steward.newSubject - - + + - + github.com/RaaLabs/steward.sendErrorLogMessage - -sendErrorLogMessage + +sendErrorLogMessage - + github.com/RaaLabs/steward.sendErrorLogMessage->github.com/RaaLabs/steward.createErrorMsgContent - - + + - - -github.com/RaaLabs/steward.newSAM - -newSAM + + +(*github.com/prometheus/client_golang/prometheus.counter).Inc + +(*counter).Inc + + + +github.com/RaaLabs/steward.sendErrorLogMessage->(*github.com/prometheus/client_golang/prometheus.counter).Inc + + + + + +(*github.com/RaaLabs/steward.server).readHTTPlistenerHandler + +(*server).readHTTPlistenerHandler + + + +(*github.com/RaaLabs/steward.server).readHTTPlistenerHandler->github.com/RaaLabs/steward.sendErrorLogMessage + + + + + +(*github.com/RaaLabs/steward.server).convertBytesToSAMs + +(*server).convertBytesToSAMs + + + +(*github.com/RaaLabs/steward.server).readHTTPlistenerHandler->(*github.com/RaaLabs/steward.server).convertBytesToSAMs + + + + + +(*github.com/RaaLabs/steward.server).checkMessageToNodes + +(*server).checkMessageToNodes + + + +(*github.com/RaaLabs/steward.server).checkMessageToNodes->github.com/RaaLabs/steward.sendErrorLogMessage + + + + + +(*github.com/RaaLabs/steward.server).convertBytesToSAMs->(*github.com/RaaLabs/steward.server).checkMessageToNodes + + + + + +github.com/RaaLabs/steward.newSubjectAndMessage + +newSubjectAndMessage + + + +(*github.com/RaaLabs/steward.server).convertBytesToSAMs->github.com/RaaLabs/steward.newSubjectAndMessage + + + + + +(*github.com/prometheus/client_golang/prometheus.counter).Add + +(*counter).Add + + + +(*github.com/RaaLabs/steward.server).convertBytesToSAMs->(*github.com/prometheus/client_golang/prometheus.counter).Add + + - -(github.com/RaaLabs/steward.Method).getHandler - -getHandler - - - -github.com/RaaLabs/steward.newSAM->(github.com/RaaLabs/steward.Method).getHandler - - - - - -github.com/RaaLabs/steward.newSAM->(github.com/RaaLabs/steward.methodREQCliCommand).getKind - - - - - -github.com/RaaLabs/steward.newSAM->(github.com/RaaLabs/steward.methodREQErrorLog).getKind - - - - - -github.com/RaaLabs/steward.newSAM->(github.com/RaaLabs/steward.methodREQHello).getKind - - - - - -github.com/RaaLabs/steward.newSAM->(github.com/RaaLabs/steward.methodREQHttpGet).getKind - - - - - -github.com/RaaLabs/steward.newSAM->(github.com/RaaLabs/steward.methodREQInitial).getKind - - - - - -github.com/RaaLabs/steward.newSAM->(github.com/RaaLabs/steward.methodREQOpCommand).getKind - - - - - -github.com/RaaLabs/steward.newSAM->(github.com/RaaLabs/steward.methodREQPing).getKind - - - - - -github.com/RaaLabs/steward.newSAM->(github.com/RaaLabs/steward.methodREQPong).getKind - - - - - -github.com/RaaLabs/steward.newSAM->(github.com/RaaLabs/steward.methodREQTextToConsole).getKind - - - - - -github.com/RaaLabs/steward.newSAM->(github.com/RaaLabs/steward.methodREQTextToFile).getKind - - - - - -github.com/RaaLabs/steward.newSAM->(github.com/RaaLabs/steward.methodREQTextToLogFile).getKind - - - - - -github.com/RaaLabs/steward.newSAM->(github.com/RaaLabs/steward.methodREQnCliCommand).getKind - - - - - -github.com/RaaLabs/steward.newReplyMessage - -newReplyMessage - - - -github.com/RaaLabs/steward.newReplyMessage->github.com/RaaLabs/steward.newSAM - - - - - -github.com/RaaLabs/steward.newProcess - -newProcess - - - -github.com/RaaLabs/steward.newProcess->(github.com/RaaLabs/steward.Method).GetMethodsAvailable - - - - - -github.com/RaaLabs/steward.processNameGet - -processNameGet - - - -github.com/RaaLabs/steward.gobEncodeMessage - -gobEncodeMessage - - - -(github.com/RaaLabs/steward.methodREQCliCommand).handler$1$1 - -(methodREQCliCommand).handler$1$1 - - - -(github.com/RaaLabs/steward.methodREQHttpGet).handler$1$1 - -(methodREQHttpGet).handler$1$1 - - - -(github.com/RaaLabs/steward.methodREQHttpGet).handler$1$1->github.com/RaaLabs/steward.sendErrorLogMessage - - - - - -github.com/RaaLabs/steward.newErrorKernel - -newErrorKernel - - - -(*github.com/RaaLabs/steward.errorKernel).startErrorKernel$1$1 - -(*errorKernel).startErrorKernel$1$1 - - - -github.com/RaaLabs/steward.convertBytesToSAM - -convertBytesToSAM - - - -github.com/RaaLabs/steward.convertBytesToSAM->github.com/RaaLabs/steward.newSAM - - - - - -github.com/RaaLabs/steward.newringBuffer - -newringBuffer - - - -go.etcd.io/bbolt.Open - -Open - - - -github.com/RaaLabs/steward.newringBuffer->go.etcd.io/bbolt.Open - - - - - -github.com/RaaLabs/steward.newConfigurationDefaults - -newConfigurationDefaults - - - -github.com/RaaLabs/steward.NewConfiguration - -NewConfiguration - - - -github.com/RaaLabs/steward.NewServer - -NewServer - - - -github.com/RaaLabs/steward.newMetrics - -newMetrics - - - -github.com/RaaLabs/steward.NewServer->github.com/RaaLabs/steward.newMetrics - - - - - -github.com/RaaLabs/steward.newProcesses - -newProcesses - - - -github.com/RaaLabs/steward.NewServer->github.com/RaaLabs/steward.newProcesses - - - - - -github.com/nats-io/nats.go.Connect - -Connect - - - -github.com/RaaLabs/steward.NewServer->github.com/nats-io/nats.go.Connect - - - - - -(*github.com/RaaLabs/steward.Configuration).WriteConfigFile - -WriteConfigFile - - - -github.com/pelletier/go-toml.NewEncoder - -NewEncoder - - - -(*github.com/RaaLabs/steward.Configuration).WriteConfigFile->github.com/pelletier/go-toml.NewEncoder - - - - - -(*github.com/pelletier/go-toml.Encoder).Encode - -Encode - - - -(*github.com/RaaLabs/steward.Configuration).WriteConfigFile->(*github.com/pelletier/go-toml.Encoder).Encode - - - - - -(*github.com/RaaLabs/steward.Configuration).ReadConfigFile - -ReadConfigFile - - - -github.com/pelletier/go-toml.NewDecoder - -NewDecoder - - - -(*github.com/RaaLabs/steward.Configuration).ReadConfigFile->github.com/pelletier/go-toml.NewDecoder - - - - - -(*github.com/pelletier/go-toml.Decoder).Decode - -Decode - - - -(*github.com/RaaLabs/steward.Configuration).ReadConfigFile->(*github.com/pelletier/go-toml.Decoder).Decode - - - - - -(*github.com/RaaLabs/steward.Configuration).CheckFlags - -CheckFlags - - - -(*github.com/RaaLabs/steward.Configuration).CheckFlags->github.com/RaaLabs/steward.newConfigurationDefaults - - - - - -(*github.com/RaaLabs/steward.Configuration).CheckFlags->(*github.com/RaaLabs/steward.Configuration).WriteConfigFile - - - - - -(*github.com/RaaLabs/steward.Configuration).CheckFlags->(*github.com/RaaLabs/steward.Configuration).ReadConfigFile - - - - -(*github.com/RaaLabs/steward.errorKernel).startErrorKernel$1 - -startErrorKernel$1 - - - -(*github.com/RaaLabs/steward.errorKernel).startErrorKernel$1->(*github.com/RaaLabs/steward.errorKernel).startErrorKernel$1$1 - - - - - - - -(*github.com/RaaLabs/steward.errorKernel).startErrorKernel - -startErrorKernel - - - -(*github.com/RaaLabs/steward.errorKernel).startErrorKernel->(*github.com/RaaLabs/steward.errorKernel).startErrorKernel$1 - - - - - - - -(*github.com/RaaLabs/steward.flagNodeSlice).Set - -Set - - - -(*github.com/RaaLabs/steward.flagNodeSlice).Parse - -Parse - - - -(*github.com/RaaLabs/steward.flagNodeSlice).Set->(*github.com/RaaLabs/steward.flagNodeSlice).Parse - - - - - -(*github.com/RaaLabs/steward.processes).printProcessesMap - -printProcessesMap - - - -(github.com/RaaLabs/steward.Subject).name - -name - - - -(*github.com/RaaLabs/steward.processes).printProcessesMap->(github.com/RaaLabs/steward.Subject).name - - - - - -github.com/prometheus/client_golang/prometheus.NewGauge - -NewGauge - - - -(*github.com/RaaLabs/steward.processes).printProcessesMap->github.com/prometheus/client_golang/prometheus.NewGauge - - - - - -(*github.com/RaaLabs/steward.ringBuffer).dbUpdate$1 - -dbUpdate$1 - - - -(*go.etcd.io/bbolt.Bucket).Put - -Put - - - -(*github.com/RaaLabs/steward.ringBuffer).dbUpdate$1->(*go.etcd.io/bbolt.Bucket).Put - - - - - -(*go.etcd.io/bbolt.Tx).CreateBucketIfNotExists - -CreateBucketIfNotExists - - - -(*github.com/RaaLabs/steward.ringBuffer).dbUpdate$1->(*go.etcd.io/bbolt.Tx).CreateBucketIfNotExists - - - - - -(*github.com/RaaLabs/steward.ringBuffer).deleteKeyFromBucket$1 - -deleteKeyFromBucket$1 - - - -(*go.etcd.io/bbolt.Bucket).Delete - -Delete - - - -(*github.com/RaaLabs/steward.ringBuffer).deleteKeyFromBucket$1->(*go.etcd.io/bbolt.Bucket).Delete - - - - - -(*go.etcd.io/bbolt.Tx).Bucket - -Bucket - - - -(*github.com/RaaLabs/steward.ringBuffer).deleteKeyFromBucket$1->(*go.etcd.io/bbolt.Tx).Bucket - - - - - -(*github.com/RaaLabs/steward.ringBuffer).printBucketContent$1 - -printBucketContent$1 - - - -(*go.etcd.io/bbolt.Bucket).ForEach - -ForEach - - - -(*github.com/RaaLabs/steward.ringBuffer).printBucketContent$1->(*go.etcd.io/bbolt.Bucket).ForEach - - - - - -(*github.com/RaaLabs/steward.ringBuffer).printBucketContent$1->(*go.etcd.io/bbolt.Tx).Bucket - - - - - -(*github.com/RaaLabs/steward.ringBuffer).deleteKeyFromBucket - -deleteKeyFromBucket - - - -(*go.etcd.io/bbolt.DB).Update - -Update - - - -(*github.com/RaaLabs/steward.ringBuffer).deleteKeyFromBucket->(*go.etcd.io/bbolt.DB).Update - - - - - -(*github.com/RaaLabs/steward.ringBuffer).processBufferMessages$1 - -processBufferMessages$1 - - - -(*github.com/RaaLabs/steward.ringBuffer).processBufferMessages$1->(*github.com/RaaLabs/steward.ringBuffer).deleteKeyFromBucket - - - - - -(*github.com/RaaLabs/steward.ringBuffer).printBucketContent - -printBucketContent - - - -(*github.com/RaaLabs/steward.ringBuffer).processBufferMessages$1->(*github.com/RaaLabs/steward.ringBuffer).printBucketContent - - - - - -(*github.com/RaaLabs/steward.ringBuffer).dbView$1 - -dbView$1 - - - -(*go.etcd.io/bbolt.Bucket).Get - -Get - - - -(*github.com/RaaLabs/steward.ringBuffer).dbView$1->(*go.etcd.io/bbolt.Bucket).Get - - - - - -(*github.com/RaaLabs/steward.ringBuffer).dbView$1->(*go.etcd.io/bbolt.Tx).Bucket - - - - - -(*github.com/RaaLabs/steward.ringBuffer).dumpBucket$1 - -dumpBucket$1 - - - -(*github.com/RaaLabs/steward.ringBuffer).dumpBucket$1->(*go.etcd.io/bbolt.Bucket).ForEach - - - - - -(*github.com/RaaLabs/steward.ringBuffer).dumpBucket$1->(*go.etcd.io/bbolt.Tx).Bucket - - - - - -(*go.etcd.io/bbolt.DB).View - -View - - - -(*github.com/RaaLabs/steward.ringBuffer).printBucketContent->(*go.etcd.io/bbolt.DB).View - - - - - -(*github.com/RaaLabs/steward.ringBuffer).dbView - -dbView - - - -(*github.com/RaaLabs/steward.ringBuffer).dbView->(*go.etcd.io/bbolt.DB).View - - - - - -(*github.com/RaaLabs/steward.ringBuffer).getIndexValue - -getIndexValue - - - -(*github.com/RaaLabs/steward.ringBuffer).getIndexValue->(*github.com/RaaLabs/steward.ringBuffer).dbView - - - - - -(*github.com/RaaLabs/steward.ringBuffer).start - -start - - - -(*github.com/RaaLabs/steward.ringBuffer).start->(*github.com/RaaLabs/steward.ringBuffer).getIndexValue - - - - - -(*github.com/RaaLabs/steward.ringBuffer).fillBuffer - -fillBuffer - - - -(*github.com/RaaLabs/steward.ringBuffer).start->(*github.com/RaaLabs/steward.ringBuffer).fillBuffer - - - - - - - -(*github.com/RaaLabs/steward.ringBuffer).startPermanentStore - -startPermanentStore - - - -(*github.com/RaaLabs/steward.ringBuffer).start->(*github.com/RaaLabs/steward.ringBuffer).startPermanentStore - - - - - - - -(*github.com/RaaLabs/steward.ringBuffer).processBufferMessages - -processBufferMessages - - - -(*github.com/RaaLabs/steward.ringBuffer).start->(*github.com/RaaLabs/steward.ringBuffer).processBufferMessages - - - - - - - -(*github.com/RaaLabs/steward.ringBuffer).dumpBucket - -dumpBucket - - - -(*github.com/RaaLabs/steward.ringBuffer).dumpBucket->(*go.etcd.io/bbolt.DB).View - - - - - -(*github.com/RaaLabs/steward.ringBuffer).fillBuffer$1 - -fillBuffer$1 - - - -(*github.com/RaaLabs/steward.ringBuffer).fillBuffer$1->github.com/RaaLabs/steward.sendErrorLogMessage - - - - - -(*github.com/RaaLabs/steward.ringBuffer).fillBuffer$1->(*github.com/RaaLabs/steward.ringBuffer).dumpBucket - - - - - -(*github.com/RaaLabs/steward.ringBuffer).fillBuffer->github.com/RaaLabs/steward.sendErrorLogMessage - - - - - -(*github.com/RaaLabs/steward.ringBuffer).fillBuffer->(*github.com/RaaLabs/steward.ringBuffer).fillBuffer$1 - - - - - -(*github.com/RaaLabs/steward.ringBuffer).dbUpdate - -dbUpdate - - - -(*github.com/RaaLabs/steward.ringBuffer).fillBuffer->(*github.com/RaaLabs/steward.ringBuffer).dbUpdate - - - - - -(github.com/RaaLabs/steward.CommandOrEvent).GetCommandOrEventAvailable - -GetCommandOrEventAvailable - - - -(*github.com/RaaLabs/steward.ringBuffer).fillBuffer->(github.com/RaaLabs/steward.CommandOrEvent).GetCommandOrEventAvailable - - - - - -(github.com/RaaLabs/steward.CommandOrEventAvailable).CheckIfExists - -CheckIfExists - - - -(*github.com/RaaLabs/steward.ringBuffer).fillBuffer->(github.com/RaaLabs/steward.CommandOrEventAvailable).CheckIfExists - - - - - -(*github.com/RaaLabs/steward.ringBuffer).dbUpdate->(*go.etcd.io/bbolt.DB).Update - - - - - -(*github.com/RaaLabs/steward.ringBuffer).processBufferMessages->(*github.com/RaaLabs/steward.ringBuffer).processBufferMessages$1 - - - - - - - -(*github.com/RaaLabs/steward.server).startMetrics$1 - -startMetrics$1 - - - -github.com/prometheus/client_golang/prometheus.Register - -Register - - - -(*github.com/RaaLabs/steward.server).startMetrics$1->github.com/prometheus/client_golang/prometheus.Register - - - - - -(*github.com/prometheus/client_golang/prometheus.gauge).Set - -Set - - - -(*github.com/RaaLabs/steward.server).startMetrics$1->(*github.com/prometheus/client_golang/prometheus.gauge).Set - - - - - -(*github.com/RaaLabs/steward.server).startMetrics - -startMetrics - - - -(*github.com/RaaLabs/steward.server).startMetrics->(*github.com/RaaLabs/steward.server).startMetrics$1 - - - - - - - -github.com/prometheus/client_golang/prometheus/promhttp.Handler - -Handler - - - -(*github.com/RaaLabs/steward.server).startMetrics->github.com/prometheus/client_golang/prometheus/promhttp.Handler - - - - - -(*github.com/RaaLabs/steward.server).Start - -Start - - - -(*github.com/RaaLabs/steward.server).Start->github.com/RaaLabs/steward.newSubject - - - - - -(*github.com/RaaLabs/steward.server).Start->github.com/RaaLabs/steward.newProcess - - - - - -(*github.com/RaaLabs/steward.server).Start->github.com/RaaLabs/steward.newErrorKernel - - - - - -(*github.com/RaaLabs/steward.server).Start->(*github.com/RaaLabs/steward.errorKernel).startErrorKernel - - - - - -(*github.com/RaaLabs/steward.server).Start->(*github.com/RaaLabs/steward.processes).printProcessesMap - - - - - -(*github.com/RaaLabs/steward.server).Start->(*github.com/RaaLabs/steward.server).startMetrics - - - - - - - -(*github.com/RaaLabs/steward.server).readSocket - -readSocket - - - -(*github.com/RaaLabs/steward.server).Start->(*github.com/RaaLabs/steward.server).readSocket - - - - - - - -(*github.com/RaaLabs/steward.server).routeMessagesToProcess - -routeMessagesToProcess - - - -(*github.com/RaaLabs/steward.server).Start->(*github.com/RaaLabs/steward.server).routeMessagesToProcess - - - - - -(github.com/RaaLabs/steward.process).ProcessesStart - -ProcessesStart - - - -(*github.com/RaaLabs/steward.server).Start->(github.com/RaaLabs/steward.process).ProcessesStart - - - - - -(*github.com/RaaLabs/steward.server).readSocket->github.com/RaaLabs/steward.sendErrorLogMessage - - - - - -(*github.com/RaaLabs/steward.server).readSocket->github.com/RaaLabs/steward.convertBytesToSAM - - - - - -(*github.com/RaaLabs/steward.server).routeMessagesToProcess->github.com/RaaLabs/steward.newringBuffer - - - - - -(*github.com/RaaLabs/steward.server).routeMessagesToProcess->(*github.com/RaaLabs/steward.ringBuffer).start - - - - - -(*github.com/RaaLabs/steward.server).routeMessagesToProcess$1 - -routeMessagesToProcess$1 - - - -(*github.com/RaaLabs/steward.server).routeMessagesToProcess->(*github.com/RaaLabs/steward.server).routeMessagesToProcess$1 - - - - - - - -(*github.com/RaaLabs/steward.server).routeMessagesToProcess$2 - -routeMessagesToProcess$2 - - - -(*github.com/RaaLabs/steward.server).routeMessagesToProcess->(*github.com/RaaLabs/steward.server).routeMessagesToProcess$2 - - - - - - - -(*github.com/RaaLabs/steward.server).routeMessagesToProcess->(github.com/RaaLabs/steward.CommandOrEvent).GetCommandOrEventAvailable - - - - - -(*github.com/RaaLabs/steward.server).routeMessagesToProcess->(github.com/RaaLabs/steward.Method).GetMethodsAvailable - - - - - -(*github.com/RaaLabs/steward.server).routeMessagesToProcess$2->github.com/RaaLabs/steward.newSubject - - - - - -(*github.com/RaaLabs/steward.server).routeMessagesToProcess$2->github.com/RaaLabs/steward.sendErrorLogMessage - - - - - -(*github.com/RaaLabs/steward.server).routeMessagesToProcess$2->github.com/RaaLabs/steward.newProcess - - - - - -(*github.com/RaaLabs/steward.server).routeMessagesToProcess$2->github.com/RaaLabs/steward.processNameGet - - - - - -(*github.com/RaaLabs/steward.server).routeMessagesToProcess$2->(github.com/RaaLabs/steward.CommandOrEventAvailable).CheckIfExists - - - - - -(github.com/RaaLabs/steward.MethodsAvailable).CheckIfExists - -CheckIfExists - - - -(*github.com/RaaLabs/steward.server).routeMessagesToProcess$2->(github.com/RaaLabs/steward.MethodsAvailable).CheckIfExists - - - - - -(*github.com/RaaLabs/steward.server).routeMessagesToProcess$2->(github.com/RaaLabs/steward.Subject).name - - - - - -(github.com/RaaLabs/steward.process).spawnWorker - -spawnWorker - - - -(*github.com/RaaLabs/steward.server).routeMessagesToProcess$2->(github.com/RaaLabs/steward.process).spawnWorker - - - - - -command-line-arguments.main - -main - - - -command-line-arguments.main->github.com/RaaLabs/steward.NewConfiguration - - - - - -command-line-arguments.main->github.com/RaaLabs/steward.NewServer - - - - - -command-line-arguments.main->(*github.com/RaaLabs/steward.Configuration).CheckFlags - - - - - -command-line-arguments.main->(*github.com/RaaLabs/steward.server).Start - - - - - - - -(github.com/RaaLabs/steward.CommandOrEventAvailable).CheckIfExists->(github.com/RaaLabs/steward.Subject).name - - +(github.com/RaaLabs/steward.Method).getHandler + +(Method).getHandler - + (github.com/RaaLabs/steward.Method).getHandler->(github.com/RaaLabs/steward.Method).GetMethodsAvailable - - + + - - -(github.com/RaaLabs/steward.methodREQCliCommand).handler$1 - -handler$1 + + +github.com/RaaLabs/steward.newSubjectAndMessage->(github.com/RaaLabs/steward.methodREQErrorLog).getKind + + - - -(github.com/RaaLabs/steward.methodREQCliCommand).handler$1->github.com/RaaLabs/steward.sendErrorLogMessage - - + + +github.com/RaaLabs/steward.newSubjectAndMessage->(github.com/RaaLabs/steward.methodREQInitial).getKind + + - - -(github.com/RaaLabs/steward.methodREQCliCommand).handler$1->github.com/RaaLabs/steward.newReplyMessage - - + + +github.com/RaaLabs/steward.newSubjectAndMessage->(github.com/RaaLabs/steward.methodREQOpCommand).getKind + + - - -(github.com/RaaLabs/steward.methodREQCliCommand).handler$1->(github.com/RaaLabs/steward.methodREQCliCommand).handler$1$1 - - - - + + +github.com/RaaLabs/steward.newSubjectAndMessage->(github.com/RaaLabs/steward.methodREQPing).getKind + + - - -(github.com/RaaLabs/steward.methodREQCliCommand).handler - -handler + + +github.com/RaaLabs/steward.newSubjectAndMessage->(github.com/RaaLabs/steward.methodREQCliCommand).getKind + + - - -(github.com/RaaLabs/steward.methodREQCliCommand).handler->(github.com/RaaLabs/steward.methodREQCliCommand).handler$1 - - - - + + +github.com/RaaLabs/steward.newSubjectAndMessage->(github.com/RaaLabs/steward.methodREQToConsole).getKind + + - - -(github.com/RaaLabs/steward.methodREQErrorLog).handler - -handler + + +github.com/RaaLabs/steward.newSubjectAndMessage->(github.com/RaaLabs/steward.methodREQHttpGet).getKind + + - - -(github.com/RaaLabs/steward.methodREQHello).handler - -handler + + +github.com/RaaLabs/steward.newSubjectAndMessage->(github.com/RaaLabs/steward.methodREQToFile).getKind + + - - -(github.com/RaaLabs/steward.methodREQHttpGet).handler$1 - -handler$1 + + +github.com/RaaLabs/steward.newSubjectAndMessage->(github.com/RaaLabs/steward.methodREQToFileAppend).getKind + + - - -(github.com/RaaLabs/steward.methodREQHttpGet).handler$1->github.com/RaaLabs/steward.sendErrorLogMessage - - - - - -(github.com/RaaLabs/steward.methodREQHttpGet).handler$1->github.com/RaaLabs/steward.newReplyMessage - - - - - -(github.com/RaaLabs/steward.methodREQHttpGet).handler$1->(github.com/RaaLabs/steward.methodREQHttpGet).handler$1$1 - - - - - - - -(github.com/RaaLabs/steward.methodREQHttpGet).handler - -handler - - - -(github.com/RaaLabs/steward.methodREQHttpGet).handler->(github.com/RaaLabs/steward.methodREQHttpGet).handler$1 - - - - - - - -(github.com/RaaLabs/steward.methodREQInitial).handler - -handler - - - -(github.com/RaaLabs/steward.methodREQOpCommand).handler$1 - -handler$1 - - - -(github.com/RaaLabs/steward.methodREQOpCommand).handler$1->github.com/RaaLabs/steward.newSubject - - - - - -(github.com/RaaLabs/steward.methodREQOpCommand).handler$1->github.com/RaaLabs/steward.sendErrorLogMessage - - - - - -(github.com/RaaLabs/steward.methodREQOpCommand).handler$1->github.com/RaaLabs/steward.newReplyMessage - - - - - -(github.com/RaaLabs/steward.methodREQOpCommand).handler$1->github.com/RaaLabs/steward.newProcess - - - - - -(github.com/RaaLabs/steward.methodREQOpCommand).handler$1->github.com/RaaLabs/steward.processNameGet - - - - - -(github.com/RaaLabs/steward.methodREQOpCommand).handler$1->(github.com/RaaLabs/steward.Subject).name - - - - - -(github.com/RaaLabs/steward.methodREQOpCommand).handler$1->(github.com/RaaLabs/steward.process).spawnWorker - - - - - - - -(*github.com/nats-io/nats.go.Subscription).Unsubscribe - -Unsubscribe - - - -(github.com/RaaLabs/steward.methodREQOpCommand).handler$1->(*github.com/nats-io/nats.go.Subscription).Unsubscribe - - - - - -(github.com/RaaLabs/steward.methodREQOpCommand).handler - -handler - - - -(github.com/RaaLabs/steward.methodREQOpCommand).handler->(github.com/RaaLabs/steward.methodREQOpCommand).handler$1 - - - - - - - -(github.com/RaaLabs/steward.methodREQPing).handler$1 - -handler$1 - - - -(github.com/RaaLabs/steward.methodREQPing).handler$1->github.com/RaaLabs/steward.newReplyMessage - - - - - -(github.com/RaaLabs/steward.methodREQPing).handler - -handler - - - -(github.com/RaaLabs/steward.methodREQPing).handler->(github.com/RaaLabs/steward.methodREQPing).handler$1 - - - - - - - -(github.com/RaaLabs/steward.methodREQPong).handler - -handler - - - -(github.com/RaaLabs/steward.methodREQTextToConsole).handler - -handler - - - -(github.com/RaaLabs/steward.methodREQTextToFile).handler - -handler - - - -(github.com/RaaLabs/steward.methodREQTextToLogFile).handler - -handler - - - -(github.com/RaaLabs/steward.methodREQnCliCommand).handler$1 - -handler$1 - - - -(github.com/RaaLabs/steward.methodREQnCliCommand).handler$1->(github.com/RaaLabs/steward.methodREQnCliCommand).handler$1$1 - - - - - - - -(github.com/RaaLabs/steward.methodREQnCliCommand).handler$1->github.com/RaaLabs/steward.sendErrorLogMessage - - - - + -(github.com/RaaLabs/steward.methodREQnCliCommand).handler$1->github.com/RaaLabs/steward.newReplyMessage - - +github.com/RaaLabs/steward.newSubjectAndMessage->(github.com/RaaLabs/steward.methodREQnCliCommandCont).getKind + + - - -(github.com/RaaLabs/steward.methodREQnCliCommand).handler - -handler + + +github.com/RaaLabs/steward.newSubjectAndMessage->(github.com/RaaLabs/steward.methodREQnCliCommand).getKind + + - - -(github.com/RaaLabs/steward.methodREQnCliCommand).handler->(github.com/RaaLabs/steward.methodREQnCliCommand).handler$1 - - - - + + +github.com/RaaLabs/steward.newSubjectAndMessage->(github.com/RaaLabs/steward.methodREQToSocket).getKind + + - + + +github.com/RaaLabs/steward.newSubjectAndMessage->(github.com/RaaLabs/steward.methodREQHello).getKind + + + + + +github.com/RaaLabs/steward.newSubjectAndMessage->(github.com/RaaLabs/steward.methodREQTailFile).getKind + + + + + +github.com/RaaLabs/steward.newSubjectAndMessage->(github.com/RaaLabs/steward.methodREQPong).getKind + + + + + +github.com/RaaLabs/steward.newSubjectAndMessage->(github.com/RaaLabs/steward.Method).getHandler + + + + + +(*github.com/RaaLabs/steward.ringBuffer).dbView$1 + +(*ringBuffer).dbView$1 + + + +(*github.com/RaaLabs/steward.ringBuffer).dbView$1->(*go.etcd.io/bbolt.Tx).Bucket + + + + + +(*go.etcd.io/bbolt.Bucket).Get + +(*Bucket).Get + + + +(*github.com/RaaLabs/steward.ringBuffer).dbView$1->(*go.etcd.io/bbolt.Bucket).Get + + + + + +(*github.com/RaaLabs/steward.ringBuffer).dumpBucket$1 + +(*ringBuffer).dumpBucket$1 + + + +(*go.etcd.io/bbolt.Bucket).ForEach + +(*Bucket).ForEach + + + +(*github.com/RaaLabs/steward.ringBuffer).dumpBucket$1->(*go.etcd.io/bbolt.Bucket).ForEach + + + + + +(*github.com/RaaLabs/steward.ringBuffer).dumpBucket$1->(*go.etcd.io/bbolt.Tx).Bucket + + + + + +(*github.com/RaaLabs/steward.ringBuffer).dbView + +(*ringBuffer).dbView + + + +(*go.etcd.io/bbolt.DB).View + +(*DB).View + + -(github.com/RaaLabs/steward.process).spawnWorker->github.com/RaaLabs/steward.processNameGet - - +(*github.com/RaaLabs/steward.ringBuffer).dbView->(*go.etcd.io/bbolt.DB).View + + - - -(github.com/RaaLabs/steward.process).spawnWorker->(github.com/RaaLabs/steward.Subject).name - - + + +(*github.com/RaaLabs/steward.ringBuffer).getIndexValue + +(*ringBuffer).getIndexValue - - -(github.com/RaaLabs/steward.process).spawnWorker$1 - -spawnWorker$1 - - - -(github.com/RaaLabs/steward.process).spawnWorker->(github.com/RaaLabs/steward.process).spawnWorker$1 - - - - - - - -(github.com/RaaLabs/steward.process).publishMessages - -publishMessages - - - -(github.com/RaaLabs/steward.process).spawnWorker->(github.com/RaaLabs/steward.process).publishMessages - - - - - - - -(github.com/RaaLabs/steward.process).spawnWorker$2 - -spawnWorker$2 - - - -(github.com/RaaLabs/steward.process).spawnWorker->(github.com/RaaLabs/steward.process).spawnWorker$2 - - - - - - - -(github.com/RaaLabs/steward.process).subscribeMessages - -subscribeMessages - - - -(github.com/RaaLabs/steward.process).spawnWorker->(github.com/RaaLabs/steward.process).subscribeMessages - - - - + -(github.com/RaaLabs/steward.process).spawnWorker$1->github.com/RaaLabs/steward.sendErrorLogMessage - - +(*github.com/RaaLabs/steward.ringBuffer).getIndexValue->(*github.com/RaaLabs/steward.ringBuffer).dbView + + - - -(github.com/RaaLabs/steward.startup).pubREQHello$1 - -pubREQHello$1 + + +(*github.com/RaaLabs/steward.metrics).start + +(*metrics).start - - -(github.com/RaaLabs/steward.process).spawnWorker$1->(github.com/RaaLabs/steward.startup).pubREQHello$1 - - + + +github.com/prometheus/client_golang/prometheus/promhttp.HandlerFor + +HandlerFor - - -(github.com/RaaLabs/steward.startup).subREQHello$1 - -subREQHello$1 + + +(*github.com/RaaLabs/steward.metrics).start->github.com/prometheus/client_golang/prometheus/promhttp.HandlerFor + + - - -(github.com/RaaLabs/steward.process).spawnWorker$1->(github.com/RaaLabs/steward.startup).subREQHello$1 - - + + +(*github.com/RaaLabs/steward.server).Start$2 + +(*server).Start$2 - - -(github.com/RaaLabs/steward.process).publishMessages->github.com/RaaLabs/steward.sendErrorLogMessage - - - - - -(github.com/RaaLabs/steward.process).publishMessages->github.com/RaaLabs/steward.processNameGet - - - - - -(github.com/RaaLabs/steward.process).publishMessages->(github.com/RaaLabs/steward.Subject).name - - - - - -(github.com/RaaLabs/steward.process).messageDeliverNats - -messageDeliverNats - - - -(github.com/RaaLabs/steward.process).publishMessages->(github.com/RaaLabs/steward.process).messageDeliverNats - - - - - -(github.com/RaaLabs/steward.process).messageDeliverNats->github.com/RaaLabs/steward.sendErrorLogMessage - - - - - -(github.com/RaaLabs/steward.process).messageDeliverNats->github.com/RaaLabs/steward.gobEncodeMessage - - - - - -(github.com/RaaLabs/steward.process).messageDeliverNats->(github.com/RaaLabs/steward.Subject).name - - - - - -(*github.com/nats-io/nats.go.Conn).SubscribeSync - -SubscribeSync - - - -(github.com/RaaLabs/steward.process).messageDeliverNats->(*github.com/nats-io/nats.go.Conn).SubscribeSync - - - - - -(*github.com/nats-io/nats.go.Conn).PublishMsg - -PublishMsg - - - -(github.com/RaaLabs/steward.process).messageDeliverNats->(*github.com/nats-io/nats.go.Conn).PublishMsg - - - - - -(*github.com/nats-io/nats.go.Subscription).NextMsg - -NextMsg - - - -(github.com/RaaLabs/steward.process).messageDeliverNats->(*github.com/nats-io/nats.go.Subscription).NextMsg - - + + +(*github.com/RaaLabs/steward.server).Start$2->(*github.com/RaaLabs/steward.metrics).start + + - + (github.com/RaaLabs/steward.process).subscriberHandler - -subscriberHandler + +(process).subscriberHandler - + (github.com/RaaLabs/steward.process).subscriberHandler->github.com/RaaLabs/steward.sendErrorLogMessage - - + + + + + +(github.com/RaaLabs/steward.MethodsAvailable).CheckIfExists + +(MethodsAvailable).CheckIfExists - + (github.com/RaaLabs/steward.process).subscriberHandler->(github.com/RaaLabs/steward.MethodsAvailable).CheckIfExists - - + + - - -(github.com/RaaLabs/steward.process).subscriberHandler->(github.com/RaaLabs/steward.methodREQCliCommand).handler - - + + +(github.com/RaaLabs/steward.methodREQErrorLog).handler + +(methodREQErrorLog).handler - + (github.com/RaaLabs/steward.process).subscriberHandler->(github.com/RaaLabs/steward.methodREQErrorLog).handler - - + + - - -(github.com/RaaLabs/steward.process).subscriberHandler->(github.com/RaaLabs/steward.methodREQHello).handler - - - - - -(github.com/RaaLabs/steward.process).subscriberHandler->(github.com/RaaLabs/steward.methodREQHttpGet).handler - - + + +(github.com/RaaLabs/steward.methodREQInitial).handler + +(methodREQInitial).handler - + (github.com/RaaLabs/steward.process).subscriberHandler->(github.com/RaaLabs/steward.methodREQInitial).handler - - + + + + + +(github.com/RaaLabs/steward.methodREQOpCommand).handler + +(methodREQOpCommand).handler - + (github.com/RaaLabs/steward.process).subscriberHandler->(github.com/RaaLabs/steward.methodREQOpCommand).handler - - + + + + + +(github.com/RaaLabs/steward.methodREQPing).handler + +(methodREQPing).handler - + (github.com/RaaLabs/steward.process).subscriberHandler->(github.com/RaaLabs/steward.methodREQPing).handler - - + + - - -(github.com/RaaLabs/steward.process).subscriberHandler->(github.com/RaaLabs/steward.methodREQPong).handler - - + + +(github.com/RaaLabs/steward.methodREQCliCommand).handler + +(methodREQCliCommand).handler - - -(github.com/RaaLabs/steward.process).subscriberHandler->(github.com/RaaLabs/steward.methodREQTextToConsole).handler - - + + +(github.com/RaaLabs/steward.process).subscriberHandler->(github.com/RaaLabs/steward.methodREQCliCommand).handler + + - - -(github.com/RaaLabs/steward.process).subscriberHandler->(github.com/RaaLabs/steward.methodREQTextToFile).handler - - + + +(github.com/RaaLabs/steward.methodREQToConsole).handler + +(methodREQToConsole).handler - - -(github.com/RaaLabs/steward.process).subscriberHandler->(github.com/RaaLabs/steward.methodREQTextToLogFile).handler - - + + +(github.com/RaaLabs/steward.process).subscriberHandler->(github.com/RaaLabs/steward.methodREQToConsole).handler + + + + + +(github.com/RaaLabs/steward.methodREQHttpGet).handler + +(methodREQHttpGet).handler + + + +(github.com/RaaLabs/steward.process).subscriberHandler->(github.com/RaaLabs/steward.methodREQHttpGet).handler + + + + + +(github.com/RaaLabs/steward.methodREQToFile).handler + +(methodREQToFile).handler + + + +(github.com/RaaLabs/steward.process).subscriberHandler->(github.com/RaaLabs/steward.methodREQToFile).handler + + + + + +(github.com/RaaLabs/steward.methodREQToFileAppend).handler + +(methodREQToFileAppend).handler + + + +(github.com/RaaLabs/steward.process).subscriberHandler->(github.com/RaaLabs/steward.methodREQToFileAppend).handler + + + + + +(github.com/RaaLabs/steward.methodREQnCliCommandCont).handler + +(methodREQnCliCommandCont).handler + + + +(github.com/RaaLabs/steward.process).subscriberHandler->(github.com/RaaLabs/steward.methodREQnCliCommandCont).handler + + + + + +(github.com/RaaLabs/steward.methodREQnCliCommand).handler + +(methodREQnCliCommand).handler - + (github.com/RaaLabs/steward.process).subscriberHandler->(github.com/RaaLabs/steward.methodREQnCliCommand).handler - - + + + + + +(github.com/RaaLabs/steward.methodREQToSocket).handler + +(methodREQToSocket).handler + + + +(github.com/RaaLabs/steward.process).subscriberHandler->(github.com/RaaLabs/steward.methodREQToSocket).handler + + + + + +(github.com/RaaLabs/steward.methodREQHello).handler + +(methodREQHello).handler + + + +(github.com/RaaLabs/steward.process).subscriberHandler->(github.com/RaaLabs/steward.methodREQHello).handler + + + + + +(github.com/RaaLabs/steward.methodREQTailFile).handler + +(methodREQTailFile).handler + + + +(github.com/RaaLabs/steward.process).subscriberHandler->(github.com/RaaLabs/steward.methodREQTailFile).handler + + + + + +(github.com/RaaLabs/steward.methodREQPong).handler + +(methodREQPong).handler + + + +(github.com/RaaLabs/steward.process).subscriberHandler->(github.com/RaaLabs/steward.methodREQPong).handler + + - + (*github.com/nats-io/nats.go.Conn).Publish - -Publish + +(*Conn).Publish - + (github.com/RaaLabs/steward.process).subscriberHandler->(*github.com/nats-io/nats.go.Conn).Publish - - + + - - -(github.com/RaaLabs/steward.process).subscribeMessages$1 - -subscribeMessages$1 + + +github.com/RaaLabs/steward.selectFileNaming + +selectFileNaming - - -(github.com/RaaLabs/steward.process).subscribeMessages$1->(github.com/RaaLabs/steward.process).subscriberHandler - - - - + + +(github.com/RaaLabs/steward.methodREQErrorLog).handler->github.com/RaaLabs/steward.selectFileNaming + + - + + +(github.com/RaaLabs/steward.methodREQErrorLog).handler->(*github.com/prometheus/client_golang/prometheus.counter).Inc + + + + + +github.com/RaaLabs/steward.newReplyMessage + +newReplyMessage + + + +github.com/RaaLabs/steward.newReplyMessage->github.com/RaaLabs/steward.sendErrorLogMessage + + + + + +github.com/RaaLabs/steward.newReplyMessage->github.com/RaaLabs/steward.newSubjectAndMessage + + + + + +(github.com/RaaLabs/steward.methodREQOpCommand).handler$1 + +(methodREQOpCommand).handler$1 + + + +(github.com/RaaLabs/steward.methodREQOpCommand).handler$1->github.com/RaaLabs/steward.newSubject + + + + + +(github.com/RaaLabs/steward.methodREQOpCommand).handler$1->github.com/RaaLabs/steward.sendErrorLogMessage + + + + + +(github.com/RaaLabs/steward.methodREQOpCommand).handler$1->github.com/RaaLabs/steward.newReplyMessage + + + + + +(github.com/RaaLabs/steward.Subject).name + +(Subject).name + + + +(github.com/RaaLabs/steward.methodREQOpCommand).handler$1->(github.com/RaaLabs/steward.Subject).name + + + + + +github.com/RaaLabs/steward.newProcess + +newProcess + + + +(github.com/RaaLabs/steward.methodREQOpCommand).handler$1->github.com/RaaLabs/steward.newProcess + + + + + +(github.com/RaaLabs/steward.process).spawnWorker + +(process).spawnWorker + + -(github.com/RaaLabs/steward.process).spawnWorker$2->github.com/RaaLabs/steward.sendErrorLogMessage - - +(github.com/RaaLabs/steward.methodREQOpCommand).handler$1->(github.com/RaaLabs/steward.process).spawnWorker + + + + - + + +github.com/RaaLabs/steward.processNameGet + +processNameGet + + -(github.com/RaaLabs/steward.process).spawnWorker$2->(github.com/RaaLabs/steward.startup).pubREQHello$1 - - +(github.com/RaaLabs/steward.methodREQOpCommand).handler$1->github.com/RaaLabs/steward.processNameGet + + - - -(github.com/RaaLabs/steward.process).spawnWorker$2->(github.com/RaaLabs/steward.startup).subREQHello$1 - - + + +(github.com/RaaLabs/steward.methodREQOpCommand).handler$1$1 + +(methodREQOpCommand).handler$1$1 - + + +(github.com/RaaLabs/steward.methodREQOpCommand).handler$1->(github.com/RaaLabs/steward.methodREQOpCommand).handler$1$1 + + + + + +(*github.com/nats-io/nats.go.Subscription).Unsubscribe + +(*Subscription).Unsubscribe + + -(github.com/RaaLabs/steward.process).subscribeMessages->(github.com/RaaLabs/steward.Subject).name - - +(github.com/RaaLabs/steward.methodREQOpCommand).handler$1->(*github.com/nats-io/nats.go.Subscription).Unsubscribe + + - - -(*github.com/nats-io/nats.go.Conn).Subscribe - -Subscribe + + +(*github.com/prometheus/client_golang/prometheus.MetricVec).Delete + +(*MetricVec).Delete - + -(github.com/RaaLabs/steward.process).subscribeMessages->(*github.com/nats-io/nats.go.Conn).Subscribe - - +(github.com/RaaLabs/steward.methodREQOpCommand).handler$1->(*github.com/prometheus/client_golang/prometheus.MetricVec).Delete + + - - -(github.com/RaaLabs/steward.process).ProcessesStart->github.com/RaaLabs/steward.newSubject - - + + +github.com/RaaLabs/steward.newProcess->(github.com/RaaLabs/steward.Method).GetMethodsAvailable + + - - -(github.com/RaaLabs/steward.process).ProcessesStart->github.com/RaaLabs/steward.newProcess - - + + +github.com/RaaLabs/steward.newStartup + +newStartup - - -(github.com/RaaLabs/steward.process).ProcessesStart->(github.com/RaaLabs/steward.process).spawnWorker - - - - + + +github.com/RaaLabs/steward.newProcess->github.com/RaaLabs/steward.newStartup + + - - -(github.com/RaaLabs/steward.startup).subREQPing - -subREQPing + + +(github.com/RaaLabs/steward.process).spawnWorker->(github.com/RaaLabs/steward.Subject).name + + - - -(github.com/RaaLabs/steward.process).ProcessesStart->(github.com/RaaLabs/steward.startup).subREQPing - - + + +(github.com/RaaLabs/steward.process).spawnWorker->github.com/RaaLabs/steward.processNameGet + + - - -(github.com/RaaLabs/steward.startup).subREQTextToLogFile - -subREQTextToLogFile + + +(github.com/RaaLabs/steward.process).spawnWorker$1 + +(process).spawnWorker$1 - - -(github.com/RaaLabs/steward.process).ProcessesStart->(github.com/RaaLabs/steward.startup).subREQTextToLogFile - - + + +(github.com/RaaLabs/steward.process).spawnWorker->(github.com/RaaLabs/steward.process).spawnWorker$1 + + + + - - -(github.com/RaaLabs/steward.startup).subREQTextToFile - -subREQTextToFile + + +(github.com/RaaLabs/steward.process).publishMessages + +(process).publishMessages - - -(github.com/RaaLabs/steward.process).ProcessesStart->(github.com/RaaLabs/steward.startup).subREQTextToFile - - + + +(github.com/RaaLabs/steward.process).spawnWorker->(github.com/RaaLabs/steward.process).publishMessages + + + + - - -(github.com/RaaLabs/steward.startup).subREQHello - -subREQHello + + +(github.com/RaaLabs/steward.process).spawnWorker$2 + +(process).spawnWorker$2 - - -(github.com/RaaLabs/steward.process).ProcessesStart->(github.com/RaaLabs/steward.startup).subREQHello - - + + +(github.com/RaaLabs/steward.process).spawnWorker->(github.com/RaaLabs/steward.process).spawnWorker$2 + + + + - - -(github.com/RaaLabs/steward.startup).subREQErrorLog - -subREQErrorLog + + +(github.com/RaaLabs/steward.process).subscribeMessages + +(process).subscribeMessages - - -(github.com/RaaLabs/steward.process).ProcessesStart->(github.com/RaaLabs/steward.startup).subREQErrorLog - - + + +(github.com/RaaLabs/steward.process).spawnWorker->(github.com/RaaLabs/steward.process).subscribeMessages + + - - -(github.com/RaaLabs/steward.startup).subREQPong - -subREQPong + + +(*github.com/prometheus/client_golang/prometheus.GaugeVec).With + +(*GaugeVec).With - - -(github.com/RaaLabs/steward.process).ProcessesStart->(github.com/RaaLabs/steward.startup).subREQPong - - + + +(github.com/RaaLabs/steward.process).spawnWorker->(*github.com/prometheus/client_golang/prometheus.GaugeVec).With + + - - -(github.com/RaaLabs/steward.startup).subREQCliCommand - -subREQCliCommand + + +(github.com/RaaLabs/steward.process).spawnWorker$1->github.com/RaaLabs/steward.sendErrorLogMessage + + - - -(github.com/RaaLabs/steward.process).ProcessesStart->(github.com/RaaLabs/steward.startup).subREQCliCommand - - + + +(github.com/RaaLabs/steward.startup).pubREQHello$1 + +(startup).pubREQHello$1 - - -(github.com/RaaLabs/steward.startup).subREQnCliCommand - -subREQnCliCommand + + +(github.com/RaaLabs/steward.process).spawnWorker$1->(github.com/RaaLabs/steward.startup).pubREQHello$1 + + - - -(github.com/RaaLabs/steward.process).ProcessesStart->(github.com/RaaLabs/steward.startup).subREQnCliCommand - - + + +(github.com/RaaLabs/steward.startup).subREQHello$1 + +(startup).subREQHello$1 - - -(github.com/RaaLabs/steward.startup).subREQTextToConsole - -subREQTextToConsole + + +(github.com/RaaLabs/steward.process).spawnWorker$1->(github.com/RaaLabs/steward.startup).subREQHello$1 + + - - -(github.com/RaaLabs/steward.process).ProcessesStart->(github.com/RaaLabs/steward.startup).subREQTextToConsole - - - - - -(github.com/RaaLabs/steward.startup).pubREQHello - -pubREQHello - - - -(github.com/RaaLabs/steward.process).ProcessesStart->(github.com/RaaLabs/steward.startup).pubREQHello - - - - - -(github.com/RaaLabs/steward.startup).subREQHttpGet - -subREQHttpGet - - - -(github.com/RaaLabs/steward.process).ProcessesStart->(github.com/RaaLabs/steward.startup).subREQHttpGet - - - - - -(github.com/RaaLabs/steward.startup).pubREQHello$1->github.com/RaaLabs/steward.sendErrorLogMessage - - - - - -(github.com/RaaLabs/steward.startup).pubREQHello$1->github.com/RaaLabs/steward.newSAM - - + + +(github.com/RaaLabs/steward.startup).pubREQHello$1->github.com/RaaLabs/steward.newSubjectAndMessage + + - + (github.com/RaaLabs/steward.startup).pubREQHello$1->(github.com/RaaLabs/steward.Subject).name - - - - - -(github.com/RaaLabs/steward.startup).subREQHello$1->github.com/RaaLabs/steward.sendErrorLogMessage - - + + - + (github.com/RaaLabs/steward.startup).subREQHello$1->(github.com/RaaLabs/steward.Subject).name - - + + - - -(github.com/RaaLabs/steward.startup).subREQHello$1->github.com/prometheus/client_golang/prometheus.NewGauge - - + + +(github.com/RaaLabs/steward.startup).subREQHello$1->(*github.com/prometheus/client_golang/prometheus.GaugeVec).With + + - - -(github.com/RaaLabs/steward.startup).subREQPing->github.com/RaaLabs/steward.newSubject - - + + +(*github.com/prometheus/client_golang/prometheus.gauge).Set + +(*gauge).Set - + + +(github.com/RaaLabs/steward.startup).subREQHello$1->(*github.com/prometheus/client_golang/prometheus.gauge).Set + + + + + +(*github.com/prometheus/client_golang/prometheus.gauge).SetToCurrentTime + +(*gauge).SetToCurrentTime + + + +(github.com/RaaLabs/steward.startup).subREQHello$1->(*github.com/prometheus/client_golang/prometheus.gauge).SetToCurrentTime + + + + + +(github.com/RaaLabs/steward.process).publishMessages->(github.com/RaaLabs/steward.Subject).name + + + + + +(github.com/RaaLabs/steward.process).publishMessages->github.com/RaaLabs/steward.processNameGet + + + + + +(github.com/RaaLabs/steward.process).messageDeliverNats + +(process).messageDeliverNats + + + +(github.com/RaaLabs/steward.process).publishMessages->(github.com/RaaLabs/steward.process).messageDeliverNats + + + + + +(github.com/RaaLabs/steward.process).messageDeliverNats->github.com/RaaLabs/steward.sendErrorLogMessage + + + + + +(github.com/RaaLabs/steward.process).messageDeliverNats->(github.com/RaaLabs/steward.Subject).name + + + + + +github.com/RaaLabs/steward.gobEncodeMessage + +gobEncodeMessage + + + +(github.com/RaaLabs/steward.process).messageDeliverNats->github.com/RaaLabs/steward.gobEncodeMessage + + + + + +(*github.com/nats-io/nats.go.Conn).SubscribeSync + +(*Conn).SubscribeSync + + + +(github.com/RaaLabs/steward.process).messageDeliverNats->(*github.com/nats-io/nats.go.Conn).SubscribeSync + + + + + +(*github.com/nats-io/nats.go.Conn).PublishMsg + +(*Conn).PublishMsg + + + +(github.com/RaaLabs/steward.process).messageDeliverNats->(*github.com/nats-io/nats.go.Conn).PublishMsg + + + + + +(*github.com/nats-io/nats.go.Subscription).NextMsg + +(*Subscription).NextMsg + + + +(github.com/RaaLabs/steward.process).messageDeliverNats->(*github.com/nats-io/nats.go.Subscription).NextMsg + + + + + +(github.com/RaaLabs/steward.process).messageDeliverNats->(*github.com/prometheus/client_golang/prometheus.counter).Inc + + + + + +(github.com/RaaLabs/steward.process).spawnWorker$2->github.com/RaaLabs/steward.sendErrorLogMessage + + + + + +(github.com/RaaLabs/steward.process).spawnWorker$2->(github.com/RaaLabs/steward.startup).pubREQHello$1 + + + + + +(github.com/RaaLabs/steward.process).spawnWorker$2->(github.com/RaaLabs/steward.startup).subREQHello$1 + + + + + +(github.com/RaaLabs/steward.process).subscribeMessages->(github.com/RaaLabs/steward.Subject).name + + + + + +(*github.com/nats-io/nats.go.Conn).Subscribe + +(*Conn).Subscribe + + + +(github.com/RaaLabs/steward.process).subscribeMessages->(*github.com/nats-io/nats.go.Conn).Subscribe + + + + + +(github.com/RaaLabs/steward.methodREQOpCommand).handler$1$1->github.com/RaaLabs/steward.sendErrorLogMessage + + + + + +(github.com/RaaLabs/steward.methodREQOpCommand).handler->(github.com/RaaLabs/steward.methodREQOpCommand).handler$1 + + + + + + + +(github.com/RaaLabs/steward.methodREQPing).handler->github.com/RaaLabs/steward.sendErrorLogMessage + + + + + +(github.com/RaaLabs/steward.methodREQPing).handler->github.com/RaaLabs/steward.selectFileNaming + + + + + +(github.com/RaaLabs/steward.methodREQPing).handler$1 + +(methodREQPing).handler$1 + + + +(github.com/RaaLabs/steward.methodREQPing).handler->(github.com/RaaLabs/steward.methodREQPing).handler$1 + + + + + + + +(github.com/RaaLabs/steward.methodREQPing).handler$1->github.com/RaaLabs/steward.newReplyMessage + + + + + +(github.com/RaaLabs/steward.methodREQCliCommand).handler$1$1 + +(methodREQCliCommand).handler$1$1 + + + +(github.com/RaaLabs/steward.methodREQCliCommand).handler$1$1->github.com/RaaLabs/steward.sendErrorLogMessage + + + + + +(github.com/RaaLabs/steward.methodREQCliCommand).handler$1 + +(methodREQCliCommand).handler$1 + + + +(github.com/RaaLabs/steward.methodREQCliCommand).handler$1->github.com/RaaLabs/steward.sendErrorLogMessage + + + + + +(github.com/RaaLabs/steward.methodREQCliCommand).handler$1->github.com/RaaLabs/steward.newReplyMessage + + + + + +(github.com/RaaLabs/steward.methodREQCliCommand).handler$1->(github.com/RaaLabs/steward.methodREQCliCommand).handler$1$1 + + + + + + + +(github.com/RaaLabs/steward.methodREQCliCommand).handler->(github.com/RaaLabs/steward.methodREQCliCommand).handler$1 + + + + + + + +(github.com/RaaLabs/steward.methodREQHttpGet).handler$1 + +(methodREQHttpGet).handler$1 + + + +(github.com/RaaLabs/steward.methodREQHttpGet).handler$1->github.com/RaaLabs/steward.sendErrorLogMessage + + + + -(github.com/RaaLabs/steward.startup).subREQPing->github.com/RaaLabs/steward.newProcess - - +(github.com/RaaLabs/steward.methodREQHttpGet).handler$1->github.com/RaaLabs/steward.newReplyMessage + + - + + +(github.com/RaaLabs/steward.methodREQHttpGet).handler$1$1 + +(methodREQHttpGet).handler$1$1 + + + +(github.com/RaaLabs/steward.methodREQHttpGet).handler$1->(github.com/RaaLabs/steward.methodREQHttpGet).handler$1$1 + + + + + + + +(github.com/RaaLabs/steward.methodREQHttpGet).handler$1$1->github.com/RaaLabs/steward.sendErrorLogMessage + + + + -(github.com/RaaLabs/steward.startup).subREQPing->(github.com/RaaLabs/steward.process).spawnWorker - - - - +(github.com/RaaLabs/steward.methodREQHttpGet).handler->(github.com/RaaLabs/steward.methodREQHttpGet).handler$1 + + + + - - -(github.com/RaaLabs/steward.startup).subREQTextToLogFile->github.com/RaaLabs/steward.newSubject - - + + +(github.com/RaaLabs/steward.methodREQToFile).handler->github.com/RaaLabs/steward.sendErrorLogMessage + + - + + +(github.com/RaaLabs/steward.methodREQToFile).handler->github.com/RaaLabs/steward.selectFileNaming + + + + + +(github.com/RaaLabs/steward.methodREQToFileAppend).handler->github.com/RaaLabs/steward.sendErrorLogMessage + + + + + +(github.com/RaaLabs/steward.methodREQToFileAppend).handler->github.com/RaaLabs/steward.selectFileNaming + + + + + +(github.com/RaaLabs/steward.methodREQnCliCommandCont).handler$1$1 + +(methodREQnCliCommandCont).handler$1$1 + + + +(github.com/RaaLabs/steward.methodREQnCliCommandCont).handler$1$1->github.com/RaaLabs/steward.sendErrorLogMessage + + + + + +(github.com/RaaLabs/steward.methodREQnCliCommandCont).handler$1$1$1 + +(methodREQnCliCommandCont).handler$1$1$1 + + + +(github.com/RaaLabs/steward.methodREQnCliCommandCont).handler$1$1->(github.com/RaaLabs/steward.methodREQnCliCommandCont).handler$1$1$1 + + + + + + + +(github.com/RaaLabs/steward.methodREQnCliCommandCont).handler$1$1$1->github.com/RaaLabs/steward.sendErrorLogMessage + + + + + +(github.com/RaaLabs/steward.methodREQnCliCommandCont).handler$1 + +(methodREQnCliCommandCont).handler$1 + + + +(github.com/RaaLabs/steward.methodREQnCliCommandCont).handler$1->github.com/RaaLabs/steward.sendErrorLogMessage + + + + + +(github.com/RaaLabs/steward.methodREQnCliCommandCont).handler$1->github.com/RaaLabs/steward.newReplyMessage + + + + + +(github.com/RaaLabs/steward.methodREQnCliCommandCont).handler$1->(github.com/RaaLabs/steward.methodREQnCliCommandCont).handler$1$1 + + + + + + + +(github.com/RaaLabs/steward.methodREQnCliCommandCont).handler->(github.com/RaaLabs/steward.methodREQnCliCommandCont).handler$1 + + + + + + + +(github.com/RaaLabs/steward.methodREQnCliCommand).handler$1$1 + +(methodREQnCliCommand).handler$1$1 + + -(github.com/RaaLabs/steward.startup).subREQTextToLogFile->github.com/RaaLabs/steward.newProcess - - +(github.com/RaaLabs/steward.methodREQnCliCommand).handler$1$1->github.com/RaaLabs/steward.sendErrorLogMessage + + - - -(github.com/RaaLabs/steward.startup).subREQTextToLogFile->(github.com/RaaLabs/steward.process).spawnWorker - - - - + + +(github.com/RaaLabs/steward.methodREQnCliCommand).handler$1 + +(methodREQnCliCommand).handler$1 - + + +(github.com/RaaLabs/steward.methodREQnCliCommand).handler$1->github.com/RaaLabs/steward.sendErrorLogMessage + + + + -(github.com/RaaLabs/steward.startup).subREQTextToFile->github.com/RaaLabs/steward.newSubject - - +(github.com/RaaLabs/steward.methodREQnCliCommand).handler$1->github.com/RaaLabs/steward.newReplyMessage + + - + + +(github.com/RaaLabs/steward.methodREQnCliCommand).handler$1->(github.com/RaaLabs/steward.methodREQnCliCommand).handler$1$1 + + + + + + -(github.com/RaaLabs/steward.startup).subREQTextToFile->github.com/RaaLabs/steward.newProcess - - +(github.com/RaaLabs/steward.methodREQnCliCommand).handler->(github.com/RaaLabs/steward.methodREQnCliCommand).handler$1 + + + + - - -(github.com/RaaLabs/steward.startup).subREQTextToFile->(github.com/RaaLabs/steward.process).spawnWorker - - - - + + +(github.com/RaaLabs/steward.methodREQTailFile).handler$1 + +(methodREQTailFile).handler$1 + + + +(github.com/RaaLabs/steward.methodREQTailFile).handler$1->github.com/RaaLabs/steward.sendErrorLogMessage + + + + + +(github.com/RaaLabs/steward.methodREQTailFile).handler$1->github.com/RaaLabs/steward.newReplyMessage + + + + + +(github.com/RaaLabs/steward.methodREQTailFile).handler$1$1 + +(methodREQTailFile).handler$1$1 + + + +(github.com/RaaLabs/steward.methodREQTailFile).handler$1->(github.com/RaaLabs/steward.methodREQTailFile).handler$1$1 + + + + + + + +github.com/hpcloud/tail.TailFile + +TailFile + + + +(github.com/RaaLabs/steward.methodREQTailFile).handler$1->github.com/hpcloud/tail.TailFile + + + + + +(github.com/RaaLabs/steward.methodREQTailFile).handler->(github.com/RaaLabs/steward.methodREQTailFile).handler$1 + + + + + + + +(github.com/RaaLabs/steward.methodREQPong).handler->github.com/RaaLabs/steward.sendErrorLogMessage + + + + + +(github.com/RaaLabs/steward.methodREQPong).handler->github.com/RaaLabs/steward.selectFileNaming + + + + + +(github.com/RaaLabs/steward.process).subscribeMessages$1 + +(process).subscribeMessages$1 + + + +(github.com/RaaLabs/steward.process).subscribeMessages$1->(github.com/RaaLabs/steward.process).subscriberHandler + + + + + + + +(*github.com/RaaLabs/steward.server).readSocket$1 + +(*server).readSocket$1 + + + +(*github.com/RaaLabs/steward.server).readSocket$1->github.com/RaaLabs/steward.sendErrorLogMessage + + + + + +(*github.com/RaaLabs/steward.server).readSocket$1->(*github.com/RaaLabs/steward.server).convertBytesToSAMs + + + + + +(*github.com/RaaLabs/steward.server).Start + +(*server).Start + + + +(*github.com/RaaLabs/steward.server).Start->github.com/RaaLabs/steward.newSubject + + + + + +(*github.com/RaaLabs/steward.server).Start->(*github.com/RaaLabs/steward.server).Start$2 + + + + + + + +(*github.com/RaaLabs/steward.server).Start->github.com/RaaLabs/steward.newProcess + + + + + +github.com/RaaLabs/steward.newErrorKernel + +newErrorKernel + + + +(*github.com/RaaLabs/steward.server).Start->github.com/RaaLabs/steward.newErrorKernel + + + + + +(*github.com/RaaLabs/steward.server).Start$1 + +(*server).Start$1 + + + +(*github.com/RaaLabs/steward.server).Start->(*github.com/RaaLabs/steward.server).Start$1 + + + + + + + +(*github.com/RaaLabs/steward.server).readSocket + +(*server).readSocket + + + +(*github.com/RaaLabs/steward.server).Start->(*github.com/RaaLabs/steward.server).readSocket + + + + + + + +(*github.com/RaaLabs/steward.server).readTCPListener + +(*server).readTCPListener + + + +(*github.com/RaaLabs/steward.server).Start->(*github.com/RaaLabs/steward.server).readTCPListener + + + + + + + +(*github.com/RaaLabs/steward.server).readHttpListener + +(*server).readHttpListener + + + +(*github.com/RaaLabs/steward.server).Start->(*github.com/RaaLabs/steward.server).readHttpListener + + + + + + + +(*github.com/RaaLabs/steward.processes).Start + +(*processes).Start + + + +(*github.com/RaaLabs/steward.server).Start->(*github.com/RaaLabs/steward.processes).Start + + + + + +(*github.com/RaaLabs/steward.processes).printProcessesMap + +(*processes).printProcessesMap + + + +(*github.com/RaaLabs/steward.server).Start->(*github.com/RaaLabs/steward.processes).printProcessesMap + + + + + +(*github.com/RaaLabs/steward.server).exposeDataFolder + +(*server).exposeDataFolder + + + +(*github.com/RaaLabs/steward.server).Start->(*github.com/RaaLabs/steward.server).exposeDataFolder + + + + + + + +(*github.com/RaaLabs/steward.server).routeMessagesToProcess + +(*server).routeMessagesToProcess + + + +(*github.com/RaaLabs/steward.server).Start->(*github.com/RaaLabs/steward.server).routeMessagesToProcess + + + + + +(*github.com/RaaLabs/steward.errorKernel).start + +(*errorKernel).start + + + +(*github.com/RaaLabs/steward.errorKernel).start$1 + +(*errorKernel).start$1 + + + +(*github.com/RaaLabs/steward.errorKernel).start->(*github.com/RaaLabs/steward.errorKernel).start$1 + + + + + + + +(*github.com/RaaLabs/steward.server).Start$1->(*github.com/RaaLabs/steward.errorKernel).start + + + + + +(*github.com/RaaLabs/steward.server).readSocket->github.com/RaaLabs/steward.sendErrorLogMessage + + + + + +(*github.com/RaaLabs/steward.server).readSocket->(*github.com/RaaLabs/steward.server).readSocket$1 + + + + + + + +(*github.com/RaaLabs/steward.server).readTCPListener->github.com/RaaLabs/steward.sendErrorLogMessage + + + + + +(*github.com/RaaLabs/steward.server).readTCPListener$1 + +(*server).readTCPListener$1 + + + +(*github.com/RaaLabs/steward.server).readTCPListener->(*github.com/RaaLabs/steward.server).readTCPListener$1 + + + + + + + +(*github.com/RaaLabs/steward.server).readTCPListener$1->github.com/RaaLabs/steward.sendErrorLogMessage + + + + + +(*github.com/RaaLabs/steward.server).readTCPListener$1->(*github.com/RaaLabs/steward.server).convertBytesToSAMs + + + + + +(*github.com/RaaLabs/steward.server).readHttpListener$1 + +(*server).readHttpListener$1 + + + +(*github.com/RaaLabs/steward.server).readHttpListener->(*github.com/RaaLabs/steward.server).readHttpListener$1 + + + + + + + +(*github.com/RaaLabs/steward.processes).Start->github.com/RaaLabs/steward.newSubject + + + + + +(*github.com/RaaLabs/steward.processes).Start->github.com/RaaLabs/steward.newProcess + + + + + +(*github.com/RaaLabs/steward.processes).Start->(github.com/RaaLabs/steward.process).spawnWorker + + + + + + + +(github.com/RaaLabs/steward.startup).subREQToFileAppend + +(startup).subREQToFileAppend + + + +(*github.com/RaaLabs/steward.processes).Start->(github.com/RaaLabs/steward.startup).subREQToFileAppend + + + + + +(github.com/RaaLabs/steward.startup).subREQToFile + +(startup).subREQToFile + + + +(*github.com/RaaLabs/steward.processes).Start->(github.com/RaaLabs/steward.startup).subREQToFile + + + + + +(github.com/RaaLabs/steward.startup).subREQHello + +(startup).subREQHello + + + +(*github.com/RaaLabs/steward.processes).Start->(github.com/RaaLabs/steward.startup).subREQHello + + + + + +(github.com/RaaLabs/steward.startup).subREQErrorLog + +(startup).subREQErrorLog + + + +(*github.com/RaaLabs/steward.processes).Start->(github.com/RaaLabs/steward.startup).subREQErrorLog + + + + + +(github.com/RaaLabs/steward.startup).subREQPing + +(startup).subREQPing + + + +(*github.com/RaaLabs/steward.processes).Start->(github.com/RaaLabs/steward.startup).subREQPing + + + + + +(github.com/RaaLabs/steward.startup).subREQPong + +(startup).subREQPong + + + +(*github.com/RaaLabs/steward.processes).Start->(github.com/RaaLabs/steward.startup).subREQPong + + + + + +(github.com/RaaLabs/steward.startup).subREQCliCommand + +(startup).subREQCliCommand + + + +(*github.com/RaaLabs/steward.processes).Start->(github.com/RaaLabs/steward.startup).subREQCliCommand + + + + + +(github.com/RaaLabs/steward.startup).subREQnCliCommand + +(startup).subREQnCliCommand + + + +(*github.com/RaaLabs/steward.processes).Start->(github.com/RaaLabs/steward.startup).subREQnCliCommand + + + + + +(github.com/RaaLabs/steward.startup).subREQToConsole + +(startup).subREQToConsole + + + +(*github.com/RaaLabs/steward.processes).Start->(github.com/RaaLabs/steward.startup).subREQToConsole + + + + + +(github.com/RaaLabs/steward.startup).pubREQHello + +(startup).pubREQHello + + + +(*github.com/RaaLabs/steward.processes).Start->(github.com/RaaLabs/steward.startup).pubREQHello + + + + + +(github.com/RaaLabs/steward.startup).subREQHttpGet + +(startup).subREQHttpGet + + + +(*github.com/RaaLabs/steward.processes).Start->(github.com/RaaLabs/steward.startup).subREQHttpGet + + + + + +(github.com/RaaLabs/steward.startup).subREQTailFile + +(startup).subREQTailFile + + + +(*github.com/RaaLabs/steward.processes).Start->(github.com/RaaLabs/steward.startup).subREQTailFile + + + + + +(github.com/RaaLabs/steward.startup).subREQnCliCommandCont + +(startup).subREQnCliCommandCont + + + +(*github.com/RaaLabs/steward.processes).Start->(github.com/RaaLabs/steward.startup).subREQnCliCommandCont + + + + + +(github.com/RaaLabs/steward.startup).subREQToSocket + +(startup).subREQToSocket + + + +(*github.com/RaaLabs/steward.processes).Start->(github.com/RaaLabs/steward.startup).subREQToSocket + + + + + +(github.com/RaaLabs/steward.startup).subREQToFileAppend->github.com/RaaLabs/steward.newSubject + + + + + +(github.com/RaaLabs/steward.startup).subREQToFileAppend->github.com/RaaLabs/steward.newProcess + + + + + +(github.com/RaaLabs/steward.startup).subREQToFileAppend->(github.com/RaaLabs/steward.process).spawnWorker + + + + + + + +(github.com/RaaLabs/steward.startup).subREQToFile->github.com/RaaLabs/steward.newSubject + + + + + +(github.com/RaaLabs/steward.startup).subREQToFile->github.com/RaaLabs/steward.newProcess + + + + + +(github.com/RaaLabs/steward.startup).subREQToFile->(github.com/RaaLabs/steward.process).spawnWorker + + + + - + (github.com/RaaLabs/steward.startup).subREQHello->github.com/RaaLabs/steward.newSubject - - + + - + (github.com/RaaLabs/steward.startup).subREQHello->github.com/RaaLabs/steward.newProcess - - + + - + (github.com/RaaLabs/steward.startup).subREQHello->(github.com/RaaLabs/steward.process).spawnWorker - - - - + + + + - + (github.com/RaaLabs/steward.startup).subREQErrorLog->github.com/RaaLabs/steward.newSubject - - + + - + (github.com/RaaLabs/steward.startup).subREQErrorLog->github.com/RaaLabs/steward.newProcess - - + + - + (github.com/RaaLabs/steward.startup).subREQErrorLog->(github.com/RaaLabs/steward.process).spawnWorker - - - - + + + + + + + +(github.com/RaaLabs/steward.startup).subREQPing->github.com/RaaLabs/steward.newSubject + + + + + +(github.com/RaaLabs/steward.startup).subREQPing->github.com/RaaLabs/steward.newProcess + + + + + +(github.com/RaaLabs/steward.startup).subREQPing->(github.com/RaaLabs/steward.process).spawnWorker + + + + - + (github.com/RaaLabs/steward.startup).subREQPong->github.com/RaaLabs/steward.newSubject - - + + - + (github.com/RaaLabs/steward.startup).subREQPong->github.com/RaaLabs/steward.newProcess - - + + - + (github.com/RaaLabs/steward.startup).subREQPong->(github.com/RaaLabs/steward.process).spawnWorker - - - - + + + + - + (github.com/RaaLabs/steward.startup).subREQCliCommand->github.com/RaaLabs/steward.newSubject - - + + - + (github.com/RaaLabs/steward.startup).subREQCliCommand->github.com/RaaLabs/steward.newProcess - - + + - + (github.com/RaaLabs/steward.startup).subREQCliCommand->(github.com/RaaLabs/steward.process).spawnWorker - - - - + + + + - + (github.com/RaaLabs/steward.startup).subREQnCliCommand->github.com/RaaLabs/steward.newSubject - - + + - + (github.com/RaaLabs/steward.startup).subREQnCliCommand->github.com/RaaLabs/steward.newProcess - - + + - + (github.com/RaaLabs/steward.startup).subREQnCliCommand->(github.com/RaaLabs/steward.process).spawnWorker - - - - + + + + - - -(github.com/RaaLabs/steward.startup).subREQTextToConsole->github.com/RaaLabs/steward.newSubject - - + + +(github.com/RaaLabs/steward.startup).subREQToConsole->github.com/RaaLabs/steward.newSubject + + - - -(github.com/RaaLabs/steward.startup).subREQTextToConsole->github.com/RaaLabs/steward.newProcess - - + + +(github.com/RaaLabs/steward.startup).subREQToConsole->github.com/RaaLabs/steward.newProcess + + - - -(github.com/RaaLabs/steward.startup).subREQTextToConsole->(github.com/RaaLabs/steward.process).spawnWorker - - - - + + +(github.com/RaaLabs/steward.startup).subREQToConsole->(github.com/RaaLabs/steward.process).spawnWorker + + + + - + (github.com/RaaLabs/steward.startup).pubREQHello->github.com/RaaLabs/steward.newSubject - - + + - + (github.com/RaaLabs/steward.startup).pubREQHello->github.com/RaaLabs/steward.newProcess - - + + - + (github.com/RaaLabs/steward.startup).pubREQHello->(github.com/RaaLabs/steward.process).spawnWorker - - - - + + + + - + (github.com/RaaLabs/steward.startup).subREQHttpGet->github.com/RaaLabs/steward.newSubject - - + + - + (github.com/RaaLabs/steward.startup).subREQHttpGet->github.com/RaaLabs/steward.newProcess - - + + - + (github.com/RaaLabs/steward.startup).subREQHttpGet->(github.com/RaaLabs/steward.process).spawnWorker - - - - + + + + + + + +(github.com/RaaLabs/steward.startup).subREQTailFile->github.com/RaaLabs/steward.newSubject + + + + + +(github.com/RaaLabs/steward.startup).subREQTailFile->github.com/RaaLabs/steward.newProcess + + + + + +(github.com/RaaLabs/steward.startup).subREQTailFile->(github.com/RaaLabs/steward.process).spawnWorker + + + + + + + +(github.com/RaaLabs/steward.startup).subREQnCliCommandCont->github.com/RaaLabs/steward.newSubject + + + + + +(github.com/RaaLabs/steward.startup).subREQnCliCommandCont->github.com/RaaLabs/steward.newProcess + + + + + +(github.com/RaaLabs/steward.startup).subREQnCliCommandCont->(github.com/RaaLabs/steward.process).spawnWorker + + + + + + + +(github.com/RaaLabs/steward.startup).subREQToSocket->github.com/RaaLabs/steward.newSubject + + + + + +(github.com/RaaLabs/steward.startup).subREQToSocket->github.com/RaaLabs/steward.newProcess + + + + + +(github.com/RaaLabs/steward.startup).subREQToSocket->(github.com/RaaLabs/steward.process).spawnWorker + + + + + + + +(*github.com/RaaLabs/steward.processes).printProcessesMap->(github.com/RaaLabs/steward.Subject).name + + + + + +(*github.com/RaaLabs/steward.processes).printProcessesMap->(*github.com/prometheus/client_golang/prometheus.gauge).Set + + + + + +github.com/RaaLabs/steward.newringBuffer + +newringBuffer + + + +go.etcd.io/bbolt.Open + +Open + + + +github.com/RaaLabs/steward.newringBuffer->go.etcd.io/bbolt.Open + + + + + +(*github.com/RaaLabs/steward.server).routeMessagesToProcess->(github.com/RaaLabs/steward.Method).GetMethodsAvailable + + + + + +(*github.com/RaaLabs/steward.server).routeMessagesToProcess->github.com/RaaLabs/steward.newringBuffer + + + + + +(*github.com/RaaLabs/steward.ringBuffer).start + +(*ringBuffer).start + + + +(*github.com/RaaLabs/steward.server).routeMessagesToProcess->(*github.com/RaaLabs/steward.ringBuffer).start + + + + + +(github.com/RaaLabs/steward.CommandOrEvent).GetCommandOrEventAvailable + +(CommandOrEvent).GetCommandOrEventAvailable + + + +(*github.com/RaaLabs/steward.server).routeMessagesToProcess->(github.com/RaaLabs/steward.CommandOrEvent).GetCommandOrEventAvailable + + + + + +(*github.com/RaaLabs/steward.server).routeMessagesToProcess$1 + +(*server).routeMessagesToProcess$1 + + + +(*github.com/RaaLabs/steward.server).routeMessagesToProcess->(*github.com/RaaLabs/steward.server).routeMessagesToProcess$1 + + + + + + + +(*github.com/RaaLabs/steward.server).routeMessagesToProcess$2 + +(*server).routeMessagesToProcess$2 + + + +(*github.com/RaaLabs/steward.server).routeMessagesToProcess->(*github.com/RaaLabs/steward.server).routeMessagesToProcess$2 + + + + + + + +(*github.com/RaaLabs/steward.ringBuffer).start->(*github.com/RaaLabs/steward.ringBuffer).getIndexValue + + + + + +(*github.com/RaaLabs/steward.ringBuffer).fillBuffer + +(*ringBuffer).fillBuffer + + + +(*github.com/RaaLabs/steward.ringBuffer).start->(*github.com/RaaLabs/steward.ringBuffer).fillBuffer + + + + + + + +(*github.com/RaaLabs/steward.ringBuffer).startPermanentStore + +(*ringBuffer).startPermanentStore + + + +(*github.com/RaaLabs/steward.ringBuffer).start->(*github.com/RaaLabs/steward.ringBuffer).startPermanentStore + + + + + + + +(*github.com/RaaLabs/steward.ringBuffer).processBufferMessages + +(*ringBuffer).processBufferMessages + + + +(*github.com/RaaLabs/steward.ringBuffer).start->(*github.com/RaaLabs/steward.ringBuffer).processBufferMessages + + + + + + + +(*github.com/RaaLabs/steward.ringBuffer).dumpBucket + +(*ringBuffer).dumpBucket + + + +(*github.com/RaaLabs/steward.ringBuffer).dumpBucket->(*go.etcd.io/bbolt.DB).View + + + + + +(*github.com/RaaLabs/steward.ringBuffer).fillBuffer$1 + +(*ringBuffer).fillBuffer$1 + + + +(*github.com/RaaLabs/steward.ringBuffer).fillBuffer$1->(*github.com/RaaLabs/steward.ringBuffer).dumpBucket + + + + + +(*github.com/RaaLabs/steward.ringBuffer).fillBuffer->github.com/RaaLabs/steward.sendErrorLogMessage + + + + + +(*github.com/RaaLabs/steward.ringBuffer).fillBuffer->(*github.com/RaaLabs/steward.ringBuffer).fillBuffer$1 + + + + + +(*github.com/RaaLabs/steward.ringBuffer).fillBuffer->(github.com/RaaLabs/steward.CommandOrEvent).GetCommandOrEventAvailable + + + + + +(github.com/RaaLabs/steward.CommandOrEventAvailable).CheckIfExists + +(CommandOrEventAvailable).CheckIfExists + + + +(*github.com/RaaLabs/steward.ringBuffer).fillBuffer->(github.com/RaaLabs/steward.CommandOrEventAvailable).CheckIfExists + + + + + +(*github.com/RaaLabs/steward.ringBuffer).dbUpdate + +(*ringBuffer).dbUpdate + + + +(*github.com/RaaLabs/steward.ringBuffer).fillBuffer->(*github.com/RaaLabs/steward.ringBuffer).dbUpdate + + + + + +(*go.etcd.io/bbolt.DB).Update + +(*DB).Update + + + +(*github.com/RaaLabs/steward.ringBuffer).dbUpdate->(*go.etcd.io/bbolt.DB).Update + + + + + +(*github.com/RaaLabs/steward.ringBuffer).deleteKeyFromBucket + +(*ringBuffer).deleteKeyFromBucket + + + +(*github.com/RaaLabs/steward.ringBuffer).deleteKeyFromBucket->(*go.etcd.io/bbolt.DB).Update + + + + + +(*github.com/RaaLabs/steward.ringBuffer).processBufferMessages$1 + +(*ringBuffer).processBufferMessages$1 + + + +(*github.com/RaaLabs/steward.ringBuffer).processBufferMessages$1->(*github.com/RaaLabs/steward.ringBuffer).deleteKeyFromBucket + + + + + +(*github.com/RaaLabs/steward.ringBuffer).processBufferMessages$1->(*github.com/prometheus/client_golang/prometheus.counter).Inc + + + + + +(*github.com/RaaLabs/steward.ringBuffer).processBufferMessages$1->(*github.com/prometheus/client_golang/prometheus.gauge).Set + + + + + +(*github.com/RaaLabs/steward.ringBuffer).processBufferMessages->(*github.com/RaaLabs/steward.ringBuffer).processBufferMessages$1 + + + + + + + +(*github.com/RaaLabs/steward.ringBuffer).processBufferMessages->(*github.com/prometheus/client_golang/prometheus.gauge).Set + + + + + +(*github.com/RaaLabs/steward.server).routeMessagesToProcess$2->github.com/RaaLabs/steward.newSubject + + + + + +(*github.com/RaaLabs/steward.server).routeMessagesToProcess$2->github.com/RaaLabs/steward.sendErrorLogMessage + + + + + +(*github.com/RaaLabs/steward.server).routeMessagesToProcess$2->(github.com/RaaLabs/steward.MethodsAvailable).CheckIfExists + + + + + +(*github.com/RaaLabs/steward.server).routeMessagesToProcess$2->(github.com/RaaLabs/steward.Subject).name + + + + + +(*github.com/RaaLabs/steward.server).routeMessagesToProcess$2->github.com/RaaLabs/steward.newProcess + + + + + +(*github.com/RaaLabs/steward.server).routeMessagesToProcess$2->(github.com/RaaLabs/steward.process).spawnWorker + + + + + +(*github.com/RaaLabs/steward.server).routeMessagesToProcess$2->github.com/RaaLabs/steward.processNameGet + + + + + +(*github.com/RaaLabs/steward.server).routeMessagesToProcess$2->(github.com/RaaLabs/steward.CommandOrEventAvailable).CheckIfExists + + + + + +(*github.com/RaaLabs/steward.ringBuffer).processBufferMessages$1$1 + +(*ringBuffer).processBufferMessages$1$1 + + + +(*github.com/RaaLabs/steward.server).routeMessagesToProcess$2->(*github.com/RaaLabs/steward.ringBuffer).processBufferMessages$1$1 + + + + + +github.com/RaaLabs/steward.newMetrics + +newMetrics + + + +github.com/prometheus/client_golang/prometheus.NewRegistry + +NewRegistry + + + +github.com/RaaLabs/steward.newMetrics->github.com/prometheus/client_golang/prometheus.NewRegistry + + + + + +(*github.com/prometheus/client_golang/prometheus.Registry).MustRegister + +(*Registry).MustRegister + + + +github.com/RaaLabs/steward.newMetrics->(*github.com/prometheus/client_golang/prometheus.Registry).MustRegister + + + + + +github.com/prometheus/client_golang/prometheus.NewGauge + +NewGauge + + + +github.com/RaaLabs/steward.newMetrics->github.com/prometheus/client_golang/prometheus.NewGauge + + + + + +github.com/prometheus/client_golang/prometheus.NewGaugeVec + +NewGaugeVec + + + +github.com/RaaLabs/steward.newMetrics->github.com/prometheus/client_golang/prometheus.NewGaugeVec + + + + + +github.com/prometheus/client_golang/prometheus.NewCounter + +NewCounter + + + +github.com/RaaLabs/steward.newMetrics->github.com/prometheus/client_golang/prometheus.NewCounter + + + + + +github.com/prometheus/client_golang/prometheus/collectors.NewGoCollector + +NewGoCollector + + + +github.com/RaaLabs/steward.newMetrics->github.com/prometheus/client_golang/prometheus/collectors.NewGoCollector + + + + + +github.com/RaaLabs/steward.NewConfiguration + +NewConfiguration + + + +(*github.com/RaaLabs/steward.Configuration).ReadConfigFile + +(*Configuration).ReadConfigFile + + + +github.com/RaaLabs/steward.checkConfigValues + +checkConfigValues + + + +(*github.com/RaaLabs/steward.Configuration).ReadConfigFile->github.com/RaaLabs/steward.checkConfigValues + + + + + +github.com/pelletier/go-toml.NewDecoder + +NewDecoder + + + +(*github.com/RaaLabs/steward.Configuration).ReadConfigFile->github.com/pelletier/go-toml.NewDecoder + + + + + +(*github.com/pelletier/go-toml.Decoder).Decode + +(*Decoder).Decode + + + +(*github.com/RaaLabs/steward.Configuration).ReadConfigFile->(*github.com/pelletier/go-toml.Decoder).Decode + + + + + +github.com/RaaLabs/steward.newConfigurationDefaults + +newConfigurationDefaults + + + +github.com/RaaLabs/steward.checkConfigValues->github.com/RaaLabs/steward.newConfigurationDefaults + + + + + +(*github.com/RaaLabs/steward.Configuration).CheckFlags + +(*Configuration).CheckFlags + + + +(*github.com/RaaLabs/steward.Configuration).CheckFlags->(*github.com/RaaLabs/steward.Configuration).ReadConfigFile + + + + + +(*github.com/RaaLabs/steward.Configuration).CheckFlags->github.com/RaaLabs/steward.newConfigurationDefaults + + + + + +(*github.com/RaaLabs/steward.Configuration).WriteConfigFile + +(*Configuration).WriteConfigFile + + + +(*github.com/RaaLabs/steward.Configuration).CheckFlags->(*github.com/RaaLabs/steward.Configuration).WriteConfigFile + + + + + +github.com/pelletier/go-toml.NewEncoder + +NewEncoder + + + +(*github.com/RaaLabs/steward.Configuration).WriteConfigFile->github.com/pelletier/go-toml.NewEncoder + + + + + +(*github.com/pelletier/go-toml.Encoder).Encode + +(*Encoder).Encode + + + +(*github.com/RaaLabs/steward.Configuration).WriteConfigFile->(*github.com/pelletier/go-toml.Encoder).Encode + + + + + +github.com/RaaLabs/steward.NewServer + +NewServer + + + +github.com/RaaLabs/steward.NewServer->github.com/RaaLabs/steward.newMetrics + + + + + +github.com/RaaLabs/steward.newProcesses + +newProcesses + + + +github.com/RaaLabs/steward.NewServer->github.com/RaaLabs/steward.newProcesses + + + + + +github.com/nats-io/nats.go.RootCAs + +RootCAs + + + +github.com/RaaLabs/steward.NewServer->github.com/nats-io/nats.go.RootCAs + + + + + +github.com/nats-io/nats.go.NkeyOptionFromSeed + +NkeyOptionFromSeed + + + +github.com/RaaLabs/steward.NewServer->github.com/nats-io/nats.go.NkeyOptionFromSeed + + + + + +github.com/nats-io/nats.go.MaxReconnects + +MaxReconnects + + + +github.com/RaaLabs/steward.NewServer->github.com/nats-io/nats.go.MaxReconnects + + + + + +github.com/nats-io/nats.go.Connect + +Connect + + + +github.com/RaaLabs/steward.NewServer->github.com/nats-io/nats.go.Connect + + + + + +(*github.com/RaaLabs/steward.server).Stop + +(*server).Stop + + + +(*github.com/RaaLabs/steward.processes).Stop + +(*processes).Stop + + + +(*github.com/RaaLabs/steward.server).Stop->(*github.com/RaaLabs/steward.processes).Stop + + + + + +(*github.com/RaaLabs/steward.errorKernel).stop + +(*errorKernel).stop + + + +(*github.com/RaaLabs/steward.server).Stop->(*github.com/RaaLabs/steward.errorKernel).stop + + + + + +command-line-arguments.main + +main + + + +command-line-arguments.main->(*github.com/RaaLabs/steward.server).Start + + + + + + + +command-line-arguments.main->github.com/RaaLabs/steward.NewConfiguration + + + + + +command-line-arguments.main->(*github.com/RaaLabs/steward.Configuration).CheckFlags + + + + + +command-line-arguments.main->github.com/RaaLabs/steward.NewServer + + + + + +command-line-arguments.main->(*github.com/RaaLabs/steward.server).Stop + + - + (*github.com/nats-io/nats.go.Conn).waitForMsgs - -waitForMsgs + +(*Conn).waitForMsgs - + (*github.com/nats-io/nats.go.Conn).waitForMsgs->(github.com/RaaLabs/steward.process).subscribeMessages$1 - - + + (*go.etcd.io/bbolt.Bucket).ForEach->(*github.com/RaaLabs/steward.ringBuffer).dumpBucket$1$1 - - - - - -(*go.etcd.io/bbolt.Bucket).ForEach->(*github.com/RaaLabs/steward.ringBuffer).printBucketContent$1$1 - - + + - + (*go.etcd.io/bbolt.DB).Update->(*github.com/RaaLabs/steward.ringBuffer).dbUpdate$1 - - + + - + (*go.etcd.io/bbolt.DB).Update->(*github.com/RaaLabs/steward.ringBuffer).deleteKeyFromBucket$1 - - - - - -(*go.etcd.io/bbolt.DB).View->(*github.com/RaaLabs/steward.ringBuffer).printBucketContent$1 - - + + - + (*go.etcd.io/bbolt.DB).View->(*github.com/RaaLabs/steward.ringBuffer).dbView$1 - - + + - + (*go.etcd.io/bbolt.DB).View->(*github.com/RaaLabs/steward.ringBuffer).dumpBucket$1 - - + + diff --git a/steward_test.go b/steward_test.go index ff41d97..488f108 100644 --- a/steward_test.go +++ b/steward_test.go @@ -145,7 +145,7 @@ func checkREQOpCommandTest(stewardServer *server, conf *Configuration, t *testin return fmt.Errorf(" [FAILED] : checkREQOpCommandTest: %v", err) } - t.Logf(" [SUCCESS] : checkREQOpCommandTest\n") + t.Logf(" \U0001f600 [SUCCESS] : checkREQOpCommandTest\n") return nil } @@ -173,7 +173,7 @@ func checkREQCliCommandTest(stewardServer *server, conf *Configuration, t *testi return fmt.Errorf(" [FAILED] : checkREQCliCommandTest: %v", err) } - t.Logf(" [SUCCESS] : checkREQCliCommandTest\n") + t.Logf(" \U0001f600 [SUCCESS] : checkREQCliCommandTest\n") return nil } @@ -201,7 +201,7 @@ func checkREQnCliCommandTest(stewardServer *server, conf *Configuration, t *test return fmt.Errorf(" [FAILED] : checkREQnCliCommandTest: %v", err) } - t.Logf(" [SUCCESS] : checkREQnCliCommandTest\n") + t.Logf(" \U0001f600 [SUCCESS] : checkREQnCliCommandTest\n") return nil } @@ -229,7 +229,7 @@ func checkREQnCliCommandContTest(stewardServer *server, conf *Configuration, t * return fmt.Errorf(" [FAILED] : checkREQnCliCommandContTest: %v", err) } - t.Logf(" [SUCCESS] : checkREQnCliCommandContTest\n") + t.Logf(" \U0001f600 [SUCCESS] : checkREQnCliCommandContTest\n") return nil } @@ -253,7 +253,7 @@ func checkREQHelloTest(stewardServer *server, conf *Configuration, t *testing.T) return fmt.Errorf(" [FAILED] : checkREQHelloTest: %v", err) } - t.Logf(" [SUCCESS] : checkREQHelloTest\n") + t.Logf(" \U0001f600 [SUCCESS] : checkREQHelloTest\n") return nil } @@ -277,7 +277,7 @@ func checkREQErrorLogTest(stewardServer *server, conf *Configuration, t *testing return fmt.Errorf(" [FAILED] : checkREQErrorLogTest: %v", err) } - t.Logf(" [SUCCESS] : checkREQErrorLogTest\n") + t.Logf(" \U0001f600 [SUCCESS] : checkREQErrorLogTest\n") return nil } @@ -316,7 +316,7 @@ func checkREQHttpGetTest(stewardServer *server, conf *Configuration, t *testing. return fmt.Errorf(" [FAILED] : checkREQHttpGetTest: %v", err) } - t.Logf(" [SUCCESS] : checkREQHttpGetTest\n") + t.Logf(" \U0001f600 [SUCCESS] : checkREQHttpGetTest\n") return nil } @@ -402,7 +402,7 @@ func checkREQTailFileTest(stewardServer *server, conf *Configuration, t *testing return fmt.Errorf(" [FAILED] : checkREQTailFileTest: %v", err) } - t.Logf(" [SUCCESS] : checkREQTailFileTest\n") + t.Logf(" \U0001f600 [SUCCESS] : checkREQTailFileTest\n") return nil } @@ -464,7 +464,7 @@ func checkErrorKernelMalformedJSONtest(stewardServer *server, conf *Configuratio } if found { - t.Logf(" [SUCCESS] : checkErrorKernelMalformedJSONtest") + t.Logf(" \U0001f600 [SUCCESS] : checkErrorKernelMalformedJSONtest") return nil } case <-ticker.C: @@ -500,7 +500,7 @@ func checkMetricValuesTest(stewardServer *server, conf *Configuration, t *testin return fmt.Errorf("error: promRegistry.gathering: did not find specified metric processes_total") } - t.Logf(" [SUCCESS] : checkMetricValuesTest") + t.Logf(" \U0001f600 [SUCCESS] : checkMetricValuesTest") return nil }