objectset

Documentation

Index

• Constants
• type Client
• type DesiredSet
  • func (o *DesiredSet) AddInjector(inj injectors.ConfigInjector)
  • func (o *DesiredSet) Apply() error
  • func (o *DesiredSet) Err() error
• type ObjectSet
  • func NewObjectSet() *ObjectSet
  • func (o *ObjectSet) Add(objs ...runtime.Object) *ObjectSet
  • func (o *ObjectSet) AddErr(err error)
  • func (o *ObjectSet) AddInput(objs ...runtime.Object) *ObjectSet
  • func (o *ObjectSet) Err() error
• type Processor
  • func NewProcessor(setID string) *Processor
  • func (t *Processor) AllowDiscovery(discovery discovery.DiscoveryInterface, restConfig rest.Config) *Processor
  • func (t *Processor) Client(clients ...Client) *Processor
  • func (t *Processor) CodeVersion(version string) *Processor
  • func (t Processor) NewDesiredSet(owner runtime.Object, objs *ObjectSet) *DesiredSet
  • func (t Processor) Remove(owner runtime.Object) error
  • func (t *Processor) SetID() string

Constants

const (
	LabelID        = "objectset.rio.cattle.io/id"
	LabelGVK       = "objectset.rio.cattle.io/owner-gvk"
	LabelName      = "objectset.rio.cattle.io/owner-name"
	LabelNamespace = "objectset.rio.cattle.io/owner-namespace"
	LabelHash      = "objectset.rio.cattle.io/hash"
)

const (
	LabelApplied = "objectset.rio.cattle.io/applied"
	LabelInputID = "objectset.rio.cattle.io/inputid"
)

Types

type Client

type Client interface {
	Generic() controller.GenericController
	ObjectClient() *objectclient.ObjectClient
}

type DesiredSet

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

func (*DesiredSet) AddInjector

func (o *DesiredSet) AddInjector(inj injectors.ConfigInjector)

func (*DesiredSet) Apply

func (o *DesiredSet) Apply() error

func (*DesiredSet) Err

func (o *DesiredSet) Err() error

type ObjectSet

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

func NewObjectSet

func NewObjectSet() *ObjectSet

func (*ObjectSet) Add

func (o *ObjectSet) Add(objs ...runtime.Object) *ObjectSet

func (*ObjectSet) AddErr

func (o *ObjectSet) AddErr(err error)

func (*ObjectSet) AddInput

func (o *ObjectSet) AddInput(objs ...runtime.Object) *ObjectSet

func (*ObjectSet) Err

func (o *ObjectSet) Err() error

type Processor

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

func NewProcessor

func NewProcessor(setID string) *Processor

func (*Processor) AllowDiscovery

func (t *Processor) AllowDiscovery(discovery discovery.DiscoveryInterface, restConfig rest.Config) *Processor

func (*Processor) Client

func (t *Processor) Client(clients ...Client) *Processor

func (*Processor) CodeVersion

func (t *Processor) CodeVersion(version string) *Processor

func (Processor) NewDesiredSet

func (t Processor) NewDesiredSet(owner runtime.Object, objs *ObjectSet) *DesiredSet

func (Processor) Remove

func (t Processor) Remove(owner runtime.Object) error

func (*Processor) SetID

func (t *Processor) SetID() string