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(fw *choria.Framework, log *logrus.Entry)
- func (p *Provider) PluginInstance() interface{}
- func (p *Provider) PluginName() string
- func (p *Provider) PluginType() plugin.Type
- func (p *Provider) PluginVersion() string
- func (p *Provider) RegisterAgents(ctx context.Context, mgr server.AgentManager, ...) error
- func (p *Provider) Version() string
- type ShimRequest
- type ShimRequestBody
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ChoriaPlugin ¶
ChoriaPlugin produces the plugin for choria
func NewRubyAgent ¶
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) Initialize ¶
Initialize configures the agent provider
func (*Provider) PluginInstance ¶
func (p *Provider) PluginInstance() interface{}
PluginInstance implements plugin.Pluggable
func (*Provider) PluginName ¶
PluginName implements plugin.Pluggable
func (*Provider) PluginType ¶
PluginType implements plugin.Pluggable
func (*Provider) PluginVersion ¶
PluginVersion implements plugin.Pluggable
func (*Provider) RegisterAgents ¶
func (p *Provider) RegisterAgents(ctx context.Context, mgr server.AgentManager, connector choria.InstanceConnector, log *logrus.Entry) error
RegisterAgents registers known ruby agents using a shimm agent
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
Source Files
Click to show internal directories.
Click to hide internal directories.