Documentation ¶ Index ¶ type Plugin func New(o PluginOptions) *Plugin func (p *Plugin) Init(ctx context.Context, c *astikit.Closer, f *astiflow.Flow) error func (p *Plugin) Metadata() astiflow.Metadata func (p *Plugin) Start(ctx context.Context, tc astikit.TaskCreator) type PluginOptions Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ This section is empty. Types ¶ type Plugin ¶ type Plugin struct { // contains filtered or unexported fields } func New ¶ func New(o PluginOptions) *Plugin func (*Plugin) Init ¶ func (p *Plugin) Init(ctx context.Context, c *astikit.Closer, f *astiflow.Flow) error func (*Plugin) Metadata ¶ func (p *Plugin) Metadata() astiflow.Metadata func (*Plugin) Start ¶ func (p *Plugin) Start(ctx context.Context, tc astikit.TaskCreator) type PluginOptions ¶ type PluginOptions struct { DeltaPeriod time.Duration Path string } Source Files ¶ View all Source files plugin.go Click to show internal directories. Click to hide internal directories.