router

Documentation

Index

• Constants
• func BuildAndInitOtpt(settings *ActionSettings, aquaServerUrl string) actions.Action
• func SetupConnOptions(opts []nats.Option) []nats.Option
• type ActionSettings
• type Router
  • func Instance() *Router
  • func (ctx *Router) GetCurrentEvents() []any
  • func (ctx *Router) HandleRoute(routeName string, in []byte)
  • func (ctx *Router) ReloadConfig()
  • func (ctx *Router) Send(data []byte)
  • func (ctx *Router) Start(cfgfile string) error
  • func (ctx *Router) Terminate()
• type Template
• type TenantSettings
  • func Parsev2cfg(cfgpath string) (*TenantSettings, error)

Constants

const (
	ServiceNowTableDefault = "incident"
	AnonymizeReplacement   = "<hidden>"
)

const (
	B  = 1
	KB = 1024
	MB = 1024 * KB
	GB = 1024 * MB
)

Functions

func BuildAndInitOtpt

func BuildAndInitOtpt(settings *ActionSettings, aquaServerUrl string) actions.Action

func SetupConnOptions

func SetupConnOptions(opts []nats.Option) []nats.Option

Types

type ActionSettings

type ActionSettings struct {
	Name              string                       `json:"name,omitempty"`
	Type              string                       `json:"type,omitempty"`
	RunsOn            string                       `json:"runs-on,omitempty"`
	Enable            bool                         `json:"enable,omitempty"`
	Url               string                       `json:"url,omitempty"`
	User              string                       `json:"user,omitempty"`
	Password          string                       `json:"password,omitempty"`
	TlsVerify         bool                         `json:"tls-verify,omitempty"`
	ProjectKey        string                       `json:"project-key,omitempty" structs:"project-key,omitempty"`
	IssueType         string                       `json:"issuetype,omitempty" structs:"issuetype"`
	BoardName         string                       `json:"board,omitempty" structs:"board,omitempty"`
	Priority          string                       `json:"priority,omitempty"`
	Assignee          []string                     `json:"assignee,omitempty"`
	Summary           string                       `json:"summary,omitempty"`
	FixVersions       []string                     `json:"fix-versions,omitempty"`
	AffectsVersions   []string                     `json:"affects-versions,omitempty"`
	Labels            []string                     `json:"labels,omitempty"`
	Sprint            string                       `json:"sprint,omitempty"`
	Unknowns          map[string]string            `json:"unknowns,omitempty" structs:"unknowns,omitempty"`
	Host              string                       `json:"host,omitempty"`
	Port              int                          `json:"port,omitempty"`
	Recipients        []string                     `json:"recipients,omitempty"`
	Sender            string                       `json:"sender,omitempty"`
	Token             string                       `json:"token,omitempty"`
	UseMX             bool                         `json:"use-mx,omitempty"`
	InstanceName      string                       `json:"instance,omitempty"`
	SizeLimit         int                          `json:"size-limit,omitempty"`
	InputFile         string                       `json:"input-file,omitempty"`
	ExecScript        string                       `json:"exec-script,omitempty"`
	Env               []string                     `json:"env,omitempty"`
	BodyFile          string                       `json:"body-file,omitempty"`
	BodyContent       string                       `json:"body-content,omitempty"`
	Method            string                       `json:"method,omitempty"`
	Timeout           string                       `json:"timeout,omitempty"`
	Headers           map[string][]string          `json:"headers,omitempty"`
	OrganizationId    string                       `json:"organization-id,omitempty"`
	KubeConfigFile    string                       `json:"kube-config-file,omitempty"`
	KubeLabelSelector string                       `json:"kube-label-selector,omitempty"`
	KubeActions       map[string]map[string]string `json:"kube-actions,omitempty"`
	KubeNamespace     string                       `json:"kube-namespace,omitempty"`
	DockerImageName   string                       `json:"docker-image-name,omitempty"`
	DockerNetwork     string                       `json:"docker-network,omitempty"`
	DockerCmd         []string                     `json:"docker-cmd,omitempty"`
	DockerVolumes     map[string]string            `json:"docker-volume-mounts,omitempty"`
	DockerEnv         []string                     `json:"docker-env,omitempty"`
	Tags              []string                     `json:"tags,omitempty"`
	Alias             string                       `json:"alias,omitempty"`
	Entity            string                       `json:"entity,omitempty"`
}

type Router

type Router struct {
	ConfigCh      chan *nats.Msg
	Mode          string
	NatsServer    *server.Server
	NatsConn      *nats.Conn
	NatsMsgCh     chan *nats.Msg
	RunnerName    string
	ControllerURL string
	// contains filtered or unexported fields
}

func Instance

func Instance() *Router

func (*Router) GetCurrentEvents

func (ctx *Router) GetCurrentEvents() []any

func (*Router) HandleRoute

func (ctx *Router) HandleRoute(routeName string, in []byte)

func (*Router) ReloadConfig

func (ctx *Router) ReloadConfig()

func (*Router) Send

func (ctx *Router) Send(data []byte)

func (*Router) Start

func (ctx *Router) Start(cfgfile string) error

func (*Router) Terminate

func (ctx *Router) Terminate()

type Template

type Template struct {
	Name               string `json:"name,omitempty"`
	Body               string `json:"body,omitempty"`
	RegoPackage        string `json:"rego-package,omitempty"`
	LegacyScanRenderer string `json:"legacy-scan-renderer,omitempty"`
	Url                string `json:"url,omitempty"`
}

type TenantSettings

type TenantSettings struct {
	AquaServer      string              `json:"aqua-server,omitempty"`
	DBMaxSize       string              `json:"max-db-size,omitempty"`
	DBRemoveOldData int                 `json:"delete-old-data,omitempty"`
	DBTestInterval  int                 `json:"db-verify-interval,omitempty"`
	Actions         []ActionSettings    `json:"actions,omitempty"`
	InputRoutes     []routes.InputRoute `json:"routes,omitempty"`
	Templates       []Template          `json:"templates,omitempty"`
}

func Parsev2cfg

func Parsev2cfg(cfgpath string) (*TenantSettings, error)