mirror of
https://github.com/dragonheim/gagent.git
synced 2025-04-26 01:08:59 -07:00
fix: changed import source.
This commit is contained in:
parent
316ea1afa6
commit
77c9399942
14 changed files with 54 additions and 170 deletions
|
@ -6,7 +6,7 @@ import (
|
|||
log "log"
|
||||
time "time"
|
||||
|
||||
gstructs "git.dragonheim.net/dragonheim/gagent/internal/gstructs"
|
||||
gstructs "github.com/dragonheim/gagent/internal/gstructs"
|
||||
|
||||
hclsimple "github.com/hashicorp/hcl/v2/hclsimple"
|
||||
// hclwrite "github.com/hashicorp/hcl/v2/hclwrite"
|
||||
|
|
|
@ -12,18 +12,18 @@ import (
|
|||
sync "sync"
|
||||
time "time"
|
||||
|
||||
gstructs "git.dragonheim.net/dragonheim/gagent/internal/gstructs"
|
||||
gstructs "github.com/dragonheim/gagent/internal/gstructs"
|
||||
|
||||
zmq "github.com/pebbe/zmq4"
|
||||
)
|
||||
|
||||
/*
|
||||
Client mode will send an agent file to a router for processing
|
||||
Clients do not process the agent files, only send them as
|
||||
requests to a router. If started without arguments, the client
|
||||
will contact the router and attempt to retrieve the results
|
||||
of it's most recent request.
|
||||
Main is the entrypoint for the client process
|
||||
Client mode will send an agent file to a router for processing
|
||||
Clients do not process the agent files, only send them as
|
||||
requests to a router. If started without arguments, the client
|
||||
will contact the router and attempt to retrieve the results
|
||||
of it's most recent request.
|
||||
Main is the entrypoint for the client process
|
||||
*/
|
||||
func Main(wg *sync.WaitGroup, config gstructs.GagentConfig) {
|
||||
log.Printf("[INFO] Starting client\n")
|
||||
|
|
|
@ -6,8 +6,8 @@ import (
|
|||
http "net/http"
|
||||
sync "sync"
|
||||
|
||||
gcdb "git.dragonheim.net/dragonheim/gagent/internal/chaindb"
|
||||
gstructs "git.dragonheim.net/dragonheim/gagent/internal/gstructs"
|
||||
gcdb "github.com/dragonheim/gagent/internal/chaindb"
|
||||
gstructs "github.com/dragonheim/gagent/internal/gstructs"
|
||||
|
||||
prometheus "github.com/prometheus/client_golang/prometheus"
|
||||
promauto "github.com/prometheus/client_golang/prometheus/promauto"
|
||||
|
@ -24,12 +24,12 @@ var (
|
|||
)
|
||||
|
||||
/*
|
||||
The 'router' processes routing requests from the agent. The router does
|
||||
not handle any of the agent activities beyond processing the agent's
|
||||
list of tags and passing the agent and it's storage to either a member
|
||||
or client node. Tags are used by the agent to give hints as to where
|
||||
it should be routed.
|
||||
Main is the entrypoint for the router
|
||||
The 'router' processes routing requests from the agent. The router does
|
||||
not handle any of the agent activities beyond processing the agent's
|
||||
list of tags and passing the agent and it's storage to either a member
|
||||
or client node. Tags are used by the agent to give hints as to where
|
||||
it should be routed.
|
||||
Main is the entrypoint for the router
|
||||
*/
|
||||
func Main(wg *sync.WaitGroup, config gstructs.GagentConfig) {
|
||||
log.Printf("[INFO] Starting router\n")
|
||||
|
|
|
@ -6,13 +6,13 @@ import (
|
|||
|
||||
cty "github.com/zclconf/go-cty/cty"
|
||||
|
||||
gs "git.dragonheim.net/dragonheim/gagent/internal/gstructs"
|
||||
gs "github.com/dragonheim/gagent/internal/gstructs"
|
||||
|
||||
hclwrite "github.com/hashicorp/hcl/v2/hclwrite"
|
||||
)
|
||||
|
||||
/*
|
||||
Main is the entrypoint for the setup process
|
||||
Main is the entrypoint for the setup process
|
||||
*/
|
||||
func Main(wg *sync.WaitGroup, config gs.GagentConfig) {
|
||||
log.Printf("[INFO] Starting setup\n")
|
||||
|
|
|
@ -5,9 +5,9 @@ import (
|
|||
log "log"
|
||||
sync "sync"
|
||||
|
||||
gstructs "git.dragonheim.net/dragonheim/gagent/internal/gstructs"
|
||||
gstructs "github.com/dragonheim/gagent/internal/gstructs"
|
||||
|
||||
// picol "git.dragonheim.net/dragonheim/gagent/src/picol"
|
||||
// picol "github.com/dragonheim/gagent/src/picol"
|
||||
|
||||
prometheus "github.com/prometheus/client_golang/prometheus"
|
||||
promauto "github.com/prometheus/client_golang/prometheus/promauto"
|
||||
|
@ -22,11 +22,11 @@ var (
|
|||
)
|
||||
|
||||
/*
|
||||
The "worker" processes the agent code. The worker nodes do not know
|
||||
anything about the network structure. Instead they know only to which
|
||||
router(s) they are connected. The worker will execute the agent code and
|
||||
pass the agent and it's results to a router.
|
||||
Main is the entrypoint for the worker process
|
||||
The "worker" processes the agent code. The worker nodes do not know
|
||||
anything about the network structure. Instead they know only to which
|
||||
router(s) they are connected. The worker will execute the agent code and
|
||||
pass the agent and it's results to a router.
|
||||
Main is the entrypoint for the worker process
|
||||
*/
|
||||
func Main(wg *sync.WaitGroup, config gstructs.GagentConfig) {
|
||||
log.Printf("[INFO] Starting worker\n")
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue