inline

Documentation

Index

• type Plugin
  • func New(opts ...func(*Plugin)) *Plugin
  • func (p *Plugin) Init(ctx context.Context, _ *proto.Job) error
  • func (p *Plugin) Name() string
  • func (p *Plugin) Plugin(_ context.Context, q *proto.P) any
  • func (p *Plugin) Step(context.Context) any
  • func (p *Plugin) Subscribe(context.Context) <-chan proto.Message
  • func (p *Plugin) WithProto(q *proto.P) *Plugin
• type Step
  • func (s *Step) Stop()

Types

type Plugin

type Plugin struct {
	wire.Config
	// contains filtered or unexported fields
}

func New

func New(opts ...func(*Plugin)) *Plugin

func (*Plugin) Init

func (p *Plugin) Init(ctx context.Context, _ *proto.Job) error

func (*Plugin) Name

func (p *Plugin) Name() string

func (*Plugin) Plugin

func (p *Plugin) Plugin(_ context.Context, q *proto.P) any

func (*Plugin) Step

func (p *Plugin) Step(context.Context) any

func (*Plugin) Subscribe

func (p *Plugin) Subscribe(context.Context) <-chan proto.Message

func (*Plugin) WithProto

func (p *Plugin) WithProto(q *proto.P) *Plugin

type Step

type Step struct {
	wire.Step `json:",inline"`
	// contains filtered or unexported fields
}

func (*Step) Stop

func (s *Step) Stop()