diff --git a/README.md b/README.md index 4532496..acf0396 100644 --- a/README.md +++ b/README.md @@ -88,11 +88,17 @@ If one process hangs on a long running message method it will not affect the res - All handling down to the process and message level are handled concurrently. So if there are problems handling one message sent to a node on a subject it will not affect the messages being sent to other nodes, or other messages sent on other subjects to the same host. -- Default timeouts to wait for ACK messages and max attempts to retry sending a message specified upon startup. This can be overridden on the message level. - - Message types of both ACK and NACK, so we can decide if we want or don't want an Acknowledge if a message was delivered succesfully. Example: We probably want an ACK when sending some CLICommand to be executed, but we don't care for an acknowledge (NACK) when we send an "hello I'm here" event. +### Timeouts and retries + +- Default timeouts to wait for ACK messages and max attempts to retry sending a message are specified upon startup. This can be overridden on the message level. + +- Timeout's can be specified on both the message, and the method. With other words a message can have a timeout, and for example if the method it will trigger is a shell command it can have it's own timeout so processes can have a timeout if they get stuck. + +- Setting the retries to `0` is the same as unlimited retries. + ### Flags and configuration file Steward supports both the use of flags/arguments set at startup, and the use of a config file. But how it is used might be a little different than how similar use is normally done. @@ -369,10 +375,6 @@ and for a shell command of type command to a host named "ship2" ## TODO -- FIX so it can handle multiple slices of input for msg.pipe - -- Make a scraper that first send an EventACK, and the content of the scraping is returned by a node as a new EventACK back the where the initial event originated. - - Implement a log scraper method in `tail -f` style ? - Implement a web scraper method ? @@ -381,8 +383,6 @@ and for a shell command of type command to a host named "ship2" - Authentication between node instances and brokers. -- Implement context to be able to stop processes, and message handlers. - ## Disclaimer All code in this repository are to be concidered not-production-ready. The code are the attempt to concretize the idea of a purely async management system where the controlling unit is decoupled from the receiving unit, and that that we know the state of all the receiving units at all times. diff --git a/steward.svg b/steward.svg index 3d93ebc..58f3a09 100644 --- a/steward.svg +++ b/steward.svg @@ -4,1898 +4,1946 @@ - - + + gocallvis - + command-line-arguments cluster_focus - -steward + +steward cluster_*github.com/RaaLabs/steward.Configuration - -(*Configuration) + +(*Configuration) cluster_*github.com/RaaLabs/steward.errorKernel - -(*errorKernel) + +(*errorKernel) -cluster_*github.com/RaaLabs/steward.ringBuffer - - -(*ringBuffer) +cluster_*github.com/RaaLabs/steward.flagNodeSlice + + +(*flagNodeSlice) -cluster_*github.com/RaaLabs/steward.server - - -(*server) +cluster_*github.com/RaaLabs/steward.ringBuffer + + +(*ringBuffer) -cluster_command-line-arguments - - -main +cluster_*github.com/RaaLabs/steward.server + + +(*server) -cluster_github.com/RaaLabs/steward.CommandOrEvent - - -(CommandOrEvent) +cluster_command-line-arguments + + +main -cluster_github.com/RaaLabs/steward.CommandOrEventAvailable - - -(CommandOrEventAvailable) +cluster_github.com/RaaLabs/steward.CommandOrEvent + + +(CommandOrEvent) -cluster_github.com/RaaLabs/steward.Method - - -(Method) +cluster_github.com/RaaLabs/steward.CommandOrEventAvailable + + +(CommandOrEventAvailable) -cluster_github.com/RaaLabs/steward.MethodsAvailable - - -(MethodsAvailable) +cluster_github.com/RaaLabs/steward.Method + + +(Method) -cluster_github.com/RaaLabs/steward.Subject - - -(Subject) +cluster_github.com/RaaLabs/steward.MethodsAvailable + + +(MethodsAvailable) -cluster_github.com/RaaLabs/steward.methodCLICommand - - -(methodCLICommand) +cluster_github.com/RaaLabs/steward.Subject + + +(Subject) -cluster_github.com/RaaLabs/steward.methodCLICommandReply - - -(methodCLICommandReply) +cluster_github.com/RaaLabs/steward.methodCLICommand + + +(methodCLICommand) -cluster_github.com/RaaLabs/steward.methodCLICommandRequest - - -(methodCLICommandRequest) +cluster_github.com/RaaLabs/steward.methodCLICommandReply + + +(methodCLICommandReply) -cluster_github.com/RaaLabs/steward.methodCLICommandRequestNOSEQ - - -(methodCLICommandRequestNOSEQ) +cluster_github.com/RaaLabs/steward.methodCLICommandRequest + + +(methodCLICommandRequest) -cluster_github.com/RaaLabs/steward.methodEchoReply - - -(methodEchoReply) +cluster_github.com/RaaLabs/steward.methodCLICommandRequestNOSEQ + + +(methodCLICommandRequestNOSEQ) -cluster_github.com/RaaLabs/steward.methodEchoRequest - - -(methodEchoRequest) +cluster_github.com/RaaLabs/steward.methodEchoReply + + +(methodEchoReply) -cluster_github.com/RaaLabs/steward.methodErrorLog - - -(methodErrorLog) +cluster_github.com/RaaLabs/steward.methodEchoRequest + + +(methodEchoRequest) -cluster_github.com/RaaLabs/steward.methodSayHello - - -(methodSayHello) +cluster_github.com/RaaLabs/steward.methodErrorLog + + +(methodErrorLog) -cluster_github.com/RaaLabs/steward.methodTextLogging - - -(methodTextLogging) +cluster_github.com/RaaLabs/steward.methodSayHello + + +(methodSayHello) -cluster_github.com/RaaLabs/steward.process - - -(process) +cluster_github.com/RaaLabs/steward.methodTextLogging + + +(methodTextLogging) -cluster_github.com/fsnotify/fsnotify - - -fsnotify +cluster_github.com/RaaLabs/steward.process + + +(process) -cluster_*github.com/fsnotify/fsnotify.Watcher - - -(*Watcher) +cluster_github.com/nats-io/nats.go + + +nats -cluster_github.com/nats-io/nats.go - - -nats +cluster_*github.com/nats-io/nats.go.Conn + + +(*Conn) -cluster_*github.com/nats-io/nats.go.Conn - - -(*Conn) +cluster_*github.com/nats-io/nats.go.Subscription + + +(*Subscription) -cluster_*github.com/nats-io/nats.go.Subscription - - -(*Subscription) +cluster_github.com/pelletier/go-toml + + +toml -cluster_github.com/pelletier/go-toml - - -toml +cluster_*github.com/pelletier/go-toml.Decoder + + +(*Decoder) -cluster_*github.com/pelletier/go-toml.Decoder - - -(*Decoder) +cluster_*github.com/pelletier/go-toml.Encoder + + +(*Encoder) -cluster_*github.com/pelletier/go-toml.Encoder - - -(*Encoder) +cluster_github.com/prometheus/client_golang/prometheus + + +prometheus -cluster_github.com/prometheus/client_golang/prometheus - - -prometheus +cluster_*github.com/prometheus/client_golang/prometheus.gauge + + +(*gauge) -cluster_*github.com/prometheus/client_golang/prometheus.gauge - - -(*gauge) +cluster_github.com/prometheus/client_golang/prometheus/promhttp + + +promhttp -cluster_github.com/prometheus/client_golang/prometheus/promhttp - - -promhttp +cluster_go.etcd.io/bbolt + + +bbolt -cluster_go.etcd.io/bbolt - - -bbolt +cluster_*go.etcd.io/bbolt.Bucket + + +(*Bucket) -cluster_*go.etcd.io/bbolt.Bucket - - -(*Bucket) +cluster_*go.etcd.io/bbolt.DB + + +(*DB) -cluster_*go.etcd.io/bbolt.DB - - -(*DB) - - - - cluster_*go.etcd.io/bbolt.Tx - - -(*Tx) + + +(*Tx) (*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.newSAM - -newSAM - - - -(github.com/RaaLabs/steward.Method).getHandler - -getHandler - - - -github.com/RaaLabs/steward.newSAM->(github.com/RaaLabs/steward.Method).getHandler - - - - - -(github.com/RaaLabs/steward.methodCLICommand).getKind - -getKind - - - -github.com/RaaLabs/steward.newSAM->(github.com/RaaLabs/steward.methodCLICommand).getKind - - - - - -(github.com/RaaLabs/steward.methodCLICommandReply).getKind - -getKind - - - -github.com/RaaLabs/steward.newSAM->(github.com/RaaLabs/steward.methodCLICommandReply).getKind - - - - - -(github.com/RaaLabs/steward.methodCLICommandRequest).getKind - -getKind - - - -github.com/RaaLabs/steward.newSAM->(github.com/RaaLabs/steward.methodCLICommandRequest).getKind - - - - - -(github.com/RaaLabs/steward.methodCLICommandRequestNOSEQ).getKind - -getKind - - - -github.com/RaaLabs/steward.newSAM->(github.com/RaaLabs/steward.methodCLICommandRequestNOSEQ).getKind - - - - - -(github.com/RaaLabs/steward.methodEchoReply).getKind - -getKind - - - -github.com/RaaLabs/steward.newSAM->(github.com/RaaLabs/steward.methodEchoReply).getKind - - - - - -(github.com/RaaLabs/steward.methodEchoRequest).getKind - -getKind - - - -github.com/RaaLabs/steward.newSAM->(github.com/RaaLabs/steward.methodEchoRequest).getKind - - - - - -(github.com/RaaLabs/steward.methodErrorLog).getKind - -getKind - - - -github.com/RaaLabs/steward.newSAM->(github.com/RaaLabs/steward.methodErrorLog).getKind - - - - - -(github.com/RaaLabs/steward.methodSayHello).getKind - -getKind - - - -github.com/RaaLabs/steward.newSAM->(github.com/RaaLabs/steward.methodSayHello).getKind - - - - - -(github.com/RaaLabs/steward.methodTextLogging).getKind - -getKind - - - -github.com/RaaLabs/steward.newSAM->(github.com/RaaLabs/steward.methodTextLogging).getKind - - + +(*ringBuffer).printBucketContent$1$1 - + github.com/RaaLabs/steward.sendErrorLogMessage - -sendErrorLogMessage + +sendErrorLogMessage - + github.com/RaaLabs/steward.createErrorMsgContent - -createErrorMsgContent + +createErrorMsgContent - + github.com/RaaLabs/steward.sendErrorLogMessage->github.com/RaaLabs/steward.createErrorMsgContent - - + + - + + +(github.com/RaaLabs/steward.methodCLICommandRequest).handler$1$1 + +(methodCLICommandRequest).handler$1$1 + + -github.com/RaaLabs/steward.processNameGet - -processNameGet +github.com/RaaLabs/steward.newSAM + +newSAM - + + +(github.com/RaaLabs/steward.Method).getHandler + +getHandler + + + +github.com/RaaLabs/steward.newSAM->(github.com/RaaLabs/steward.Method).getHandler + + + + + +(github.com/RaaLabs/steward.methodCLICommand).getKind + +getKind + + + +github.com/RaaLabs/steward.newSAM->(github.com/RaaLabs/steward.methodCLICommand).getKind + + + + + +(github.com/RaaLabs/steward.methodCLICommandReply).getKind + +getKind + + + +github.com/RaaLabs/steward.newSAM->(github.com/RaaLabs/steward.methodCLICommandReply).getKind + + + + + +(github.com/RaaLabs/steward.methodCLICommandRequest).getKind + +getKind + + + +github.com/RaaLabs/steward.newSAM->(github.com/RaaLabs/steward.methodCLICommandRequest).getKind + + + + + +(github.com/RaaLabs/steward.methodCLICommandRequestNOSEQ).getKind + +getKind + + + +github.com/RaaLabs/steward.newSAM->(github.com/RaaLabs/steward.methodCLICommandRequestNOSEQ).getKind + + + + + +(github.com/RaaLabs/steward.methodEchoReply).getKind + +getKind + + + +github.com/RaaLabs/steward.newSAM->(github.com/RaaLabs/steward.methodEchoReply).getKind + + + + + +(github.com/RaaLabs/steward.methodEchoRequest).getKind + +getKind + + + +github.com/RaaLabs/steward.newSAM->(github.com/RaaLabs/steward.methodEchoRequest).getKind + + + + + +(github.com/RaaLabs/steward.methodErrorLog).getKind + +getKind + + + +github.com/RaaLabs/steward.newSAM->(github.com/RaaLabs/steward.methodErrorLog).getKind + + + + + +(github.com/RaaLabs/steward.methodSayHello).getKind + +getKind + + + +github.com/RaaLabs/steward.newSAM->(github.com/RaaLabs/steward.methodSayHello).getKind + + + + + +(github.com/RaaLabs/steward.methodTextLogging).getKind + +getKind + + + +github.com/RaaLabs/steward.newSAM->(github.com/RaaLabs/steward.methodTextLogging).getKind + + + + -github.com/RaaLabs/steward.gobEncodeMessage - -gobEncodeMessage +(github.com/RaaLabs/steward.methodCLICommandRequestNOSEQ).handler$1$1 + +(methodCLICommandRequestNOSEQ).handler$1$1 github.com/RaaLabs/steward.NewConfiguration - -NewConfiguration + +NewConfiguration github.com/RaaLabs/steward.newConfigurationDefaults - -newConfigurationDefaults + +newConfigurationDefaults github.com/RaaLabs/steward.NewServer - -NewServer + +NewServer github.com/RaaLabs/steward.newProcesses - -newProcesses + +newProcesses - + github.com/RaaLabs/steward.NewServer->github.com/RaaLabs/steward.newProcesses - - + + github.com/RaaLabs/steward.newMetrics - -newMetrics + +newMetrics - + github.com/RaaLabs/steward.NewServer->github.com/RaaLabs/steward.newMetrics - - + + github.com/nats-io/nats.go.Connect - -Connect + +Connect - + github.com/RaaLabs/steward.NewServer->github.com/nats-io/nats.go.Connect - - + + github.com/RaaLabs/steward.newErrorKernel - -newErrorKernel + +newErrorKernel (*github.com/RaaLabs/steward.errorKernel).startErrorKernel$1$1 - -(*errorKernel).startErrorKernel$1$1 + +(*errorKernel).startErrorKernel$1$1 - + -github.com/RaaLabs/steward.fileWatcherStart - -fileWatcherStart +github.com/RaaLabs/steward.convertBytesToSAM + +convertBytesToSAM - - -github.com/RaaLabs/steward.fileWatcherStart$1 - -fileWatcherStart$1 - - - -github.com/RaaLabs/steward.fileWatcherStart->github.com/RaaLabs/steward.fileWatcherStart$1 - - - - - - - -github.com/fsnotify/fsnotify.NewWatcher - -NewWatcher - - - -github.com/RaaLabs/steward.fileWatcherStart->github.com/fsnotify/fsnotify.NewWatcher - - - - - -(*github.com/fsnotify/fsnotify.Watcher).Close - -Close - - - -github.com/RaaLabs/steward.fileWatcherStart->(*github.com/fsnotify/fsnotify.Watcher).Close - - - - - - - -(*github.com/fsnotify/fsnotify.Watcher).Add - -Add - - - -github.com/RaaLabs/steward.fileWatcherStart->(*github.com/fsnotify/fsnotify.Watcher).Add - - - - - -github.com/RaaLabs/steward.readTruncateMessageFile - -readTruncateMessageFile - - - -github.com/RaaLabs/steward.jsonFromFileData - -jsonFromFileData - - - -github.com/RaaLabs/steward.jsonFromFileData->github.com/RaaLabs/steward.newSAM - - + + +github.com/RaaLabs/steward.convertBytesToSAM->github.com/RaaLabs/steward.newSAM + + - + github.com/RaaLabs/steward.newSubject - -newSubject + +newSubject - + github.com/RaaLabs/steward.newProcess - -newProcess + +newProcess - + (github.com/RaaLabs/steward.Method).GetMethodsAvailable - -GetMethodsAvailable + +GetMethodsAvailable - + 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.newringBuffer - -newringBuffer + +newringBuffer go.etcd.io/bbolt.Open - -Open + +Open - + github.com/RaaLabs/steward.newringBuffer->go.etcd.io/bbolt.Open - - + + - + (*github.com/RaaLabs/steward.Configuration).ReadConfigFile - -ReadConfigFile + +ReadConfigFile github.com/pelletier/go-toml.NewDecoder - -NewDecoder + +NewDecoder - + (*github.com/RaaLabs/steward.Configuration).ReadConfigFile->github.com/pelletier/go-toml.NewDecoder - - + + (*github.com/pelletier/go-toml.Decoder).Decode - -Decode + +Decode - + (*github.com/RaaLabs/steward.Configuration).ReadConfigFile->(*github.com/pelletier/go-toml.Decoder).Decode - - + + - + (*github.com/RaaLabs/steward.Configuration).CheckFlags - -CheckFlags + +CheckFlags - + (*github.com/RaaLabs/steward.Configuration).CheckFlags->github.com/RaaLabs/steward.newConfigurationDefaults - - + + - + (*github.com/RaaLabs/steward.Configuration).CheckFlags->(*github.com/RaaLabs/steward.Configuration).ReadConfigFile - - + + - + (*github.com/RaaLabs/steward.Configuration).WriteConfigFile - -WriteConfigFile + +WriteConfigFile - + (*github.com/RaaLabs/steward.Configuration).CheckFlags->(*github.com/RaaLabs/steward.Configuration).WriteConfigFile - - + + github.com/pelletier/go-toml.NewEncoder - -NewEncoder + +NewEncoder - + (*github.com/RaaLabs/steward.Configuration).WriteConfigFile->github.com/pelletier/go-toml.NewEncoder - - + + (*github.com/pelletier/go-toml.Encoder).Encode - -Encode + +Encode - + (*github.com/RaaLabs/steward.Configuration).WriteConfigFile->(*github.com/pelletier/go-toml.Encoder).Encode - - + + - + (*github.com/RaaLabs/steward.errorKernel).startErrorKernel$1 - -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 + +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.ringBuffer).dbUpdate$1 - -dbUpdate$1 + +dbUpdate$1 (*go.etcd.io/bbolt.Bucket).Put - -Put + +Put (*github.com/RaaLabs/steward.ringBuffer).dbUpdate$1->(*go.etcd.io/bbolt.Bucket).Put - - + + (*go.etcd.io/bbolt.Tx).CreateBucketIfNotExists - -CreateBucketIfNotExists + +CreateBucketIfNotExists (*github.com/RaaLabs/steward.ringBuffer).dbUpdate$1->(*go.etcd.io/bbolt.Tx).CreateBucketIfNotExists - - + + - + (*github.com/RaaLabs/steward.ringBuffer).deleteKeyFromBucket$1 - -deleteKeyFromBucket$1 + +deleteKeyFromBucket$1 (*go.etcd.io/bbolt.Bucket).Delete - -Delete + +Delete (*github.com/RaaLabs/steward.ringBuffer).deleteKeyFromBucket$1->(*go.etcd.io/bbolt.Bucket).Delete - - + + (*go.etcd.io/bbolt.Tx).Bucket - -Bucket + +Bucket (*github.com/RaaLabs/steward.ringBuffer).deleteKeyFromBucket$1->(*go.etcd.io/bbolt.Tx).Bucket - - + + - - -(*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 - - - -(*go.etcd.io/bbolt.Bucket).ForEach - -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).printBucketContent$1 - -printBucketContent$1 - - - -(*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).printBucketContent - -printBucketContent - - - -(*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).dumpBucket - -dumpBucket - - - -(*github.com/RaaLabs/steward.ringBuffer).dumpBucket->(*go.etcd.io/bbolt.DB).View - - - - - -(*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).fillBuffer$1 - -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.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).deleteKeyFromBucket + +deleteKeyFromBucket (*go.etcd.io/bbolt.DB).Update - -Update - - - -(*github.com/RaaLabs/steward.ringBuffer).dbUpdate->(*go.etcd.io/bbolt.DB).Update - - - - - -(*github.com/RaaLabs/steward.ringBuffer).deleteKeyFromBucket - -deleteKeyFromBucket + +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).printBucketContent - - + +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 + + + +(*go.etcd.io/bbolt.Bucket).ForEach + +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).printBucketContent$1 + +printBucketContent$1 + + + +(*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 + + + + + +(*go.etcd.io/bbolt.DB).View + +View + + + +(*github.com/RaaLabs/steward.ringBuffer).printBucketContent->(*go.etcd.io/bbolt.DB).View + + + + + +(*github.com/RaaLabs/steward.ringBuffer).processBufferMessages + +processBufferMessages - + (*github.com/RaaLabs/steward.ringBuffer).processBufferMessages->(*github.com/RaaLabs/steward.ringBuffer).processBufferMessages$1 - - - - + + + + + + + +(*github.com/RaaLabs/steward.ringBuffer).dumpBucket + +dumpBucket + + + +(*github.com/RaaLabs/steward.ringBuffer).dumpBucket->(*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).processBufferMessages + + + + + + + +(*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).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.server).Start - -Start + +Start - + (*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).startMetrics - -startMetrics + +startMetrics - + (*github.com/RaaLabs/steward.server).Start->(*github.com/RaaLabs/steward.server).startMetrics - - - - + + + + - - -(*github.com/RaaLabs/steward.server).getMessagesFromFile - -getMessagesFromFile + + +(*github.com/RaaLabs/steward.server).readSocket + +readSocket - - -(*github.com/RaaLabs/steward.server).Start->(*github.com/RaaLabs/steward.server).getMessagesFromFile - - - - + + +(*github.com/RaaLabs/steward.server).Start->(*github.com/RaaLabs/steward.server).readSocket + + + + - + (*github.com/RaaLabs/steward.server).ProcessesStart - -ProcessesStart + +ProcessesStart - + (*github.com/RaaLabs/steward.server).Start->(*github.com/RaaLabs/steward.server).ProcessesStart - - + + - + (*github.com/RaaLabs/steward.server).printProcessesMap - -printProcessesMap + +printProcessesMap - + (*github.com/RaaLabs/steward.server).Start->(*github.com/RaaLabs/steward.server).printProcessesMap - - + + - + (*github.com/RaaLabs/steward.server).routeMessagesToProcess - -routeMessagesToProcess + +routeMessagesToProcess - + (*github.com/RaaLabs/steward.server).Start->(*github.com/RaaLabs/steward.server).routeMessagesToProcess - - + + - + (*github.com/RaaLabs/steward.server).startMetrics$1 - -startMetrics$1 + +startMetrics$1 github.com/prometheus/client_golang/prometheus.Register - -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 + +Set - + (*github.com/RaaLabs/steward.server).startMetrics$1->(*github.com/prometheus/client_golang/prometheus.gauge).Set - - + + - + (*github.com/RaaLabs/steward.server).startMetrics->(*github.com/RaaLabs/steward.server).startMetrics$1 - - - - + + + + github.com/prometheus/client_golang/prometheus/promhttp.Handler - -Handler + +Handler - + (*github.com/RaaLabs/steward.server).startMetrics->github.com/prometheus/client_golang/prometheus/promhttp.Handler - - + + - - -(*github.com/RaaLabs/steward.server).getMessagesFromFile->github.com/RaaLabs/steward.fileWatcherStart - - - - + + +(*github.com/RaaLabs/steward.server).readSocket->github.com/RaaLabs/steward.sendErrorLogMessage + + - + -(*github.com/RaaLabs/steward.server).getMessagesFromFile->github.com/RaaLabs/steward.readTruncateMessageFile - - - - - -(*github.com/RaaLabs/steward.server).getMessagesFromFile->github.com/RaaLabs/steward.jsonFromFileData - - +(*github.com/RaaLabs/steward.server).readSocket->github.com/RaaLabs/steward.convertBytesToSAM + + - + (*github.com/RaaLabs/steward.server).ProcessesStart->github.com/RaaLabs/steward.newSubject - - + + - + (*github.com/RaaLabs/steward.server).ProcessesStart->github.com/RaaLabs/steward.newProcess - - + + - + (github.com/RaaLabs/steward.process).spawnWorker - -spawnWorker + +spawnWorker - + (*github.com/RaaLabs/steward.server).ProcessesStart->(github.com/RaaLabs/steward.process).spawnWorker - - - - + + + + - + (*github.com/RaaLabs/steward.server).ProcessesStart$1 - -ProcessesStart$1 + +ProcessesStart$1 github.com/prometheus/client_golang/prometheus.NewGauge - -NewGauge + +NewGauge - + (*github.com/RaaLabs/steward.server).ProcessesStart$1->github.com/prometheus/client_golang/prometheus.NewGauge - - + + - + (*github.com/RaaLabs/steward.server).ProcessesStart$2 - -ProcessesStart$2 + +ProcessesStart$2 - + (*github.com/RaaLabs/steward.server).ProcessesStart$2->github.com/RaaLabs/steward.newSAM - - + + - + (github.com/RaaLabs/steward.Subject).name - -name + +name - + (*github.com/RaaLabs/steward.server).printProcessesMap->(github.com/RaaLabs/steward.Subject).name - - + + - + (*github.com/RaaLabs/steward.server).printProcessesMap->github.com/prometheus/client_golang/prometheus.NewGauge - - + + - + (*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 + +routeMessagesToProcess$1 - + (*github.com/RaaLabs/steward.server).routeMessagesToProcess->(*github.com/RaaLabs/steward.server).routeMessagesToProcess$1 - - - - + + + + - + (*github.com/RaaLabs/steward.server).routeMessagesToProcess$2 - -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.processNameGet - - + + +(*github.com/RaaLabs/steward.server).routeMessagesToProcess$2->github.com/RaaLabs/steward.sendErrorLogMessage + + - + (*github.com/RaaLabs/steward.server).routeMessagesToProcess$2->github.com/RaaLabs/steward.newSubject - - + + - + (*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.server).printProcessesMap - - + + - + (*github.com/RaaLabs/steward.server).routeMessagesToProcess$2->(github.com/RaaLabs/steward.CommandOrEventAvailable).CheckIfExists - - + + - + (github.com/RaaLabs/steward.MethodsAvailable).CheckIfExists - -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.server).routeMessagesToProcess$2->(github.com/RaaLabs/steward.process).spawnWorker - - + + - + command-line-arguments.main - -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->(github.com/RaaLabs/steward.Method).GetMethodsAvailable - - + + - + (github.com/RaaLabs/steward.methodCLICommand).handler - -handler + +handler + + + +(github.com/RaaLabs/steward.methodCLICommand).handler->github.com/RaaLabs/steward.sendErrorLogMessage + + + + + +(github.com/RaaLabs/steward.methodCLICommand).handler$1 + +handler$1 + + + +(github.com/RaaLabs/steward.methodCLICommand).handler->(github.com/RaaLabs/steward.methodCLICommand).handler$1 + + + + - + (github.com/RaaLabs/steward.methodCLICommandReply).handler - -handler + +handler + + + +(github.com/RaaLabs/steward.methodCLICommandRequest).handler$1 + +handler$1 + + + +(github.com/RaaLabs/steward.methodCLICommandRequest).handler$1->github.com/RaaLabs/steward.sendErrorLogMessage + + + + + +(github.com/RaaLabs/steward.methodCLICommandRequest).handler$1->(github.com/RaaLabs/steward.methodCLICommandRequest).handler$1$1 + + + + + + + +(github.com/RaaLabs/steward.methodCLICommandRequest).handler$1->github.com/RaaLabs/steward.newSAM + + - + (github.com/RaaLabs/steward.methodCLICommandRequest).handler - -handler + +handler - - -(github.com/RaaLabs/steward.methodCLICommandRequest).handler->github.com/RaaLabs/steward.newSAM - - + + +(github.com/RaaLabs/steward.methodCLICommandRequest).handler->(github.com/RaaLabs/steward.methodCLICommandRequest).handler$1 + + + + - + (github.com/RaaLabs/steward.methodCLICommandRequestNOSEQ).handler$1 - -handler$1 + +handler$1 + + + +(github.com/RaaLabs/steward.methodCLICommandRequestNOSEQ).handler$1->github.com/RaaLabs/steward.sendErrorLogMessage + + - + (github.com/RaaLabs/steward.methodCLICommandRequestNOSEQ).handler$1->github.com/RaaLabs/steward.newSAM - - + + + + + +(github.com/RaaLabs/steward.methodCLICommandRequestNOSEQ).handler$1->(github.com/RaaLabs/steward.methodCLICommandRequestNOSEQ).handler$1$1 + + + + - + (github.com/RaaLabs/steward.methodCLICommandRequestNOSEQ).handler - -handler + +handler - + (github.com/RaaLabs/steward.methodCLICommandRequestNOSEQ).handler->(github.com/RaaLabs/steward.methodCLICommandRequestNOSEQ).handler$1 - - - - + + + + - + (github.com/RaaLabs/steward.methodEchoReply).handler - -handler + +handler - + (github.com/RaaLabs/steward.methodEchoRequest).handler - -handler + +handler - + (github.com/RaaLabs/steward.methodEchoRequest).handler->github.com/RaaLabs/steward.newSAM - - + + - + (github.com/RaaLabs/steward.methodErrorLog).handler - -handler + +handler - + (github.com/RaaLabs/steward.methodSayHello).handler - -handler + +handler - + (github.com/RaaLabs/steward.methodTextLogging).handler - -handler + +handler - + (github.com/RaaLabs/steward.methodTextLogging).handler->(github.com/RaaLabs/steward.Subject).name - - + + - + (github.com/RaaLabs/steward.process).subscriberHandler - -subscriberHandler + +subscriberHandler - + (github.com/RaaLabs/steward.process).subscriberHandler->github.com/RaaLabs/steward.sendErrorLogMessage - - + + - + (github.com/RaaLabs/steward.process).subscriberHandler->(github.com/RaaLabs/steward.MethodsAvailable).CheckIfExists - - + + - + (github.com/RaaLabs/steward.process).subscriberHandler->(github.com/RaaLabs/steward.methodCLICommand).handler - - + + - + (github.com/RaaLabs/steward.process).subscriberHandler->(github.com/RaaLabs/steward.methodCLICommandReply).handler - - + + - + (github.com/RaaLabs/steward.process).subscriberHandler->(github.com/RaaLabs/steward.methodCLICommandRequest).handler - - + + - + (github.com/RaaLabs/steward.process).subscriberHandler->(github.com/RaaLabs/steward.methodCLICommandRequestNOSEQ).handler - - + + - + (github.com/RaaLabs/steward.process).subscriberHandler->(github.com/RaaLabs/steward.methodEchoReply).handler - - + + - + (github.com/RaaLabs/steward.process).subscriberHandler->(github.com/RaaLabs/steward.methodEchoRequest).handler - - + + - + (github.com/RaaLabs/steward.process).subscriberHandler->(github.com/RaaLabs/steward.methodErrorLog).handler - - + + - + (github.com/RaaLabs/steward.process).subscriberHandler->(github.com/RaaLabs/steward.methodSayHello).handler - - + + - + (github.com/RaaLabs/steward.process).subscriberHandler->(github.com/RaaLabs/steward.methodTextLogging).handler - - + + (*github.com/nats-io/nats.go.Conn).Publish - -Publish + +Publish - + (github.com/RaaLabs/steward.process).subscriberHandler->(*github.com/nats-io/nats.go.Conn).Publish - - + + - + (github.com/RaaLabs/steward.process).subscribeMessages$1 - -subscribeMessages$1 + +subscribeMessages$1 - + (github.com/RaaLabs/steward.process).subscribeMessages$1->(github.com/RaaLabs/steward.process).subscriberHandler - - - - + + + + + + + +(github.com/RaaLabs/steward.process).spawnWorker->github.com/RaaLabs/steward.processNameGet + + + + + +(github.com/RaaLabs/steward.process).spawnWorker->(github.com/RaaLabs/steward.Subject).name + + + + + +(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 + +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.process).spawnWorker$1->(*github.com/RaaLabs/steward.server).ProcessesStart$1 + + + + + +(github.com/RaaLabs/steward.process).spawnWorker$1->(*github.com/RaaLabs/steward.server).ProcessesStart$2 + + - + (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 + +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 + +SubscribeSync - + (github.com/RaaLabs/steward.process).messageDeliverNats->(*github.com/nats-io/nats.go.Conn).SubscribeSync - - + + (*github.com/nats-io/nats.go.Conn).PublishMsg - -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 + +NextMsg - -(github.com/RaaLabs/steward.process).messageDeliverNats->(*github.com/nats-io/nats.go.Subscription).NextMsg - - - - - -(github.com/RaaLabs/steward.process).spawnWorker->github.com/RaaLabs/steward.processNameGet - - - - - -(github.com/RaaLabs/steward.process).spawnWorker->(github.com/RaaLabs/steward.Subject).name - - - - - -(github.com/RaaLabs/steward.process).spawnWorker->(github.com/RaaLabs/steward.process).publishMessages - - - - - - - -(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).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).messageDeliverNats->(*github.com/nats-io/nats.go.Subscription).NextMsg + + - - -(github.com/RaaLabs/steward.process).spawnWorker$1->(*github.com/RaaLabs/steward.server).ProcessesStart$1 - - - - - -(github.com/RaaLabs/steward.process).spawnWorker$1->(*github.com/RaaLabs/steward.server).ProcessesStart$2 - - + + +(github.com/RaaLabs/steward.process).spawnWorker$2->github.com/RaaLabs/steward.sendErrorLogMessage + + - + (github.com/RaaLabs/steward.process).spawnWorker$2->(*github.com/RaaLabs/steward.server).ProcessesStart$1 - - + + - + (github.com/RaaLabs/steward.process).spawnWorker$2->(*github.com/RaaLabs/steward.server).ProcessesStart$2 - - + + - + (github.com/RaaLabs/steward.process).subscribeMessages->(github.com/RaaLabs/steward.Subject).name - - + + (*github.com/nats-io/nats.go.Conn).Subscribe - -Subscribe + +Subscribe - + (github.com/RaaLabs/steward.process).subscribeMessages->(*github.com/nats-io/nats.go.Conn).Subscribe - - + + (*github.com/nats-io/nats.go.Conn).waitForMsgs - -waitForMsgs + +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).dbView$1 - - + + - + (*go.etcd.io/bbolt.DB).View->(*github.com/RaaLabs/steward.ringBuffer).dumpBucket$1 - - + + - + (*go.etcd.io/bbolt.DB).View->(*github.com/RaaLabs/steward.ringBuffer).printBucketContent$1 - - + +