orbiter

package
v0.32.11 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 15, 2020 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Adapt added in v0.25.0

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

func AdaptFuncGoroutine added in v0.20.4

func Destroy

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

func DestroyFuncGoroutine added in v0.20.4

func DestroyFuncGoroutine(query func() error) error

func Metrics added in v0.21.0

func Metrics()

func NoopConfigure added in v0.25.0

func NoopConfigure(orb orbconfig.Orb) error

func NoopDestroy added in v0.25.0

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, map[string]*secret.Secret, 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 added in v0.21.0

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

type ConfigureFunc added in v0.25.0

type ConfigureFunc func(orb orbconfig.Orb) error

type DestroyFunc

type DestroyFunc func() error

type EnsureFunc

type EnsureFunc func(pdf api.PushDesiredFunc) *EnsureResult

func QueryFuncGoroutine added in v0.20.4

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

type EnsureResult added in v0.22.0

type EnsureResult struct {
	Err  error
	Done bool
}

func EnsureFuncGoroutine added in v0.20.4

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

func NoopEnsure added in v0.25.0

func NoopEnsure(_ api.PushDesiredFunc) *EnsureResult

func ToEnsureResult added in v0.22.0

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL