Functions — github.com/cedi/picokubelet

hub / github.com/cedi/picokubelet / functions

Functions86 in github.com/cedi/picokubelet

⨍ Functions 86 ◇ Types & classes 28

↓ 12 callersMethodobserve

(&mut self, current: bool, now: u64)

src/k8s/conditions.rs:28

↓ 12 callersMethodwrite_json

(&self, out: &mut HString<2048>)

src/k8s/models.rs:33

↓ 10 callersFunctioninputs

()

src/k8s/conditions.rs:317

↓ 9 callersFunctionfmt_rfc3339

Format unix seconds as RFC3339 with microsecond precision (which k8s expects in `renewTime`): "2026-05-02T15:47:17.000000Z".

src/wallclock.rs:77

↓ 9 callersFunctionunix_now_secs

()

src/wallclock.rs:22

↓ 6 callersMethodas_str

(&self)

src/k8s/path.rs:14

↓ 6 callersFunctioneval_existential

(i: &CustomCondInputs)

src/k8s/conditions.rs:223

↓ 5 callersMethodrun

(&mut self, client: &'static SharedClient, identity: NodeIdentity)

src/reconcilers/mod.rs:35

↓ 5 callersFunctionwrite

(tx: &mut Channel<'static, Async, Tx>, c: Color)

src/led.rs:202

↓ 4 callersFunctioneval_vibes

(i: &CustomCondInputs)

src/k8s/conditions.rs:170

↓ 4 callersMethodrequest

( &mut self, http_method: &str, content_type: &str, path: &str, body:

src/net/client.rs:83

↓ 3 callersFunctioneval_caffeinated

(i: &CustomCondInputs)

src/k8s/conditions.rs:207

↓ 3 callersFunctioneval_haunted

(i: &CustomCondInputs)

src/k8s/conditions.rs:284

↓ 3 callersFunctioneval_peckish

(i: &CustomCondInputs)

src/k8s/conditions.rs:251

↓ 3 callersMethodpatch_merge

(&mut self, path: &str, body: &[u8])

src/net/client.rs:64

↓ 3 callersMethodpost

(&mut self, path: &str, body: &[u8])

src/net/client.rs:59

↓ 3 callersFunctionrender_steady

(pattern: LedPattern, elapsed_ms: u64)

src/led.rs:148

↓ 3 callersFunctionset

Fire-and-forget: never blocks the caller. Latest signal wins.

src/led.rs:53

↓ 2 callersFunctionbreathe

Eased pulse between 5% and 25% of each channel cap. Smoothstep keeps the corners gentle; a triangle wave reads as frantic.

src/led.rs:163

↓ 2 callersMethodheap_pct_free

Heap percent free, 0..=100.

src/k8s/conditions.rs:140

↓ 2 callersFunctionnet_task

(mut runner: NetRunner<'static, WifiInterface<'static>>)

src/net/wifi.rs:50

↓ 2 callersMethodpatch_strategic

( &mut self, path: &str, body: &[u8], )

src/net/client.rs:69

↓ 2 callersFunctionread_common_register

(spi: &mut EthSpiDevice, addr: u16)

src/net/ethernet.rs:28

↓ 2 callersFunctionself_test

(tx: &mut Channel<'static, Async, Tx>)

src/led.rs:141

↓ 1 callersFunctionanchor_clock

(client: &SharedClient)

src/kubelet.rs:70

↓ 1 callersFunctionbootstrap

( client: &SharedClient, identity: &NodeIdentity, )

src/kubelet.rs:56

↓ 1 callersFunctionbreathe_pct

(elapsed_ms: u64, period_ms: u64)

src/led.rs:173

↓ 1 callersFunctionbssid_to_u64

(b: [u8; 6])

src/net/wifi.rs:22

↓ 1 callersMethodclone

(&self)

src/k8s/path.rs:20

↓ 1 callersFunctionconnection_task

(mut controller: WifiController<'static>)

src/net/wifi.rs:32

↓ 1 callersFunctioncreate_lease

(client: &SharedClient)

src/kubelet.rs:132

↓ 1 callersMethodcreate_lease

(&self, renew_unix: u64)

src/k8s/api.rs:82

↓ 1 callersFunctionethernet_task

(runner: EthRunner)

src/net/ethernet.rs:72

↓ 1 callersMethodget

(&mut self, path: &str)

src/net/client.rs:55

↓ 1 callersMethodheader

(&self, name: &str)

src/net/http.rs:41

↓ 1 callersMethodinterval

(&self)

src/reconcilers/mod.rs:29

↓ 1 callersFunctionlease_reconciler

(client: &'static SharedClient, identity: NodeIdentity)

src/reconcilers/lease.rs:162

↓ 1 callersFunctionled_task

(rmt: RMT<'static>, pin: GPIO21<'static>)

src/led.rs:94

↓ 1 callersFunctionmilestone_for

(count: u32)

src/reconcilers/lease.rs:77

↓ 1 callersFunctionparse_http_date

Parse RFC1123 HTTP Date like "Sat, 02 May 2026 15:47:17 GMT" → unix secs. Tolerant of the surrounding spaces but not other formats.

src/wallclock.rs:46

↓ 1 callersFunctionparse_response

(buf: &[u8])

src/net/http.rs:53

↓ 1 callersMethodpatch_heap_annotation

( &self, identity: &NodeIdentity, free_bytes: usize, )

src/k8s/api.rs:145

↓ 1 callersMethodpatch_node_status

( &self, identity: &NodeIdentity, tracker: &NodeCondTracker, custom: &[CustomC

src/k8s/api.rs:110

↓ 1 callersFunctionprobe_w5500

(spi: &mut EthSpiDevice)

src/net/ethernet.rs:38

↓ 1 callersFunctionpush_initial_status

( client: &SharedClient, identity: &NodeIdentity, tracker: &mut NodeCondTracker, custom: &mut

src/kubelet.rs:162

↓ 1 callersFunctionread_header

(addr: u16)

src/net/ethernet.rs:24

↓ 1 callersMethodreconcile

(&mut self, ctx: &mut ReconcileContext)

src/reconcilers/lease.rs:121

↓ 1 callersFunctionregister_node

(client: &SharedClient, identity: &NodeIdentity)

src/kubelet.rs:97

↓ 1 callersMethodrenew_lease

( &self, identity: &NodeIdentity, renew_unix: u64, )

src/k8s/api.rs:52

↓ 1 callersFunctionset_wall_clock

(unix_secs: u64)

src/wallclock.rs:16

↓ 1 callersFunctionstatus_reconciler

( client: &'static SharedClient, identity: NodeIdentity, tracker: NodeCondTracker, custom: Cus

src/reconcilers/status.rs:207

↓ 1 callersFunctionunix_from_ymdhms

Convert (year, month, day, h, m, s) → unix epoch seconds. Howard Hinnant's civil_from_days algorithm in reverse, simplified for AD years.

src/wallclock.rs:34

Methodas_str

(self)

src/k8s/conditions.rs:71

Functioncaffeinated_turns_decaf_after_fresh_window

()

src/k8s/conditions.rs:382

Functionclone_preserves_path_contents

()

src/k8s/path.rs:47

Functioncond_state_tracks_transition_time_only_on_flips

()

src/k8s/conditions.rs:329

Functioncustom_conditions_start_unknown_so_first_real_value_forces_patch

()

src/k8s/conditions.rs:341

Functionexistential_thresholds_are_monotonic

()

src/k8s/conditions.rs:394

Methodfmt

(&self, f: &mut fmt::Formatter<'_>)

src/k8s/api.rs:25

Functionformats_kubernetes_timestamp_with_microseconds

()

src/wallclock.rs:121

Functionformats_path_without_allocating

()

src/k8s/path.rs:32

Methodfrom

(e: embassy_net::tcp::ConnectError)

src/net/http.rs:24

Functionhaunted_prefers_new_bssid_over_time_slip

()

src/k8s/conditions.rs:431

Functionheap_annotation_serializes_free_bytes_as_string_annotation

()

src/k8s/models.rs:293

Functionheap_percent_is_capped_at_total_heap

()

src/k8s/conditions.rs:352

Functionlease_body_contains_name_namespace_duration_and_renew_time

()

src/k8s/models.rs:245

(mut runner: NetRunner<'static, WiznetNetDevice<'static>>)

src/net/ethernet.rs:77

(initial: bool, now: u64)

src/k8s/conditions.rs:21

Methodnew

(client: &'static SharedClient)

src/k8s/api.rs:48

Methodnew

(args: fmt::Arguments<'_>)

src/k8s/path.rs:8

Methodnew

( stack: Stack<'static>, api_ip: Ipv4Address, api_port: u16, rng: Rng,

src/net/client.rs:35

Methodnew

(client: &'static SharedClient, identity: NodeIdentity)

src/reconcilers/mod.rs:18

Methodnew

(tracker: NodeCondTracker, custom: CustomCondTracker)

src/reconcilers/status.rs:73

Methodnew

()

src/reconcilers/lease.rs:110

Functionnode_registration_uses_supplied_ip_as_internal_address

()

src/k8s/models.rs:307

Functionparses_http_date_from_kubernetes_version_response

()

src/wallclock.rs:108

Functionpeckish_defers_to_memory_pressure_threshold

()

src/k8s/conditions.rs:419

Methodreconcile

(&mut self, ctx: &mut ReconcileContext)

src/reconcilers/status.rs:92

Functionrejects_non_http_date_months

()

src/wallclock.rs:116

Functionrejects_paths_that_exceed_capacity

()

src/k8s/path.rs:40

Functionstatus_patch_writes_custom_conditions_after_builtin_conditions

()

src/k8s/models.rs:263

Functionunix_conversion_handles_leap_day

()

src/wallclock.rs:130

Functionvibes_prefers_cursed_reconnects_over_good_heap

()

src/k8s/conditions.rs:362

Functionvibes_reports_immaculate_on_fresh_stable_boot

()

src/k8s/conditions.rs:374