workload

Documentation

Index

• Constants
• type Controller
  • func NewController(bpfWorkload *bpfwl.BpfWorkload, enableAccesslog bool) *Controller
  • func (c *Controller) GetAccesslogTrigger() bool
  • func (c *Controller) HandleWorkloadStream() error
  • func (c *Controller) Run(ctx context.Context)
  • func (c *Controller) SetAccesslogTrigger(info bool)
  • func (c *Controller) WorkloadStreamCreateAndSend(client discoveryv3.AggregatedDiscoveryServiceClient, ctx context.Context) error
• type HashName
  • func NewHashName() *HashName
  • func (h *HashName) Delete(str string)
  • func (h *HashName) Hash(str string) uint32
  • func (h *HashName) NumToStr(num uint32) string
  • func (h *HashName) Reset()
• type Processor
  • func NewProcessor(workloadMap bpf2go.KmeshCgroupSockWorkloadMaps) *Processor
  • func (p *Processor) GetBpfCache() *bpf.Cache

Constants

const (
	AddressType       = "type.googleapis.com/istio.workload.Address"
	AuthorizationType = "type.googleapis.com/istio.security.Authorization"
)

const (
	LbPolicyRandom    = 0
	KmeshWaypointPort = 15019 // use this fixed port instead of the HboneMtlsPort in kmesh
)

Types

type Controller

type Controller struct {
	Stream           discoveryv3.AggregatedDiscoveryService_DeltaAggregatedResourcesClient
	Processor        *Processor
	Rbac             *auth.Rbac
	MetricController *telemetry.MetricController
	// contains filtered or unexported fields
}

func NewController

func NewController(bpfWorkload *bpfwl.BpfWorkload, enableAccesslog bool) *Controller

func (*Controller) GetAccesslogTrigger

func (c *Controller) GetAccesslogTrigger() bool

func (*Controller) HandleWorkloadStream

func (c *Controller) HandleWorkloadStream() error

func (*Controller) Run

func (c *Controller) Run(ctx context.Context)

func (*Controller) SetAccesslogTrigger

func (c *Controller) SetAccesslogTrigger(info bool)

func (*Controller) WorkloadStreamCreateAndSend

func (c *Controller) WorkloadStreamCreateAndSend(client discoveryv3.AggregatedDiscoveryServiceClient, ctx context.Context) error

type HashName

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

HashName converts a string to a uint32 integer as the key of bpf map

func NewHashName

func NewHashName() *HashName

func (*HashName) Delete

func (h *HashName) Delete(str string)

func (*HashName) Hash

func (h *HashName) Hash(str string) uint32

func (*HashName) NumToStr

func (h *HashName) NumToStr(num uint32) string

func (*HashName) Reset

func (h *HashName) Reset()

Should only be used by test

type Processor

type Processor struct {
	WorkloadCache cache.WorkloadCache
	ServiceCache  cache.ServiceCache
	// contains filtered or unexported fields
}

func NewProcessor

func NewProcessor(workloadMap bpf2go.KmeshCgroupSockWorkloadMaps) *Processor

func (*Processor) GetBpfCache

func (p *Processor) GetBpfCache() *bpf.Cache