k8s

package
v1.2.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 26, 2026 License: MIT Imports: 61 Imported by: 1

Documentation

Index

Constants

View Source 
const K8sAPIGroupCiliumEndpointV2 = "cilium/v2::CiliumEndpoint"

Variables

View Source 
var Cell = cell.Module(
	"k8s-watcher",
	"Kubernetes watchers needed by Hubble flow enrichment",

	infrastructureCell,
	ipcacheCell,
	watcherCell,
	stubsCell,
)

Cell provides the Kubernetes watchers needed by Hubble flow enrichment. It is broken into sub-cells so that when Cilium changes its DI graph upstream, the failing sub-cell immediately identifies which dependency boundary broke.

Functions

func Start 

func Start(ctx context.Context, k *watchers.K8sWatcher)

Types

type APIServerEventHandler 

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

type NoOpPolicyRepository added in v0.0.30 

type NoOpPolicyRepository struct{}

NoOpPolicyRepository is a no-op implementation of the PolicyRepository interface.

func (*NoOpPolicyRepository) BumpRevision added in v0.0.30 

func (n *NoOpPolicyRepository) BumpRevision() uint64

func (*NoOpPolicyRepository) GetAuthTypes added in v0.0.30 

func (n *NoOpPolicyRepository) GetAuthTypes(identity.NumericIdentity, identity.NumericIdentity) policy.AuthTypes

func (*NoOpPolicyRepository) GetEnvoyHTTPRules added in v0.0.30 

func (n *NoOpPolicyRepository) GetEnvoyHTTPRules(*api.L7Rules, string) (*cilium.HttpNetworkPolicyRules, bool)

func (*NoOpPolicyRepository) GetPolicySnapshot added in v1.2.1 

func (n *NoOpPolicyRepository) GetPolicySnapshot() map[identity.NumericIdentity]policy.SelectorPolicy

func (*NoOpPolicyRepository) GetRevision added in v0.0.30 

func (n *NoOpPolicyRepository) GetRevision() uint64

func (*NoOpPolicyRepository) GetRulesList added in v0.0.30 

func (n *NoOpPolicyRepository) GetRulesList() *models.Policy

func (*NoOpPolicyRepository) GetSelectorCache added in v0.0.30 

func (n *NoOpPolicyRepository) GetSelectorCache() *policy.SelectorCache

func (*NoOpPolicyRepository) GetSelectorPolicy added in v0.0.30 

func (n *NoOpPolicyRepository) GetSelectorPolicy(*identity.Identity, uint64, policy.GetPolicyStatistics, uint64) (policy.SelectorPolicy, uint64, error)

func (*NoOpPolicyRepository) GetSubjectSelectorCache added in v1.2.1 

func (n *NoOpPolicyRepository) GetSubjectSelectorCache() *policy.SelectorCache

func (*NoOpPolicyRepository) Iterate added in v0.0.30 

func (n *NoOpPolicyRepository) Iterate(func(*policytypes.PolicyEntry))

func (*NoOpPolicyRepository) ReplaceByResource added in v0.0.30 

func (n *NoOpPolicyRepository) ReplaceByResource(
	_ policytypes.PolicyEntries, _ ipcachetypes.ResourceID,
) (affectedIDs *set.Set[identity.NumericIdentity], rev uint64, oldRevCnt int)

func (*NoOpPolicyRepository) Search added in v0.0.30 

func (n *NoOpPolicyRepository) Search() (entries policytypes.PolicyEntries, rev uint64)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.