Documentation
¶
Index ¶
- func New(store ark.Store, logger logz.FieldLogger, broker cqrs.Broker, ...) *fiber.App
- func NewSubsystem(addr, logFile string, store ark.Store, logger logz.FieldLogger, ...) *subsystems.Process
- type Client
- type ClientGentleman
- func (c ClientGentleman) AddTarget(target ark.RawTarget) (ark.RawArtifact, error)
- func (c ClientGentleman) ConnectTargets(edge ark.GraphEdge) (ark.GraphEdge, error)
- func (c ClientGentleman) GetGraph() (*dag.AcyclicGraph, error)
- func (c ClientGentleman) GetGraphEdges() ([]ark.GraphEdge, error)
- func (c ClientGentleman) GetLogsByKey(logKey string) (io.Reader, error)
- func (c ClientGentleman) GetServerLogs() (io.Reader, error)
- func (c ClientGentleman) GetTargets() ([]ark.RawTarget, error)
- func (c ClientGentleman) Run(request messages.GraphRunnerExecuteCommand) (cmdRes messages.GraphRunnerExecuteCommandResponse, err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func New ¶
func New(store ark.Store, logger logz.FieldLogger, broker cqrs.Broker, logFilePath string) *fiber.App
New creates a new fiber server and storage interface
func NewSubsystem ¶
func NewSubsystem(addr, logFile string, store ark.Store, logger logz.FieldLogger, broker cqrs.Broker) *subsystems.Process
NewSubsystem stands up an http_server as a subsystem
Types ¶
type Client ¶
type Client interface {
AddTarget(target ark.RawTarget) (ark.RawArtifact, error)
GetTargets() ([]ark.RawTarget, error)
ConnectTargets(edge ark.GraphEdge) (ark.GraphEdge, error)
GetGraph() (*dag.AcyclicGraph, error)
GetGraphEdges() ([]ark.GraphEdge, error)
Run(cmd messages.GraphRunnerExecuteCommand) (messages.GraphRunnerExecuteCommandResponse, error)
GetServerLogs() (io.Reader, error)
GetLogsByKey(logKey string) (io.Reader, error)
}
Client represent a struct
type ClientGentleman ¶
type ClientGentleman struct {
// contains filtered or unexported fields
}
ClientGentleman defines the gentleman.ClientGentleman to be passed around
func (ClientGentleman) AddTarget ¶
func (c ClientGentleman) AddTarget(target ark.RawTarget) (ark.RawArtifact, error)
AddTarget adds a target to the database using the http client
func (ClientGentleman) ConnectTargets ¶
ConnectTargets connects the nodes in the graph
func (ClientGentleman) GetGraph ¶
func (c ClientGentleman) GetGraph() (*dag.AcyclicGraph, error)
GetGraph retrieves the graph from the database
func (ClientGentleman) GetGraphEdges ¶
func (c ClientGentleman) GetGraphEdges() ([]ark.GraphEdge, error)
GetGraphEdges retrieves all of the graph edges from the database
func (ClientGentleman) GetLogsByKey ¶
func (c ClientGentleman) GetLogsByKey(logKey string) (io.Reader, error)
GetLogsByKey streams logs for a specific target's key
func (ClientGentleman) GetServerLogs ¶
func (c ClientGentleman) GetServerLogs() (io.Reader, error)
GetServerLogs streams all server logs
func (ClientGentleman) GetTargets ¶
func (c ClientGentleman) GetTargets() ([]ark.RawTarget, error)
GetTargets gets all of the targets from the database and returns them as a slice of ark.Targets
func (ClientGentleman) Run ¶
func (c ClientGentleman) Run(request messages.GraphRunnerExecuteCommand) (cmdRes messages.GraphRunnerExecuteCommandResponse, err error)
Run execute targets
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.