preview

type Action string

type BlockedGCPError struct {
	Method     string
	URL        string
	Body       string
	UpdateMask []string
}

type ClientOptions struct {
	HTTPClient *http.Client
	BaseURL    *url.URL
}

type EventType string

type GKNN struct {
	Group     string
	Kind      string
	Namespace string
	Name      string
}

type GKNNReconciledResult struct {
	GKNN            GKNN
	ControllerType  k8s.ReconcilerType
	ReconcileStatus ReconcileStatus
	Diffs           *structuredreporting.Diff
	GCPActions      []*gcpAction
}

type GroupVersionResource struct {
	Group    string
	Version  string
	Resource string
}

type ListListener interface {
	OnListBegin(metadata ListMetadata)
	OnListObject(ctx context.Context, obj Object) error
	OnListEnd()
}

type ListMetadata struct {
	APIVersion      string
	Kind            string
	ResourceVersion string
}

type Object interface {
	GetNamespace() string
	GetName() string
}

type ObjectTransformer func(ctx context.Context, obj client.Object) error

type PreviewInstance struct {

	// Namespace is the namespace of the cluster to preview
	// If empty, all namespaces are previewed
	// Namespace is the namespace of the cluster to preview
	// If empty, all namespaces are previewed
	Namespace string

	ObjectTransformers []ObjectTransformer
	// contains filtered or unexported fields
}

type PreviewInstanceOptions struct {
	// UpstreamRESTConfig is the rest configuration to use when talking to upstream (real) kube-apiserver
	// (Upstream kube-apiserver may be mocked in tests)
	UpstreamRESTConfig *rest.Config

	// UpstreamGCPAuthorization is the authorization to use when talking to upstream (real) GCP
	// (Upstream GCP may be mocked in tests)
	UpstreamGCPAuthorization oauth2.TokenSource

	// UpstreamGCPHTTPClient is the http client to use when talking to upstream (real) GCP
	// (Upstream GCP may be mocked in tests)
	UpstreamGCPHTTPClient *http.Client

	// UpstreamGCPQPS is the QPS to use when talking to upstream (real) GCP
	// This limit is per API.
	UpstreamGCPQPS float64

	// UpstreamGCPBurst is the burst to use when talking to upstream (real) GCP
	// This limit is per API.
	UpstreamGCPBurst int

	// Namespace is the namespace of the cluster to preview
	// If empty, all namespaces are previewed
	Namespace string

	// ObjectTransformers are the transformers to apply to objects
	ObjectTransformers []ObjectTransformer
}

type ReconcileStatus int

type Recorder struct {

	// Track if a resource has been reconciled.
	ReconciledResources map[GKNN]bool
	// Number of resources has not been reconciled.
	RemainResourcesCount int
	// contains filtered or unexported fields
}

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

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

type WatchListener interface {
	OnWatchEvent(ctx context.Context, eventType string, object Object) error
}

type WatchOptions struct {
	ResourceVersion     string
	AllowWatchBookmarks bool
}