Documentation
¶
Index ¶
- Constants
- type Controller
- func (c *Controller) GetAccesslogTrigger() bool
- func (c *Controller) GetMonitoringTrigger() bool
- func (c *Controller) HandleWorkloadStream() error
- func (c *Controller) Run(ctx context.Context)
- func (c *Controller) SetAccesslogTrigger(enabled bool)
- func (c *Controller) SetMonitoringTrigger(enabled bool)
- func (c *Controller) SetWorkloadMetricTrigger(enable bool)
- func (c *Controller) WorkloadStreamCreateAndSend(client discoveryv3.AggregatedDiscoveryServiceClient, ctx context.Context) error
- type Processor
Constants ¶
View Source
const ( AddressType = "type.googleapis.com/istio.workload.Address" AuthorizationType = "type.googleapis.com/istio.security.Authorization" )
View Source
const (
KmeshWaypointPort = 15019 // use this fixed port instead of the HboneMtlsPort in kmesh
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Controller ¶ added in v0.4.0
type Controller struct {
Stream discoveryv3.AggregatedDiscoveryService_DeltaAggregatedResourcesClient
Processor *Processor
Rbac *auth.Rbac
MetricController *telemetry.MetricController
MapMetricController *telemetry.MapMetricController
OperationMetricController *telemetry.BpfProgMetric
// contains filtered or unexported fields
}
func NewController ¶ added in v0.4.0
func NewController(bpfWorkload *bpfwl.BpfWorkload, enableMonitoring, enablePerfMonitor bool) *Controller
func (*Controller) GetAccesslogTrigger ¶ added in v1.0.0
func (c *Controller) GetAccesslogTrigger() bool
func (*Controller) GetMonitoringTrigger ¶ added in v1.0.0
func (c *Controller) GetMonitoringTrigger() bool
func (*Controller) HandleWorkloadStream ¶ added in v0.4.0
func (c *Controller) HandleWorkloadStream() error
func (*Controller) Run ¶ added in v0.4.0
func (c *Controller) Run(ctx context.Context)
func (*Controller) SetAccesslogTrigger ¶ added in v1.0.0
func (c *Controller) SetAccesslogTrigger(enabled bool)
func (*Controller) SetMonitoringTrigger ¶ added in v1.0.0
func (c *Controller) SetMonitoringTrigger(enabled bool)
func (*Controller) SetWorkloadMetricTrigger ¶ added in v1.0.0
func (c *Controller) SetWorkloadMetricTrigger(enable bool)
func (*Controller) WorkloadStreamCreateAndSend ¶ added in v0.4.0
func (c *Controller) WorkloadStreamCreateAndSend(client discoveryv3.AggregatedDiscoveryServiceClient, ctx context.Context) error
type Processor ¶ added in v0.4.0
type Processor struct {
WorkloadCache cache.WorkloadCache
ServiceCache cache.ServiceCache
EndpointCache cache.EndpointCache
WaypointCache cache.WaypointCache
// contains filtered or unexported fields
}
func NewProcessor ¶ added in v0.5.0
func NewProcessor(workloadMap bpf2go.KmeshCgroupSockWorkloadMaps) *Processor
func (*Processor) GetBpfCache ¶ added in v0.5.0
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.