ocp

Documentation

Index

• Constants
• type BaseCollection
  • func (r *BaseCollection) Bind(collector *Collector)
• type Cluster
• type Collection
• type Collector
  • func New(db libmodel.DB, cluster Cluster, secret *core.Secret, ...) *Collector
  • func (r *Collector) Client() client.Client
  • func (r *Collector) Create(m libmodel.Model)
  • func (r *Collector) DB() libmodel.DB
  • func (r *Collector) Delete(m libmodel.Model)
  • func (r *Collector) HasParity() bool
  • func (r *Collector) Name() string
  • func (r *Collector) Owner() meta.Object
  • func (r *Collector) Reconcile(request reconcile.Request) (reconcile.Result, error)
  • func (r *Collector) Reset()
  • func (r *Collector) Shutdown()
  • func (r *Collector) Start() error
  • func (r *Collector) Test() error
  • func (r *Collector) Update(m libmodel.Model)
  • func (r *Collector) UpdateThreshold(m libmodel.Model)
• type ModelEvent
  • func (r *ModelEvent) Apply(rl *Collector) (err error)
  • func (r ModelEvent) Create(m libmodel.Model) ModelEvent
  • func (r ModelEvent) Delete(m libmodel.Model) ModelEvent
  • func (r ModelEvent) Update(m libmodel.Model) ModelEvent

Constants

const (
	RetryDelay = time.Second * 5
)

Types

type BaseCollection

type BaseCollection struct {
	// Associated data collector.
	Collector *Collector
}

Base collection.

func (*BaseCollection) Bind

func (r *BaseCollection) Bind(collector *Collector)

Associate with a collector.

type Cluster

type Cluster interface {
	meta.Object
	// Build the REST configuration
	// for the remote cluster.
	RestCfg(*core.Secret) *rest.Config
}

Cluster.

type Collection

type Collection interface {
	predicate.Predicate
	// Bind to a collector.
	Bind(*Collector)
	// Get kubernetes resource object.
	Object() runtime.Object
	// Initial reconcile.
	Reconcile(context.Context) error
}

Resource collection.

type Collector

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

An OpenShift collector.

func New

func New(
	db libmodel.DB,
	cluster Cluster,
	secret *core.Secret,
	collections ...Collection) *Collector

New collector.

func (*Collector) Client

func (r *Collector) Client() client.Client

Get the Client.

func (*Collector) Create

func (r *Collector) Create(m libmodel.Model)

Enqueue create model event. Used by watch predicates. Swallow panic: send on closed channel.

func (*Collector) DB

func (r *Collector) DB() libmodel.DB

Get the DB.

func (*Collector) Delete

func (r *Collector) Delete(m libmodel.Model)

Enqueue delete model event. Used by watch predicates. Swallow panic: send on closed channel.

func (*Collector) HasParity

func (r *Collector) HasParity() bool

Collector has achieved parity.

func (*Collector) Name

func (r *Collector) Name() string

The name.

func (*Collector) Owner

func (r *Collector) Owner() meta.Object

The owner.

func (*Collector) Reconcile

func (r *Collector) Reconcile(request reconcile.Request) (reconcile.Result, error)

Never called.

func (*Collector) Reset

func (r *Collector) Reset()

Reset.

func (*Collector) Shutdown

func (r *Collector) Shutdown()

Shutdown the collector.

1. Close manager stop channel.
2. Close watch event coroutine channel.
3. Cancel the context.

func (*Collector) Start

func (r *Collector) Start() error

Start the collector.

func (*Collector) Test

func (r *Collector) Test() error

Test connection with credentials.

func (*Collector) Update

func (r *Collector) Update(m libmodel.Model)

Enqueue update model event. Used by watch predicates. Swallow panic: send on closed channel.

func (*Collector) UpdateThreshold

func (r *Collector) UpdateThreshold(m libmodel.Model)

Update the versionThreshold

type ModelEvent

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

Model event. Used with `eventChannel`.

func (*ModelEvent) Apply

func (r *ModelEvent) Apply(rl *Collector) (err error)

Apply the change to the DB.

func (ModelEvent) Create

func (r ModelEvent) Create(m libmodel.Model) ModelEvent

Set the event model and action.

func (ModelEvent) Delete

func (r ModelEvent) Delete(m libmodel.Model) ModelEvent

Set the event model and action.

func (ModelEvent) Update

func (r ModelEvent) Update(m libmodel.Model) ModelEvent

Set the event model and action.