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 EnsureFuncGoroutine(ensure 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 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 EnsureFuncGoroutine

func EnsureFuncGoroutine(ensure 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) error

func QueryFuncGoroutine

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

type IPAddress

type IPAddress string

func (IPAddress) Validate

func (i IPAddress) Validate() error

type QueryFunc

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