plugin

Documentation

Index

• Variables
• func Call(ctx context.Context, ps types.PlugScope, req *pluginapi.Request) (resp *pluginapi.Response, err error)
• func Init(svc buildin.Services, cfg config.Loader) error
• func MustShutdown()
• func Register(spec types.PluginSpec, builder Builder)
• func SourceInfo(ctx context.Context, ps types.PlugScope) (info string, err error)
• type Builder
• type DelayProcessPlugin
  • func (d *DelayProcessPlugin) Name() string
  • func (d *DelayProcessPlugin) Run(ctx context.Context, request *pluginapi.Request) (*pluginapi.Response, error)
  • func (d *DelayProcessPlugin) Type() types.PluginType
  • func (d *DelayProcessPlugin) Version() string
• type Plugin
  • func BuildPlugin(ctx context.Context, ps types.PlugScope) (Plugin, error)
• type ProcessPlugin
• type SourcePlugin
• type ThreeBodyPlugin
  • func (d *ThreeBodyPlugin) Name() string
  • func (d *ThreeBodyPlugin) Run(ctx context.Context, request *pluginapi.Request) (*pluginapi.Response, error)
  • func (d *ThreeBodyPlugin) SourceInfo() (string, error)
  • func (d *ThreeBodyPlugin) Type() types.PluginType
  • func (d *ThreeBodyPlugin) Version() string

Variables

var (
	ErrNotFound = errors.New("PluginNotFound")
)

Functions

func Call

func Call(ctx context.Context, ps types.PlugScope, req *pluginapi.Request) (resp *pluginapi.Response, err error)

func Init

func Init(svc buildin.Services, cfg config.Loader) error

func MustShutdown

func MustShutdown()

func Register

func Register(spec types.PluginSpec, builder Builder)

func SourceInfo

func SourceInfo(ctx context.Context, ps types.PlugScope) (info string, err error)

Types

type Builder

type Builder func(ctx context.Context, spec types.PluginSpec, scope types.PlugScope) (Plugin, error)

type DelayProcessPlugin

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

func (*DelayProcessPlugin) Name

func (d *DelayProcessPlugin) Name() string

func (*DelayProcessPlugin) Run

func (d *DelayProcessPlugin) Run(ctx context.Context, request *pluginapi.Request) (*pluginapi.Response, error)

func (*DelayProcessPlugin) Type

func (d *DelayProcessPlugin) Type() types.PluginType

func (*DelayProcessPlugin) Version

func (d *DelayProcessPlugin) Version() string

type Plugin

type Plugin interface {
	Name() string
	Type() types.PluginType
	Version() string
}

func BuildPlugin

func BuildPlugin(ctx context.Context, ps types.PlugScope) (Plugin, error)

type ProcessPlugin

type ProcessPlugin interface {
	Plugin
	Run(ctx context.Context, request *pluginapi.Request) (*pluginapi.Response, error)
}

type SourcePlugin

type SourcePlugin interface {
	ProcessPlugin
	SourceInfo() (string, error)
}

type ThreeBodyPlugin

type ThreeBodyPlugin struct{}

func (*ThreeBodyPlugin) Name

func (d *ThreeBodyPlugin) Name() string

func (*ThreeBodyPlugin) Run

func (d *ThreeBodyPlugin) Run(ctx context.Context, request *pluginapi.Request) (*pluginapi.Response, error)

func (*ThreeBodyPlugin) SourceInfo

func (d *ThreeBodyPlugin) SourceInfo() (string, error)

func (*ThreeBodyPlugin) Type

func (d *ThreeBodyPlugin) Type() types.PluginType

func (*ThreeBodyPlugin) Version

func (d *ThreeBodyPlugin) Version() string