command

Nov 30, 2025

Changes in this version

type Config

+ func (c *Config) Merge(project *Config)

Nov 25, 2025

Changes in this version

type Commander

+ GetPath func() string

type Runner

+ func (cr *Runner) GetPath() string

type Static

+ func (rg *Static) GetPath() string

Aug 25, 2025

Changes in this version

+ type Commander interface

+ Configure func(opts ...RunnerOpt) error

+ ConfigureContext func(ctx context.Context, opts ...RunnerOpt) error

+ FS func() (*FilteredFS, error)

+ FindProfiles func(path string) ([]ProfileMatch, error)

+ GetCurrentProfile func() (string, *profile.Profile)

+ GetProfiles func() map[string]*profile.Profile

+ Run func() Output

+ RunContext func(ctx context.Context) Output

+ RunOnEvent func()

+ RunPlugin func(name string) Output

+ RunPluginContext func(ctx context.Context, name string) Output

+ SendEvent func(evt Event)

+ String func() string

+ Subscribe func(ch chan<- Event)

type Event

+ GetContext func() context.Context

type EventCancel

+ func NewEventCancel(ctx context.Context) EventCancel

+ func (e EventCancel) GetContext() context.Context

+ type EventConfigure struct

+ func NewEventConfigure(ctx context.Context) EventConfigure

+ func (e EventConfigure) GetContext() context.Context

type EventEnd

+ Output Output

+ func NewEventEnd(ctx context.Context, output Output) EventEnd

+ func (e EventEnd) GetContext() context.Context

+ type EventListResources struct

+ func NewEventListResources(ctx context.Context) EventListResources

+ func (e EventListResources) GetContext() context.Context

+ type EventOpenResource struct

+ Resource kube.Resource

+ func NewEventOpenResource(ctx context.Context, resource kube.Resource) EventOpenResource

+ func (e EventOpenResource) GetContext() context.Context

type EventStart

+ Type Type

+ func NewEventStart(ctx context.Context, t Type) EventStart

+ func (e EventStart) GetContext() context.Context

+ type FilteredFS struct

+ func NewFilteredFS(root RootFS, rules ...*rule.Rule) (*FilteredFS, error)

+ func NewFilteredFSFromPath(dirPath string, rules ...*rule.Rule) (*FilteredFS, error)

+ func (f *FilteredFS) Close() error

+ func (f *FilteredFS) Name() string

+ func (f *FilteredFS) Open(name string) (*os.File, error)

+ func (f *FilteredFS) OpenFile(name string, flag int, perm fs.FileMode) (*os.File, error)

+ func (f *FilteredFS) ReadDir(name string) ([]os.DirEntry, error)

+ func (f *FilteredFS) Stat(name string) (fs.FileInfo, error)

type Output

+ Timestamp time.Time

+ func NewOutput(t Type, opts ...OutputOpt) Output

+ type OutputOpt func(*Output)

+ func WithError(err error) OutputOpt

+ type ProfileMatch struct

+ Name string

+ Profile *profile.Profile

+ type RootFS interface

+ Close func() error

+ FS func() fs.FS

+ Name func() string

+ Open func(name string) (*os.File, error)

+ OpenFile func(name string, flag int, perm os.FileMode) (*os.File, error)

+ Remove func(name string) error

+ Stat func(name string) (os.FileInfo, error)

type Runner

+ func NewRunnerWithRoot(root RootFS, path string, opts ...RunnerOpt) (*Runner, error)

+ func (cr *Runner) Configure(opts ...RunnerOpt) error

+ func (cr *Runner) ConfigureContext(ctx context.Context, opts ...RunnerOpt) error

+ func (cr *Runner) FS() (*FilteredFS, error)

+ func (cr *Runner) FindProfile(path string) (string, *profile.Profile, error)

+ func (cr *Runner) FindProfiles(path string) ([]ProfileMatch, error)

+ func (cr *Runner) GetProfiles() map[string]*profile.Profile

+ func (cr *Runner) SendEvent(evt Event)

+ func (cr *Runner) SetProfile(name string) error

type RunnerOpt

+ func WithAutoProfile() RunnerOpt

+ func WithCustomProfile(name string, p *profile.Profile) RunnerOpt

+ func WithExtraArgs(args ...string) RunnerOpt

+ func WithPath(path string) RunnerOpt

+ func WithProfiles(profiles map[string]*profile.Profile) RunnerOpt

+ func WithWatch(watch bool) RunnerOpt

+ func WithWatcherBatchDuration(dur time.Duration) RunnerOpt

type Static

+ func (rg *Static) Configure(_ ...RunnerOpt) error

+ func (rg *Static) ConfigureContext(_ context.Context, _ ...RunnerOpt) error

+ func (rg *Static) FS() (*FilteredFS, error)

+ func (rg *Static) FindProfile(_ string) (string, *profile.Profile, error)

+ func (rg *Static) FindProfiles(_ string) ([]ProfileMatch, error)

+ func (rg *Static) GetProfiles() map[string]*profile.Profile

+ func (rg *Static) GetRules() []*rule.Rule

+ func (rg *Static) RunContext(ctx context.Context) Output

+ func (rg *Static) RunPluginContext(ctx context.Context, _ string) Output

+ func (rg *Static) SendEvent(evt Event)

Jul 20, 2025

Changes in this version

type Runner

+ func (cr *Runner) SetExtraArgs(args []string) error

Jun 29, 2025

Changes in this version

+ var DefaultConfig = MustNewConfig(defaultProfiles, defaultRules)

+ var ErrCommandExecution = errors.New("command execution")

+ var ErrEmptyCommand = errors.New("empty command")

+ var ErrHookExecution = errors.New("hook execution")

+ var ErrNoCommandForPath = errors.New("no command for path")

+ type Config struct

+ Profiles map[string]*profile.Profile

+ Rules []*rule.Rule

+ func MustNewConfig(ps map[string]*profile.Profile, rs []*rule.Rule) *Config

+ func NewConfig(ps map[string]*profile.Profile, rs []*rule.Rule) (*Config, error)

+ func (c *Config) EnsureDefaults()

+ func (c *Config) Validate() *ConfigError

+ type ConfigError struct

+ Err error

+ Path *yaml.Path

+ func (e ConfigError) Error() string

+ type Event any

+ type EventCancel struct

+ type EventEnd Output

+ type EventStart Type

+ type Output struct

+ Error error

+ Resources []*kube.Resource

+ Stderr string

+ Stdout string

+ Type Type

+ type Runner struct

+ func NewRunner(path string, opts ...RunnerOpt) (*Runner, error)

+ func (cr *Runner) Close()

+ func (cr *Runner) GetCurrentProfile() *profile.Profile

+ func (cr *Runner) Run() Output

+ func (cr *Runner) RunContext(ctx context.Context) Output

+ func (cr *Runner) RunOnEvent()

+ func (cr *Runner) RunPlugin(name string) Output

+ func (cr *Runner) RunPluginContext(ctx context.Context, name string) Output

+ func (cr *Runner) String() string

+ func (cr *Runner) Subscribe(ch chan<- Event)

+ func (cr *Runner) Watch() error

+ type RunnerOpt func(cr *Runner) error

+ func WithProfile(name string, p *profile.Profile) RunnerOpt

+ func WithRules(rs []*rule.Rule) RunnerOpt

+ type Static struct

+ Resources []*kube.Resource

+ func NewStatic(input string) (*Static, error)

+ func (rg *Static) Close()

+ func (rg *Static) GetCurrentProfile() *profile.Profile

+ func (rg *Static) Run() Output

+ func (rg *Static) RunOnEvent()

+ func (rg *Static) RunPlugin(_ string) Output

+ func (rg *Static) String() string

+ func (rg *Static) Subscribe(ch chan<- Event)

+ type Type int

+ const TypePlugin

+ const TypeRun