mirrors/ctrl
1
0
Fork 0
mirror of https://github.com/postmannen/ctrl.git synced 2025-03-31 01:24:31 +00:00
Code Activity

Added flags and startup for OpCommand

Browse source
This commit is contained in:
postmannen 2021-03-31 11:22:25 +02:00
parent fc04ea83bd
commit 6c3ac318dc
3 changed files with 15 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
configuration_flags.go
View file

@ -115,6 +115,8 @@ type Configuration struct {
StartSubCLICommandRequestNOSEQ flagNodeSlice
// Subscriber for CLICommandReply
StartSubCLICommandReply flagNodeSlice
// Subscriber for OpCommand
StartSubOpCommand flagNodeSlice
}
func NewConfiguration() *Configuration {
@ -143,6 +145,7 @@ func newConfigurationDefaults() Configuration {
StartSubCLICommandRequest: flagNodeSlice{OK: true, Values: []node{"*"}},
StartSubCLICommandRequestNOSEQ: flagNodeSlice{OK: true, Values: []node{"*"}},
StartSubCLICommandReply: flagNodeSlice{OK: true, Values: []node{"*"}},
StartSubOpCommand: flagNodeSlice{OK: true, Values: []node{"*"}},
}
return c
}
@ -183,6 +186,7 @@ func (c *Configuration) CheckFlags() error {
flag.Var(&c.StartSubCLICommandRequest, "startSubCLICommandRequest", "Specify comma separated list for nodes to allow messages from. Use \"*\" for from all. Value RST will turn off subscriber.")
flag.Var(&c.StartSubCLICommandRequestNOSEQ, "startSubCLICommandRequestNOSEQ", "Specify comma separated list for nodes to allow messages from. Use \"*\" for from all. Value RST will turn off subscriber.")
flag.Var(&c.StartSubCLICommandReply, "startSubCLICommandReply", "Specify comma separated list for nodes to allow messages from. Use \"*\" for from all. Value RST will turn off subscriber.")
flag.Var(&c.StartSubOpCommand, "startSubOpCommand", "Specify comma separated list for nodes to allow messages from. Use \"*\" for from all. Value RST will turn off subscriber.")
flag.Parse()

4
etc/config.toml
View file

@ -37,6 +37,10 @@ SubscribersDataFolder = "./data"
OK = true
Values = ["*"]
[StartSubOpCommand]
OK = false
Values = []
[StartSubSayHello]
OK = true
Values = ["*"]

12
startup_processes.go
View file

@ -13,11 +13,13 @@ func (s *server) ProcessesStart() {
// --- Subscriber services that can be started via flags
// Start a subscriber for OPCommand messages
{
fmt.Printf("Starting OpCommand subscriber: %#v\n", s.nodeName)
sub := newSubject(OpCommand, CommandACK, s.nodeName)
proc := newProcess(s.processes, s.toRingbufferCh, s.configuration, sub, s.errorKernel.errorCh, processKindSubscriber, []node{"*"}, nil)
go proc.spawnWorker(s)
if s.configuration.StartSubOpCommand.OK {
{
fmt.Printf("Starting OpCommand subscriber: %#v\n", s.nodeName)
sub := newSubject(OpCommand, CommandACK, s.nodeName)
proc := newProcess(s.processes, s.toRingbufferCh, s.configuration, sub, s.errorKernel.errorCh, processKindSubscriber, s.configuration.StartSubOpCommand.Values, nil)
go proc.spawnWorker(s)
}
}
// Start a subscriber for CLICommand messages