driver

type Environment interface {
	// UniqueID returns a unique identifier for this Environment instance.
	UniqueID() string

	// HydrateObject ...
	HydrateObject(objData []byte) (*Object, error)
}

type Fixture struct {
	As string
}

type KubeClient struct {
	Config    *rest.Config // XXX(jpeach): remove this, it's only needed for init
	Client    *kubernetes.Clientset
	Dynamic   dynamic.Interface
	Discovery discovery.CachedDiscoveryInterface
}

type LockingResourceEventHandler struct {
	Next cache.ResourceEventHandler
	Lock sync.Mutex
}

type MuxingResourceEventHandler struct {
	Handlers map[int]cache.ResourceEventHandler
	// contains filtered or unexported fields
}

type Object struct {
	// Object is the object to apply.
	Object *unstructured.Unstructured

	// Check is a Rego check to run on the apply.
	Check *ast.Module

	// Operation specifies whether we are updating or deleting the object.
	Operation ObjectOperationType

	// Fixture specifies that we should replace this object with the corresponding fixture.
	Fixture *Fixture
}

type ObjectDriver interface {
	// Eval creates or updates the specified object.
	Apply(*unstructured.Unstructured) (*OperationResult, error)

	// Delete deleted the specified object.
	Delete(*unstructured.Unstructured) (*OperationResult, error)

	// Adopt tells the driver to take ownership of and to start tracking
	// the specified object. Any adopted objects will be included in a
	// DeleteAll operation.
	Adopt(*unstructured.Unstructured) error

	// DeleteAll deletes all the objects that have been adopted by this driver.
	DeleteAll() error

	// InformOn establishes an informer for the given resource.
	// Events received by this informer will be delivered to all
	// watchers.
	InformOn(gvr schema.GroupVersionResource) error

	// Watch registers an event handler to receive events from
	// all the informers managed by the driver.
	Watch(cache.ResourceEventHandler) func()

	// Done marks this driver session as complete. All informers
	// are released, watchers are unregistered and adopted objects
	// are forgotten.
	Done()
}

type ObjectOperationType string

type ObjectReference struct {
	Name      string `json:"name"`
	Namespace string `json:"namespace"`

	Meta struct {
		Group   string `json:"group"`
		Version string `json:"version"`
		Kind    string `json:"kind"`
	} `json:"meta"`
}

type OperationResult struct {
	Error  *metav1.Status             `json:"error"`
	Latest *unstructured.Unstructured `json:"latest"`
	Target ObjectReference            `json:"target"`
}

type RegoDriver interface {
	// Eval evaluates the given module and returns and check results.
	Eval(*ast.Module, ...RegoOpt) ([]result.Result, error)

	Trace(RegoTracer)

	// StoreItem stores the value at the given path in the Rego data document.
	StoreItem(string, interface{}) error

	// StorePath creates the given path in the Rego data document.
	StorePath(where string) error

	// RemovePath remove any object at the given path in the Rego data document.
	RemovePath(where string) error
}

type RegoOpt = func(*rego.Rego)

type RegoTracer interface {
	topdown.Tracer
	Write()
}

type WrappingResourceEventHandlerFuncs struct {
	AddFunc    func(obj interface{})
	UpdateFunc func(oldObj, newObj interface{})
	DeleteFunc func(obj interface{})

	Next cache.ResourceEventHandler
}