orbiter

Documentation

Index

• func AdaptFuncGoroutine(adapt func() (QueryFunc, DestroyFunc, bool, error)) (QueryFunc, DestroyFunc, bool, error)
• func Destroy(monitor mntr.Monitor, gitClient *git.Client, adapt AdaptFunc, ...) error
• func DestroyFuncGoroutine(query func() error) error
• func Metrics()
• func Parse(gitClient *git.Client, files ...string) (trees []*tree.Tree, err error)
• func Takeoff(monitor mntr.Monitor, conf *Config) func()
• type AdaptFunc
• type CIDR
  • func (c CIDR) Validate() error
• type CIDRs
  • func (c CIDRs) Len() int
  • func (c CIDRs) Less(i, j int) bool
  • func (c CIDRs) Swap(i, j int)
• type Config
• type DestroyFunc
• type EnsureFunc
  • func QueryFuncGoroutine(query func() (EnsureFunc, error)) (EnsureFunc, error)
• type EnsureResult
  • func EnsureFuncGoroutine(ensure func() *EnsureResult) *EnsureResult
  • func ToEnsureResult(done bool, err error) *EnsureResult
• type IPAddress
  • func (i IPAddress) Validate() error
• type QueryFunc

Functions

func AdaptFuncGoroutine

func AdaptFuncGoroutine(adapt func() (QueryFunc, DestroyFunc, bool, error)) (QueryFunc, DestroyFunc, bool, error)

func Destroy

func Destroy(monitor mntr.Monitor, gitClient *git.Client, adapt AdaptFunc, finishedChan chan bool) error

func DestroyFuncGoroutine

func DestroyFuncGoroutine(query func() error) error

func Metrics

func Metrics()

func Parse

func Parse(gitClient *git.Client, files ...string) (trees []*tree.Tree, err error)

func Takeoff

func Takeoff(monitor mntr.Monitor, conf *Config) func()

Types

type AdaptFunc

type AdaptFunc func(monitor mntr.Monitor, finishedChan chan bool, desired *tree.Tree, current *tree.Tree) (QueryFunc, DestroyFunc, bool, error)

type CIDR

type CIDR string

func (CIDR) Validate

func (c CIDR) Validate() error

type CIDRs

type CIDRs []*CIDR

func (CIDRs) Len

func (c CIDRs) Len() int

func (CIDRs) Less

func (c CIDRs) Less(i, j int) bool

func (CIDRs) Swap

func (c CIDRs) Swap(i, j int)

type Config

type Config struct {
	OrbiterCommit string
	GitClient     *git.Client
	Adapt         AdaptFunc
	FinishedChan  chan bool
	PushEvents    func(events []*ingestion.EventRequest) error
}

type DestroyFunc

type DestroyFunc func() error

type EnsureFunc

type EnsureFunc func(psf push.Func) *EnsureResult

func QueryFuncGoroutine

func QueryFuncGoroutine(query func() (EnsureFunc, error)) (EnsureFunc, error)

type EnsureResult

type EnsureResult struct {
	Err  error
	Done bool
}

func EnsureFuncGoroutine

func EnsureFuncGoroutine(ensure func() *EnsureResult) *EnsureResult

func ToEnsureResult

func ToEnsureResult(done bool, err error) *EnsureResult

type IPAddress

type IPAddress string

func (IPAddress) Validate

func (i IPAddress) Validate() error

type QueryFunc

type QueryFunc func(nodeAgentsCurrent *common.CurrentNodeAgents, nodeAgentsDesired *common.DesiredNodeAgents, queried map[string]interface{}) (EnsureFunc, error)