"rollingUpdate": {
        "maxUnavailable": "maxUnavailableValue",
        "maxSurge": "maxSurgeValue"
      }
    },
    "minReadySeconds": 5,
    "revisionHistoryLimit": 6,
    "paused": true,
    "progressDeadlineSeconds": 9
  },
  "status": {
    "observedGeneration": 1,
    "replicas": 2,
    "updatedReplicas": 3,
    "readyReplicas": 7,
    "availableReplicas": 4,

      "rollingUpdate": {
        "maxUnavailable": "maxUnavailableValue",
        "maxSurge": "maxSurgeValue"
      }
    },
    "minReadySeconds": 5,
    "revisionHistoryLimit": 6,
    "paused": true,
    "rollbackTo": {
      "revision": 1
    },
    "progressDeadlineSeconds": 9
  },
  "status": {
    "observedGeneration": 1,
    "replicas": 2,
    "updatedReplicas": 3,

      "rollingUpdate": {
        "maxUnavailable": "maxUnavailableValue",
        "maxSurge": "maxSurgeValue"
      }
    },
    "minReadySeconds": 5,
    "revisionHistoryLimit": 6,
    "paused": true,
    "rollbackTo": {
      "revision": 1
    },
    "progressDeadlineSeconds": 9
  },
  "status": {
    "observedGeneration": 1,
    "replicas": 2,
    "updatedReplicas": 3,

      "rollingUpdate": {
        "maxUnavailable": "maxUnavailableValue",
        "maxSurge": "maxSurgeValue"
      }
    },
    "minReadySeconds": 5,
    "revisionHistoryLimit": 6,
    "paused": true,
    "progressDeadlineSeconds": 9
  },
  "status": {
    "observedGeneration": 1,
    "replicas": 2,
    "updatedReplicas": 3,
    "readyReplicas": 7,
    "availableReplicas": 4,

      "rollingUpdate": {
        "maxUnavailable": "maxUnavailableValue",
        "maxSurge": "maxSurgeValue"
      }
    },
    "minReadySeconds": 5,
    "revisionHistoryLimit": 6,
    "paused": true,
    "progressDeadlineSeconds": 9
  },
  "status": {
    "observedGeneration": 1,
    "replicas": 2,
    "updatedReplicas": 3,
    "readyReplicas": 7,
    "availableReplicas": 4,

	cacheInterval, err = c.watchCache.getAllEventsSinceLocked(requiredResourceVersion, key, opts)
	if err != nil {
		// To match the uncached watch implementation, once we have passed authn/authz/admission,
		// and successfully parsed a resource version, other errors must fail with a watch event of type ERROR,
		// rather than a directly returned error.
		return newErrWatcher(err), nil
	}

	addedWatcher := false

}

// Release blocks until all work is passed on the chain
func (item *WorkChannelItem) Release() {
	item.lock.Lock()
	defer item.lock.Unlock()
	item.pause = false
	for i := 0; i < item.queue; i++ {
		item.out <- struct{}{}
	}
	item.queue = 0
}

// WorkChannel intercepts podWork channels between the pod worker and its child
// goroutines and allows tests to pause or release the flow of podWork to the

}

// takePragma returns the current parsed pragmas
// and clears them from the parser state.
func (p *parser) takePragma() Pragma {
	prag := p.pragma
	p.pragma = nil
	return prag
}

// clearPragma is called at the end of a statement or
// other Go form that does NOT accept a pragma.
// It sends the pragma back to the pragma handler
// to be reported as unused.
func (p *parser) clearPragma() {

// license that can be found in the LICENSE file.

// Package parser implements a parser for Go source files. Input may be
// provided in a variety of forms (see the various Parse* functions); the
// output is an abstract syntax tree (AST) representing the Go source. The
// parser is invoked through one of the Parse* functions.
//
// The parser accepts a larger language than is syntactically permitted by

// license that can be found in the LICENSE file.

// Package parser implements a parser for Go source files. Input may be
// provided in a variety of forms (see the various Parse* functions); the
// output is an abstract syntax tree (AST) representing the Go source. The
// parser is invoked through one of the Parse* functions.

package parser

import (
	"fmt"
	"go/ast"
	"go/scanner"
	"go/token"
)