supervisor

type Controller interface {
	Object

	// Init initializes the Object.
	Init(superSpec *Spec)

	// Inherit also initializes the Object.
	// But it needs to handle the lifecycle of the previous generation.
	// So it's own responsibility for the object to inherit and clean the previous generation stuff.
	// The supervisor won't call Close for the previous generation.
	Inherit(superSpec *Spec, previousGeneration Object)
}

type MetaSpec struct {
	Name string `yaml:"name" jsonschema:"required,format=urlname"`
	Kind string `yaml:"kind" jsonschema:"required"`
}

type Object interface {
	// Category returns the object category of itself.
	Category() ObjectCategory

	// Kind returns the unique kind name to represent itself.
	Kind() string

	// DefaultSpec returns the default spec.
	// It must return a pointer to point a struct.
	DefaultSpec() interface{}

	// Status returns its runtime status.
	Status() *Status

	// Close closes itself. It is called by deleting.
	// Supervisor won't call Close for previous generation in Update.
	Close()
}

type ObjectCategory string

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

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

type ObjectEntityWatcherEvent struct {
	Delete map[string]*ObjectEntity
	Create map[string]*ObjectEntity
	Update map[string]*ObjectEntity
}

type ObjectEntityWatcherFilter func(entity *ObjectEntity) bool

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

type Pipeline interface {
	TrafficObject
}

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

type Status struct {
	// ObjectStatus must be a map or struct (empty is allowed),
	// If the ObjectStatus contains field `timestamp`,
	// it will be covered by the top-level Timestamp here.
	ObjectStatus interface{}
	// Timestamp is the global unix timestamp, the object
	// needs not to set it on its own.
	Timestamp int64
}

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

type TrafficGate interface {
	TrafficObject
}

type TrafficObject interface {
	Object

	// Init initializes the Object.
	Init(superSpec *Spec, muxMapper protocol.MuxMapper)

	// Inherit also initializes the Object.
	// But it needs to handle the lifecycle of the previous generation.
	// So it's own responsibility for the object to inherit and clean the previous generation stuff.
	// The supervisor won't call Close for the previous generation.
	Inherit(superSpec *Spec, previousGeneration Object, muxMapper protocol.MuxMapper)
}

type WalkFunc func(entity *ObjectEntity) bool