ruby

Documentation

Index

• func ChoriaPlugin() plugin.Pluggable
• func NewRubyAgent(ddl *agent.DDL, mgr server.AgentManager) (*mcorpc.Agent, error)
• type Provider
  • func (p *Provider) Agents() []*agent.DDL
  • func (p *Provider) Initialize(cfg *config.Config, log *logrus.Entry)
  • func (p *Provider) PluginInstance() any
  • func (p *Provider) PluginName() string
  • func (p *Provider) PluginType() inter.PluginType
  • func (p *Provider) PluginVersion() string
  • func (p *Provider) RegisterAgents(ctx context.Context, mgr server.AgentManager, connector inter.AgentConnector, ...) error
  • func (p *Provider) Version() string
• type ShimRequest
• type ShimRequestBody

Functions

func ChoriaPlugin

func ChoriaPlugin() plugin.Pluggable

ChoriaPlugin produces the plugin for choria

func NewRubyAgent

func NewRubyAgent(ddl *agent.DDL, mgr server.AgentManager) (*mcorpc.Agent, error)

NewRubyAgent creates a shim agent that calls to a old mcollective agent implemented in ruby

Types

type Provider

type Provider struct {
	// contains filtered or unexported fields
}

Provider is a Agent Provider capable of executing old mcollective ruby agents

func (*Provider) Agents

func (p *Provider) Agents() []*agent.DDL

Agents provides a list of loaded agent DDLs

func (*Provider) Initialize

func (p *Provider) Initialize(cfg *config.Config, log *logrus.Entry)

Initialize configures the agent provider

func (*Provider) PluginInstance

func (p *Provider) PluginInstance() any

PluginInstance implements plugin.Pluggable

func (*Provider) PluginName

func (p *Provider) PluginName() string

PluginName implements plugin.Pluggable

func (*Provider) PluginType

func (p *Provider) PluginType() inter.PluginType

PluginType implements plugin.Pluggable

func (*Provider) PluginVersion

func (p *Provider) PluginVersion() string

PluginVersion implements plugin.Pluggable

func (*Provider) RegisterAgents

func (p *Provider) RegisterAgents(ctx context.Context, mgr server.AgentManager, connector inter.AgentConnector, log *logrus.Entry) error

RegisterAgents registers known ruby agents using a shimm agent

func (*Provider) Version

func (p *Provider) Version() string

Version reports the version for this provider

type ShimRequest

type ShimRequest struct {
	Agent      string           `json:"agent"`
	Action     string           `json:"action"`
	RequestID  string           `json:"requestid"`
	SenderID   string           `json:"senderid"`
	CallerID   string           `json:"callerid"`
	Collective string           `json:"collective"`
	TTL        int              `json:"ttl"`
	Time       int64            `json:"msgtime"`
	Body       *ShimRequestBody `json:"body"`
}

ShimRequest is the request being published to the shim runner

type ShimRequestBody

type ShimRequestBody struct {
	Agent  string          `json:"agent"`
	Action string          `json:"action"`
	Data   json.RawMessage `json:"data"`
	Caller string          `json:"caller"`
}

ShimRequestBody is the body passed to the