jortel

func (p *Provider) Watch() error {
	pc := property.DefaultCollector(p.client.Client)
	ospec := types.ObjectSpec{
		Obj: p.client.ServiceContent.RootFolder,
		Skip: types.NewBool(true),
		SelectSet: []types.BaseSelectionSpec{
			&types.TraversalSpec{
				SelectionSpec: types.SelectionSpec{
					Name: "traverseFolders",
				},

jortel

// IncompatibleGVKs
type IncompatibleGVKs struct {
	Namespaces []Namespace `json:"namespaces,omitempty"`
}
// Workload is a store for unhealthy resource and it's dependents
type GVK struct {
	Group      string   `json:"group"`
	Version      string   `json:"version"`
    Kind      string   `json:"kind"`
}

jortel

      type: service_account
      project_id: project_id_string
      private_key_id: private_key_id_string
      private_key: private_key_string
      client_email: client@example.com
      client_id: client_id_string
      auth_uri: http://example.com/auth_uri
      token_uri: http://example.com/token_uri
      auth_provider_x509_cert_url: http://example.com/provider_cert_url
      client_x509_cert_url: http://example.com/client_cert_url

jortel

time="2019-05-28T03:57:48Z" level=error msg="Error uploading log file" backup=test-x8tgb bucket=jortel-migration error="rpc error: code = Unknown desc = error putting object velero/backups/test-x8tgb/test-x8tgb-logs.gz: RequestTimeTooSkewed: The difference between the request time and the current time is too large.\n\tstatus code: 403, request id: 4AC72465AC8F37E1, host id: qt3HacrNW8zXxaKSILcROp+PP4iatrxjylGq5lbobTjwqbC5FZ2SH4I6Ks/iZAt7InonxXnikYY=" error.file="/go/src/github.com/heptio/velero/pkg/cloudprovider/aws/object_store.go:178" error.function="github.com/heptio/velero/pkg/cloudprovider/aws.(*ObjectStore).PutObject" logSource="pkg/persistence/object_store.go:171" prefix=velero
time="2019-05-28T03:57:48Z" level=error msg="reading plugin stderr" backup=velero/test-x8tgb cmd=/plugins/velero-plugins error="read |0: file already closed" logSource="pkg/plugin/clientmgmt/logrus_adapter.go:89" pluginName=velero-plugins
time="2019-05-28T03:57:48Z" level=error msg="backup failed" controller=backup error="rpc er

jortel

Suggest the Task report its "phase" instead of returning complete (bool).  This provides information to the caller to determine based on what's being watched vs polled whether a reconcile requeue is needed.  As a side benefit, the Task.Run() can consolidate logging.  By doing this, the responsibility of doing the requeue is delegated to the controller which understands reconciles and watches etc.  The Task simply reports a rich state.

-----------------------


// Phase
const (
    Created = "Created"
    RestartRestic = "RestartRestic"
    WaitingOnResticPod = "WaitingOnResticPod"

jortel

[jortel@f28a samples]$ oc status 
In project My Project (myproject) on server https://127.0.0.1:8443

deployment/test-deployment deploys nginx
  deployment #1 running for 2 minutes - 0/1 pods (warning: 4 restarts)

Errors:
  * pod/test-deployment-58ddd6d44b-rlxtx is crash-looping

1 error, 1 info identified, use 'oc status --suggest' to see details.

jortel

[jortel@f28a migration]$ kubebuilder init --domain openshit.io --license apache2 --owner redhat
Run `dep ensure` to fetch dependencies (Recommended) [y/n]?
y
dep ensure
Running make...
make
go generate ./pkg/... ./cmd/...
go fmt ./pkg/... ./cmd/...
go vet ./pkg/... ./cmd/...
go run vendor/sigs.k8s.io/controller-tools/cmd/controller-gen/main.go all

jortel

	kubernetes-1.9.0-beta.1: Could not introduce k8s.io/client-go@kubernetes-1.9.0-beta.1, as it is not allowed by constraint kubernetes-1.12.3 from project sigs.k8s.io/controller-tools.

jortel

https://github.com/jortel/gofer/blob/master/src/gofer/messaging/adapter/model.py#L711

Petty much like the Reader.
Need to configuration and plugin.refresh() done first.
Example assumes queue named pulp.qneeded and the message should probably be the plugin.cfg.messaging.uuid

---

from gofer.messaging import NotFound, Sender

jortel

[jortel@f26c ~]$ pulp-admin ostree repo sync run -h
Command: run
Description: triggers an immediate sync of a repository

Available Arguments:

  --bg      - if specified, the client process will end immediately (the task
              will continue to run on the server)
  --repo-id - (required) unique identifier; only alphanumeric, ., -, and _
              allowed