hz

type Action[T Objecter] interface {
	Actioner
	Do(context.Context, T) (T, error)
}

type Actioner interface {
	Action() string
}

type Actor[T Objecter] struct {
	// contains filtered or unexported fields
}

type ActorOption[T Objecter] func(*actorOption[T])

type AdvertiseMsg struct {
	LabelSelector LabelSelector `json:"labelSelector,omitempty"`
}

type ApplyOpResult string

type ApplyOption func(*applyOptions)

type CUEValidator struct {
	Object Objecter
	// contains filtered or unexported fields
}

type Client struct {
	Conn *nats.Conn

	// Internal is set to true to use the internal nats subjects.
	// This is used for service accounts (controllers) that have nats
	// credentials with permission to use the internal nats subjects.
	// For clients such as hzctl, this should be false causing the client to use
	// the `api` nats subjects (requiring authn/authz).
	Internal bool

	Session string

	// Manager is the manager of apply operations.
	Manager string
}

type ClientOption func(*clientOpts)

type Components struct {
	Schemas map[string]Schema `json:"schemas,omitempty"`
}

type Controller struct {
	Conn *nats.Conn
	// contains filtered or unexported fields
}

type ControllerOption func(*controllerOption)

type CreateOption func(*createOptions)

type DeleteOption func(*deleteOptions)

type Error struct {
	// Status is the HTTP status code applicable to this problem.
	Status  int    `json:"status,omitempty"`
	Message string `json:"message,omitempty"`
}

type Event struct {
	Operation EventOperation
	Data      []byte
	Key       ObjectKeyer
	Reply     chan EventResult
}

type EventOperation string

type EventResult struct {
	Result Result
	Err    error
}

type Finalizers []string

type GenericObject struct {
	TypeMeta   `json:",inline"`
	ObjectMeta `json:"metadata,omitempty"`

	Remaining map[string]json.RawMessage `json:"-"`
}

type GenericObjectList struct {
	Items []GenericObject `json:"items,omitempty"`
}

type GetOption func(*getOptions)

type Info struct {
	Title       string `json:"title"`
	Description string `json:"description,omitempty"`
}

type LabelSelector struct {
	// MatchLabels is a map of key/value pairs, used to explicitly match labels
	// of an object.
	MatchLabels map[string]string `json:"matchLabels,omitempty" cue:",opt"`

	MatchExpressions []LabelSelectorRequirement `json:"matchExpressions,omitempty" cue:",opt"`
}

type LabelSelectorOperator string

type LabelSelectorRequirement struct {
	Key      string                `json:"key" cue:""`
	Operator LabelSelectorOperator `json:"operator" cue:"\"In\" | \"NotIn\" | \"Exists\" | \"DoesNotExist\""`
	// Values must be non-nil for In or NotIn operators.
	// Otherwise the Values has no effect.
	Values []string `json:"values,omitempty" cue:",opt"`
}

type ListOption func(*listOption)

type MetaOnlyObject struct {
	TypeMeta   `json:",inline"`
	ObjectMeta `json:"metadata"`
}

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

type ObjectClient[T Objecter] struct {
	Client Client
}

type ObjectKey struct {
	Group   string
	Version string
	Kind    string
	Account string
	Name    string
}

type ObjectKeyer interface {
	ObjectGroup() string
	ObjectVersion() string
	ObjectKind() string
	ObjectAccount() string
	ObjectName() string
}

type ObjectList struct {
	Items []json.RawMessage `json:"items,omitempty"`
}

type ObjectMeta struct {
	Name    string `json:"name,omitempty" cue:"=~\"^[a-zA-Z0-9-_]+$\""`
	Account string `json:"account,omitempty" cue:"=~\"^[a-zA-Z0-9-_]+$\""`

	Labels map[string]string `json:"labels,omitempty" cue:",opt"`

	// Revision is the revision number of the object.
	Revision          *uint64                     `json:"revision,omitempty" cue:",opt"`
	OwnerReferences   OwnerReferences             `json:"ownerReferences,omitempty" cue:",opt"`
	DeletionTimestamp *Time                       `json:"deletionTimestamp,omitempty" cue:",opt"`
	ManagedFields     managedfields.ManagedFields `json:"managedFields,omitempty" cue:",opt"`
	// Finalizers are a way for controllers to prevent garbage collection of
	// objects. The GC will not delete an object unless it has no finalizers.
	// Hence, it is the responsibility of the controller to remove the
	// finalizers once the object has been marked for deletion (by setting the
	// deletionTimestamp).
	//
	// Use type alias to "correctly" marshal to json.
	// A nil Finalizers is omitted from JSON.
	// A non-nil Finalizers is marshalled as an empty array if it is empty.
	Finalizers *Finalizers `json:"finalizers,omitempty" cue:",opt"`
}

type Objecter interface {
	ObjectKeyer
	ObjectRevision() *uint64
	ObjectDeletionTimestamp() *Time
	ObjectOwnerReferences() []OwnerReference
	ObjectOwnerReference(Objecter) (OwnerReference, bool)
	ObjectManagedFields() managedfields.ManagedFields
}

type OwnerReference struct {
	Group   string `json:"group,omitempty" cue:""`
	Version string `json:"version,omitempty" cue:""`
	Kind    string `json:"kind,omitempty" cue:""`
	Account string `json:"account,omitempty" cue:""`
	Name    string `json:"name,omitempty" cue:""`
}

type OwnerReferences []OwnerReference

type Portal struct {
	ObjectMeta `json:"metadata,omitempty" cue:""`

	Spec   *PortalSpec   `json:"spec,omitempty" cue:""`
	Status *PortalStatus `json:"status,omitempty" cue:",opt"`
}

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

type PortalSpec struct {
	DisplayName string `json:"displayName,omitempty"`
	Icon        string `json:"icon,omitempty"`
}

type PortalStatus struct{}

type Properties []Schema

type Reconciler interface {
	Reconcile(context.Context, Request) (Result, error)
}

type Request struct {
	// Key is the unique identifier of the object in the nats kv store.
	// It is the key of the object that is being reconciled.
	Key ObjectKeyer
}

type Result struct {
	// Requeue tells the Controller to requeue the reconcile key.  Defaults to
	// false.
	Requeue bool

	// RequeueAfter if greater than 0, tells the Controller to requeue the
	// reconcile key after the Duration. Implies that Requeue is true, there is
	// no need to set Requeue to true at the same time as RequeueAfter.
	RequeueAfter time.Duration
}

type RunMsg struct {
	Timeout       time.Duration   `json:"timeout,omitempty"`
	Data          json.RawMessage `json:"data,omitempty"`
	LabelSelector LabelSelector   `json:"labelSelector,omitempty"`
}

type RunOption func(*runOption)

type Schema struct {
	Key        string      `json:"-"`
	Type       *SchemaType `json:"type,omitempty"`
	Required   []string    `json:"required,omitempty"`
	Properties Properties  `json:"properties,omitempty"`

	MultipleOf       *float64     `json:"multipleOf,omitempty"`
	Maximum          *float64     `json:"maximum,omitempty"`
	ExclusiveMaximum *bool        `json:"exclusiveMaximum,omitempty"`
	Minimum          *float64     `json:"minimum,omitempty"`
	ExclusiveMinimum *bool        `json:"exclusiveMinimum,omitempty"`
	MaxLength        *int64       `json:"maxLength,omitempty"`
	MinLength        *int64       `json:"minLength,omitempty"`
	Pattern          *string      `json:"pattern,omitempty"`
	MaxItems         *int64       `json:"maxItems,omitempty"`
	MinItems         *int64       `json:"minItems,omitempty"`
	UniqueItems      *bool        `json:"uniqueItems,omitempty"`
	MaxProperties    *int64       `json:"maxProperties,omitempty"`
	MinProperties    *int64       `json:"minProperties,omitempty"`
	Enum             []string     `json:"enum,omitempty"`
	Not              *Schema      `json:"not,omitempty"`
	AllOf            []Schema     `json:"allOf,omitempty"`
	OneOf            []Schema     `json:"oneOf,omitempty"`
	AnyOf            []Schema     `json:"anyOf,omitempty"`
	Items            *Schema      `json:"items,omitempty"`
	Description      *string      `json:"description,omitempty"`
	Format           *string      `json:"format,omitempty"`
	Default          *interface{} `json:"default,omitempty"`
	Nullable         *bool        `json:"nullable,omitempty"`
	ReadOnly         *bool        `json:"readOnly,omitempty"`
	WriteOnly        *bool        `json:"writeOnly,omitempty"`
	Example          *interface{} `json:"example,omitempty"`
	Deprecated       *bool        `json:"deprecated,omitempty"`
}

type SchemaType string

type Spec struct {
	Openapi    string     `json:"openapi"`
	Info       Info       `json:"info"` // Required.
	Components Components `json:"components,omitempty"`
}

type Time struct {
	time.Time
}

type TypeMeta struct {
	APIVersion string `json:"apiVersion,omitempty"`
	Kind       string `json:"kind,omitempty"`
}

type TypedObjectList[T Objecter] struct {
	Items []T `json:"items,omitempty"`
}

type ValidateOption func(*validateOptions)

type Validator interface {
	ValidateCreate(ctx context.Context, data []byte) error
	ValidateUpdate(ctx context.Context, old, data []byte) error
	ValidateDelete(ctx context.Context, data []byte) error
}

type Watcher struct {
	Conn *nats.Conn

	Init chan struct{}
	// contains filtered or unexported fields
}

type WatcherOption func(*watcherOptions)

type ZeroValidator struct{}