Documentation
¶
Index ¶
Constants ¶
View Source
const (
CiliumIdentityHandlerName = "cilium-identity-handler"
)
View Source
const (
ServiceHandlerName = "k8s-service-handler"
)
Variables ¶
View Source
var Cell = cell.Module( "resources", "Resources for Hubble", cell.Provide(NewServiceHandler), cell.Provide( k8s.CiliumIdentityResource, NewCiliumIdentityHandler, ), )
Functions ¶
This section is empty.
Types ¶
type CiliumIdentityHandler ¶
type CiliumIdentityHandler struct {
// contains filtered or unexported fields
}
CiliumIdentityHandler watches CiliumIdentity resources using resource.Resource
func (*CiliumIdentityHandler) GetLabelsFromSecurityIdentity ¶
func (h *CiliumIdentityHandler) GetLabelsFromSecurityIdentity(id cid.NumericIdentity) []string
func (*CiliumIdentityHandler) Start ¶
func (h *CiliumIdentityHandler) Start(cell.HookContext) error
func (*CiliumIdentityHandler) Stop ¶
func (h *CiliumIdentityHandler) Stop(cell.HookContext) error
type CiliumIdentityHandlerOut ¶
type CiliumIdentityHandlerOut struct {
cell.Out
common.LabelCache
*CiliumIdentityHandler
}
func NewCiliumIdentityHandler ¶
func NewCiliumIdentityHandler(params CiliumIdentityHandlerParams) CiliumIdentityHandlerOut
NewCiliumIdentityHandler creates a new CiliumIdentityHandler instance
type CiliumIdentityHandlerParams ¶
type CiliumIdentityHandlerParams struct {
cell.In
Lifecycle cell.Lifecycle
Identities resource.Resource[*cilium_api_v2.CiliumIdentity]
}
type ServiceHandler ¶
type ServiceHandler struct {
// contains filtered or unexported fields
}
ServiceHandler watches Kubernetes services using resource.Resource
func (*ServiceHandler) Decode ¶
func (h *ServiceHandler) Decode(ip netip.Addr) *flow.Service
Decode returns the service associated with the given IP address, or nil if not found.
func (*ServiceHandler) Start ¶
func (h *ServiceHandler) Start(cell.HookContext) error
func (*ServiceHandler) Stop ¶
func (h *ServiceHandler) Stop(cell.HookContext) error
type ServiceHandlerOut ¶
type ServiceHandlerOut struct {
cell.Out
common.SvcDecoder
*ServiceHandler
}
func NewServiceHandler ¶
func NewServiceHandler(params ServiceHandlerParams) ServiceHandlerOut
NewServiceHandler creates a new ServiceHandler instance
type ServiceHandlerParams ¶
Source Files
Click to show internal directories.
Click to hide internal directories.