external

Documentation

Index

• func ChoriaPlugin() plugin.Pluggable
• type ActivationCheck
• type ActivationReply
• 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 Request

Functions

func ChoriaPlugin

func ChoriaPlugin() plugin.Pluggable

ChoriaPlugin produces the plugin for choria

Types

type ActivationCheck

type ActivationCheck struct {
	Schema   string `json:"$schema"`
	Protocol string `json:"protocol"`
	Agent    string `json:"agent"`
}

ActivationCheck is the request to determine if an agent should activate

type ActivationReply

type ActivationReply struct {
	ShouldActivate bool `json:"activate"`
}

ActivationReply is the reply from the activation check message

type Provider

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

Provider is a Choria Agent Provider that supports calling agents external to the choria process written in any language

func (*Provider) Agents

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

Agents provides a list of loaded agent DDLs

func (*Provider) Initialize

func (p *Provider) Initialize(fw *choria.Framework, log *logrus.Entry)

Initialize configures the agent provider

func (*Provider) PluginInstance

func (p *Provider) PluginInstance() interface{}

PluginInstance implements plugin.Pluggable

func (*Provider) PluginName

func (p *Provider) PluginName() string

PluginName implements plugin.Pluggable

func (*Provider) PluginType

func (p *Provider) PluginType() plugin.Type

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 choria.InstanceConnector, 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 Request

type Request struct {
	Schema     string          `json:"$schema"`
	Protocol   string          `json:"protocol"`
	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"`
	Data       json.RawMessage `json:"data"`
}

Request is the request being published to the shim runner