pipeline

Documentation

Index

• type ClassifyRuleConfig
• type ComposeRuleConfig
• type Config
• type DiscoveryConfig
• type HostSocketConfig
• type Pipeline
  • func New(cfg Config) (*Pipeline, error)
  • func (p *Pipeline) Run(ctx context.Context, in chan<- []*confgroup.Group)

Types

type ClassifyRuleConfig

type ClassifyRuleConfig struct {
	Name     string `yaml:"name"`
	Selector string `yaml:"selector"` // mandatory
	Tags     string `yaml:"tags"`     // mandatory
	Match    []struct {
		Tags string `yaml:"tags"` // mandatory
		Expr string `yaml:"expr"` // mandatory
	} `yaml:"match"` // mandatory, at least 1
}

type ComposeRuleConfig

type ComposeRuleConfig struct {
	Name     string `yaml:"name"`     // optional
	Selector string `yaml:"selector"` // mandatory
	Config   []struct {
		Selector string `yaml:"selector"` // mandatory
		Template string `yaml:"template"` // mandatory
	} `yaml:"config"` // mandatory, at least 1
}

type Config

type Config struct {
	Name      string               `yaml:"name"`
	Discovery DiscoveryConfig      `yaml:"discovery"`
	Classify  []ClassifyRuleConfig `yaml:"classify"`
	Compose   []ComposeRuleConfig  `yaml:"compose"` // TODO: "jobs"?
}

type DiscoveryConfig

type DiscoveryConfig struct {
	K8s        []kubernetes.Config `yaml:"k8s"`
	HostSocket HostSocketConfig    `yaml:"hostsocket"`
}

type HostSocketConfig

type HostSocketConfig struct {
	Net *hostsocket.NetworkSocketConfig `yaml:"net"`
}

type Pipeline

type Pipeline struct {
	*logger.Logger
	// contains filtered or unexported fields
}

func New

func New(cfg Config) (*Pipeline, error)

func (*Pipeline) Run

func (p *Pipeline) Run(ctx context.Context, in chan<- []*confgroup.Group)