Documentation
¶
Index ¶
Constants ¶
View Source
const (
TableName = "podippools"
)
Variables ¶
View Source
var ( NameIndex = statedb.Index[LocalPodIPPool, string]{ Name: "name", FromObject: func(obj LocalPodIPPool) index.KeySet { return index.NewKeySet([]byte(obj.Name)) }, FromKey: index.String, FromString: index.FromString, Unique: true, } ByName = NameIndex.Query // TableCell provides the PodIPPool StateDB table and its k8s reflector. TableCell = cell.Module( "ipam-podippool-table", "PodIPPool StateDB Table", cell.Provide(NewTableAndReflector), ) )
Functions ¶
func NewTableAndReflector ¶
func NewTableAndReflector(jg job.Group, db *statedb.DB, cs client.Clientset) (statedb.Table[LocalPodIPPool], error)
NewTableAndReflector returns the read-only Table[LocalPodIPPool] and registers the k8s reflector. These are combined to ensure any dependency on Table[LocalPodIPPool] will start after the reflector, ensuring that Start hooks can wait for the table to initialize.
Types ¶
type LocalPodIPPool ¶
type LocalPodIPPool struct {
*api_v2alpha1.CiliumPodIPPool
// UpdatedAt is the time when [LocalPodIPPool] was last updated, e.g. it
// shows when the pool change was received from the api-server.
UpdatedAt time.Time `json:"updatedAt" yaml:"updatedAt"`
}
LocalPodIPPool is an internal model of pod IP pools on the cluster
func (LocalPodIPPool) TableHeader ¶
func (p LocalPodIPPool) TableHeader() []string
func (LocalPodIPPool) TableRow ¶
func (p LocalPodIPPool) TableRow() []string
Source Files
Click to show internal directories.
Click to hide internal directories.