runtime

Documentation

Index

• Variables
• type Client
• type Factory
  • func NewFactory(opts FactoryOptions) *Factory
  • func (f *Factory) Start(ctx context.Context, spec PluginSpec, opts StartOptions) (Client, error)
• type FactoryOptions
• type OpError
  • func (e *OpError) Error() string
  • func (e *OpError) Is(target error) bool
• type PluginSpec
• type RequestMeta
• type StartOptions

Variables

var ErrUnsupported = errors.New(protocol.ErrUnsupported)

Types

type Client

type Client interface {
	Spec() PluginSpec
	Handshake() protocol.Handshake
	SupportsOp(op string) bool
	Call(ctx context.Context, op string, input any, output any) error
	StartStream(ctx context.Context, op string, input any) (streamID string, events <-chan protocol.Event, err error)
	Close(ctx context.Context) error
}

type Factory

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

func NewFactory

func NewFactory(opts FactoryOptions) *Factory

func (*Factory) Start

func (f *Factory) Start(ctx context.Context, spec PluginSpec, opts StartOptions) (Client, error)

type FactoryOptions

type FactoryOptions struct {
	HandshakeTimeout time.Duration
	ShutdownTimeout  time.Duration
}

type OpError

type OpError struct {
	PluginID string
	Op       string
	Code     string
	Message  string
	Details  map[string]any
}

func (*OpError) Error

func (e *OpError) Error() string

func (*OpError) Is

func (e *OpError) Is(target error) bool

type PluginSpec

type PluginSpec struct {
	ID       string
	Path     string
	Args     []string
	Env      map[string]string
	WorkDir  string
	Priority int
}

type RequestMeta

type RequestMeta struct {
	RepoRoot string
	Cwd      string
	DryRun   bool
}

type StartOptions

type StartOptions struct {
	Meta RequestMeta
}