overlays

Documentation

Index

• Variables
• type Condition
• type DocumentQueries
• type DocumentQuery
• type OnMissing
• type Overlay
  • func (o *Overlay) Apply(n *yaml.Node) error
  • func (o *Overlay) CheckDocumentIndex(current int) bool
  • func (o *Overlay) UnmarshalYAML(value *yaml.Node) error
• type Queries
  • func (mq *Queries) Find(node *yaml.Node) []*yaml.Node
  • func (mq *Queries) Paths() []string
  • func (mq *Queries) Set(val string) error
  • func (mq Queries) String() string
  • func (mq *Queries) Type() string
  • func (mq *Queries) UnmarshalYAML(value *yaml.Node) error
• type Query
  • func (q *Query) Find(node *yaml.Node) []*yaml.Node
  • func (q Query) String() string
  • func (q *Query) UnmarshalYAML(value *yaml.Node) error
• type WorkStream
  • func NewWorkStream() *WorkStream
  • func (s *WorkStream) AddWorkload(o *Overlay, n *yaml.Node, nodeIndex int, path string)
  • func (s *WorkStream) CloseStream()
  • func (s *WorkStream) StartHandler() error
  • func (s *WorkStream) StartStream()

Variables

var (
	// ErrOnMissingNoInjectAction occurrs if there are not matches found and no inject action present.
	ErrOnMissingNoInjectAction = errors.New("no matches and no onMissing.action of 'inject'")

	// ErrOnMissingNoInjectPath occurrs if there are no matches found for the injectPath.
	ErrOnMissingNoInjectPath = errors.New("no matches and no onMissing.injectPath")
)

Types

type Condition

type Condition struct {
	Query Queries   `yaml:"query,omitempty"`
	Value yaml.Node `yaml:"value,omitempty"`
}

type DocumentQueries

type DocumentQueries []*DocumentQuery

type DocumentQuery

type DocumentQuery struct {
	Conditions []*Condition `yaml:"conditions,omitempty"`
}

type OnMissing

type OnMissing struct {
	Action     actions.OnMissingAction `yaml:"action,omitempty"`
	InjectPath Queries                 `yaml:"injectPath,omitempty"`
}

type Overlay

type Overlay struct {
	Name          string          `yaml:"name,omitempty"`
	Query         Queries         `yaml:"query,omitempty"`
	Value         yaml.Node       `yaml:"value,omitempty"`
	Action        actions.Action  `yaml:"action,omitempty"`
	DocumentQuery DocumentQueries `yaml:"documentQuery,omitempty"`
	OnMissing     OnMissing       `yaml:"onMissing,omitempty"`
	DocumentIndex []int           `yaml:"documentIndex,omitempty"`
}

func (*Overlay) Apply

func (o *Overlay) Apply(n *yaml.Node) error

func (*Overlay) CheckDocumentIndex

func (o *Overlay) CheckDocumentIndex(current int) bool

func (*Overlay) UnmarshalYAML

func (o *Overlay) UnmarshalYAML(value *yaml.Node) error

type Queries

type Queries []Query

func (*Queries) Find

func (mq *Queries) Find(node *yaml.Node) []*yaml.Node

func (*Queries) Paths

func (mq *Queries) Paths() []string

func (*Queries) Set

func (mq *Queries) Set(val string) error

func (Queries) String

func (mq Queries) String() string

func (*Queries) Type

func (mq *Queries) Type() string

func (*Queries) UnmarshalYAML

func (mq *Queries) UnmarshalYAML(value *yaml.Node) error

type Query

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

func (*Query) Find

func (q *Query) Find(node *yaml.Node) []*yaml.Node

func (Query) String

func (q Query) String() string

func (*Query) UnmarshalYAML

func (q *Query) UnmarshalYAML(value *yaml.Node) error

type WorkStream

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

func NewWorkStream

func NewWorkStream() *WorkStream

func (*WorkStream) AddWorkload

func (s *WorkStream) AddWorkload(o *Overlay, n *yaml.Node, nodeIndex int, path string)

func (*WorkStream) CloseStream

func (s *WorkStream) CloseStream()

func (*WorkStream) StartHandler

func (s *WorkStream) StartHandler() error

func (*WorkStream) StartStream

func (s *WorkStream) StartStream()