agent

Documentation

Index

• func EachFile(libdirs []string, cb func(name string, path string) (br bool))
• type Action
  • func (a *Action) AggregateResult(result map[string]interface{}) error
  • func (a *Action) AggregateResultJSON(jres []byte) error
  • func (a *Action) AggregateSummaryFormattedStrings() (map[string][]string, error)
  • func (a *Action) AggregateSummaryJSON() ([]byte, error)
  • func (a *Action) AggregateSummaryStrings() (map[string]map[string]string, error)
  • func (a *Action) InputNames() (names []string)
  • func (a *Action) RequiresInput(input string) bool
  • func (a *Action) ValidateAndConvertToDDLTypes(args map[string]string) (result map[string]interface{}, warnings []string, err error)
  • func (a *Action) ValidateInputString(input string, val string) error
  • func (a *Action) ValidateInputValue(input string, val interface{}) (warnings []string, err error)
• type ActionAggregateItem
• type ActionInputItem
• type ActionOutputItem
• type DDL
  • func Find(agent string, libdirs []string) (ddl *DDL, err error)
  • func New(file string) (*DDL, error)
  • func (d *DDL) ActionInterface(action string) (*Action, error)
  • func (d *DDL) ActionNames() []string
  • func (d *DDL) HaveAction(action string) bool
  • func (d *DDL) Timeout() time.Duration
  • func (d *DDL) ValidateAndConvertToDDLTypes(action string, args map[string]string) (result map[string]interface{}, warnings []string, err error)

Functions

func EachFile

func EachFile(libdirs []string, cb func(name string, path string) (br bool))

EachFile calls cb with a path to every found agent DDL, stops looking when br is true

Types

type Action

type Action struct {
	Name        string                       `json:"action"`
	Input       map[string]*ActionInputItem  `json:"input"`
	Output      map[string]*ActionOutputItem `json:"output"`
	Display     string                       `json:"display"`
	Description string                       `json:"description"`
	Aggregation []ActionAggregateItem        `json:"aggregate"`

	sync.Mutex
	// contains filtered or unexported fields
}

Action describes an individual action in an agent

func (*Action) AggregateResult

func (a *Action) AggregateResult(result map[string]interface{}) error

AggregateResult receives a result and aggregate all the data found in it, most errors are squashed since aggregation are called during processing of replies and we do not want to fail a reply just because aggregation failed, thus this is basically a best efforts kind of thing on purpose

func (*Action) AggregateResultJSON

func (a *Action) AggregateResultJSON(jres []byte) error

AggregateResultJSON receives a JSON reply and aggregate all the data found in it

func (*Action) AggregateSummaryFormattedStrings

func (a *Action) AggregateSummaryFormattedStrings() (map[string][]string, error)

AggregateSummaryFormattedStrings produce a formatted string for each output item that has a aggregate summary defined

func (*Action) AggregateSummaryJSON

func (a *Action) AggregateSummaryJSON() ([]byte, error)

AggregateSummaryJSON produce a JSON representation of aggregate results for every output item that has a aggregate summary defined

func (*Action) AggregateSummaryStrings

func (a *Action) AggregateSummaryStrings() (map[string]map[string]string, error)

AggregateSummaryStrings produce a map of results for every output item that has a aggregate summary defined

func (*Action) InputNames

func (a *Action) InputNames() (names []string)

InputNames retrieves all valid input names

func (*Action) RequiresInput

func (a *Action) RequiresInput(input string) bool

RequiresInput reports if an input is required

func (*Action) ValidateAndConvertToDDLTypes

func (a *Action) ValidateAndConvertToDDLTypes(args map[string]string) (result map[string]interface{}, warnings []string, err error)

ValidateAndConvertToDDLTypes takes a map of strings like you might receive from the CLI, convert each item to the correct type according to the DDL type hints, validates its valid according to the DDL hints and returns a map of interface{} ready for conversion to JSON that would then have the correct types

func (*Action) ValidateInputString

func (a *Action) ValidateInputString(input string, val string) error

ValidateInputString attempts to convert a string to the correct type and validate it based on the DDL spec

func (*Action) ValidateInputValue

func (a *Action) ValidateInputValue(input string, val interface{}) (warnings []string, err error)

ValidateInputValue validates the input matches requirements in the DDL

type ActionAggregateItem

type ActionAggregateItem struct {
	Function  string          `json:"function"`
	Arguments json.RawMessage `json:"args"`
}

ActionAggregateItem describes a aggregate function to summarize data

type ActionInputItem

type ActionInputItem struct {
	Prompt      string      `json:"prompt"`
	Description string      `json:"description"`
	Type        string      `json:"type"`
	Default     interface{} `json:"default"`
	Optional    bool        `json:"optional"`
	Validation  string      `json:"validation"`
	MaxLength   int         `json:"maxlength"`
	Enum        []string    `json:"list"`
}

ActionInputItem describes an individual input item

type ActionOutputItem

type ActionOutputItem struct {
	Description string      `json:"description"`
	DisplayAs   string      `json:"display_as"`
	Default     interface{} `json:"default"`
}

ActionOutputItem describes an individual output item

type DDL

type DDL struct {
	Schema   string           `json:"$schema"`
	Metadata *agents.Metadata `json:"metadata"`
	Actions  []*Action        `json:"actions"`
}

DDL represents the schema of a mcorpc agent and is at a basic level compatible with the mcollective agent ddl format

func Find

func Find(agent string, libdirs []string) (ddl *DDL, err error)

Find looks in the supplied libdirs for a DDL file for a specific agent

func New

func New(file string) (*DDL, error)

New creates a new DDL from a JSON file

func (*DDL) ActionInterface

func (d *DDL) ActionInterface(action string) (*Action, error)

ActionInterface looks up an Action by name

func (*DDL) ActionNames

func (d *DDL) ActionNames() []string

ActionNames is a list of known actions defined by a DDL

func (*DDL) HaveAction

func (d *DDL) HaveAction(action string) bool

HaveAction determines if an action is known

func (*DDL) Timeout

func (d *DDL) Timeout() time.Duration

Timeout is the timeout for this agent

func (*DDL) ValidateAndConvertToDDLTypes

func (d *DDL) ValidateAndConvertToDDLTypes(action string, args map[string]string) (result map[string]interface{}, warnings []string, err error)

ValidateAndConvertToDDLTypes converts args to the correct data types as declared in the DDL and validates everything