orbiter

Documentation

Index

• func Adapt(gitClient *git.Client, monitor mntr.Monitor, finished chan struct{}, ...) (QueryFunc, DestroyFunc, ConfigureFunc, bool, *tree.Tree, *tree.Tree, error)
• func AdaptFuncGoroutine(adapt func() (QueryFunc, DestroyFunc, ConfigureFunc, bool, error)) (QueryFunc, DestroyFunc, ConfigureFunc, bool, error)
• func Destroy(monitor mntr.Monitor, gitClient *git.Client, adapt AdaptFunc, ...) error
• func DestroyFuncGoroutine(query func() error) error
• func Metrics()
• func NoopConfigure(orb orbconfig.Orb) error
• func NoopDestroy() 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 ConfigureFunc
• type DestroyFunc
• type EnsureFunc
  • func QueryFuncGoroutine(query func() (EnsureFunc, error)) (EnsureFunc, error)
• type EnsureResult
  • func EnsureFuncGoroutine(ensure func() *EnsureResult) *EnsureResult
  • func NoopEnsure(_ api.PushDesiredFunc) *EnsureResult
  • func ToEnsureResult(done bool, err error) *EnsureResult
• type IPAddress
  • func (i IPAddress) Validate() error
• type QueryFunc

Functions

func Adapt

func Adapt(gitClient *git.Client, monitor mntr.Monitor, finished chan struct{}, adapt AdaptFunc) (QueryFunc, DestroyFunc, ConfigureFunc, bool, *tree.Tree, *tree.Tree, error)

func AdaptFuncGoroutine

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

func Destroy

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

func DestroyFuncGoroutine

func DestroyFuncGoroutine(query func() error) error

func Metrics

func Metrics()

func NoopConfigure

func NoopConfigure(orb orbconfig.Orb) error

func NoopDestroy

func NoopDestroy() error

func Takeoff

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

Types

type AdaptFunc

type AdaptFunc func(monitor mntr.Monitor, finishedChan chan struct{}, desired *tree.Tree, current *tree.Tree) (QueryFunc, DestroyFunc, ConfigureFunc, 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 struct{}
	PushEvents    func(events []*ingestion.EventRequest) error
	OrbConfig     orb.Orb
}

type ConfigureFunc

type ConfigureFunc func(orb orbconfig.Orb) error

type DestroyFunc

type DestroyFunc func() error

type EnsureFunc

type EnsureFunc func(pdf api.PushDesiredFunc) *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 NoopEnsure

func NoopEnsure(_ api.PushDesiredFunc) *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)