This commit is contained in:
Michael Hohn
2024-05-10 13:21:50 -07:00
committed by =Michael Hohn
parent 9fc07e8c95
commit 12595077c7
18 changed files with 66 additions and 37 deletions

View File

@@ -10,7 +10,8 @@ import (
"os" "os"
"github.com/BurntSushi/toml" "github.com/BurntSushi/toml"
"github.com/advanced-security/mrvacommander/intefaces/mci" "github.com/advanced-security/mrvacommander/config/mcc"
"github.com/advanced-security/mrvacommander/interfaces/mci"
"github.com/advanced-security/mrvacommander/lib/commander/lcmem" "github.com/advanced-security/mrvacommander/lib/commander/lcmem"
"github.com/advanced-security/mrvacommander/lib/logger/llmem" "github.com/advanced-security/mrvacommander/lib/logger/llmem"
"github.com/advanced-security/mrvacommander/lib/queue/lqmem" "github.com/advanced-security/mrvacommander/lib/queue/lqmem"
@@ -63,12 +64,12 @@ func main() {
switch *mode { switch *mode {
case "standalone": case "standalone":
// Assemble single-process version // Assemble single-process version
state := MCState{ state := mci.State{
commander: lcmem.LCCommander, Commander: lcmem.Commander{},
logger: llmem.LCLogger, Logger: llmem.Logger{},
queue: lqmem.LCQueue, Queue: lqmem.Queue{},
storage: lsmem.LCStorage, Storage: lsmem.Storage{},
runner: lrmem.LCRunner, Runner: lrmem.Runner{},
} }
case "container": case "container":
@@ -89,31 +90,12 @@ func main() {
} }
type MCCConf struct {
}
type MCLConf struct {
}
type MCQConf struct {
}
type MCSConf struct {
}
type MCRConf struct {
}
type MCState struct {
commander mci.MCCommander
logger mci.MCLogger
queue mci.MCQueue
storage mci.MCStorage
runner mci.MCRunner
}
type MCConfig struct { type MCConfig struct {
commander MCCConf commander mcc.Commander
logger MCLConf logger mcc.Logger
queue MCQConf queue mcc.Queue
storage MCSConf storage mcc.Storage
runner MCRConf runner mcc.Runner
} }
func loadConfig(fname string) *MCConfig { func loadConfig(fname string) *MCConfig {

4
config/mcc/commander.go Normal file
View File

@@ -0,0 +1,4 @@
package mcc
type Commander struct {
}

4
config/mcc/common.go Normal file
View File

@@ -0,0 +1,4 @@
package mcc
type Common struct {
}

4
config/mcc/logger.go Normal file
View File

@@ -0,0 +1,4 @@
package mcc
type Logger struct {
}

4
config/mcc/queue.go Normal file
View File

@@ -0,0 +1,4 @@
package mcc
type Queue struct {
}

4
config/mcc/runner.go Normal file
View File

@@ -0,0 +1,4 @@
package mcc
type Runner struct {
}

4
config/mcc/storage.go Normal file
View File

@@ -0,0 +1,4 @@
package mcc
type Storage struct {
}

View File

@@ -1,4 +1,12 @@
package mci package mci
type MCCommander struct { type Commander interface {
}
type State struct {
Commander Commander
Logger Logger
Queue Queue
Storage Storage
Runner Runner
} }

View File

@@ -1,4 +1,4 @@
package mci package mci
type MCCommon struct { type Common struct {
} }

View File

@@ -1,4 +1,4 @@
package mci package mci
type MCLogger struct { type Logger interface {
} }

View File

@@ -1,4 +1,4 @@
package mci package mci
type MCQueue struct { type Queue interface {
} }

View File

@@ -1,4 +1,4 @@
package mci package mci
type MCRunner struct { type Runner interface {
} }

View File

@@ -1,4 +1,4 @@
package mci package mci
type MCStorage struct { type Storage interface {
} }

View File

@@ -12,6 +12,9 @@ import (
"github.com/hohn/ghes-mirva-server/store" "github.com/hohn/ghes-mirva-server/store"
) )
type Commander struct {
}
func StatusResponse(w http.ResponseWriter, js co.JobSpec, ji co.JobInfo, vaid int) { func StatusResponse(w http.ResponseWriter, js co.JobSpec, ji co.JobInfo, vaid int) {
slog.Debug("Submitting status response", "session", vaid) slog.Debug("Submitting status response", "session", vaid)

View File

@@ -1 +1,4 @@
package llmem package llmem
type Logger struct {
}

View File

@@ -1 +1,4 @@
package lqmem package lqmem
type Queue struct {
}

View File

@@ -1 +1,4 @@
package lrmem package lrmem
type Runner struct {
}

View File

@@ -1 +1,4 @@
package lsmem package lsmem
type Storage struct {
}