envoy

Documentation

Index

• Constants
• type AggregatedDiscoveryService
  • func NewAggregatedDiscoveryService(cds *cluster.ClustersControlPlaneService, ...) *AggregatedDiscoveryService
  • func (ads *AggregatedDiscoveryService) DeltaAggregatedResources(discovery.AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error
  • func (ads *AggregatedDiscoveryService) StreamAggregatedResources(stream discovery.AggregatedDiscoveryService_StreamAggregatedResourcesServer) error
• type SecretResourceInfo
  • func (info *SecretResourceInfo) Name() string
  • func (info *SecretResourceInfo) String() string
  • func (info *SecretResourceInfo) Type() string
• type SecretsControlPlaneService
  • func NewSecretsControlPlaneService(k8sManager *kubernetes.K8sResourceManager) *SecretsControlPlaneService
  • func (sds *SecretsControlPlaneService) BuildResource(resourceMap map[string]common.EnvoyResource, version string, node *core.Node) (*envoy_api_v2.DiscoveryResponse, error)
  • func (sds *SecretsControlPlaneService) SecretAdded(info *kubernetes.SecretInfo)
  • func (sds *SecretsControlPlaneService) SecretDeleted(info *kubernetes.SecretInfo)
  • func (sds *SecretsControlPlaneService) SecretUpdated(oldSecret, newSecret *kubernetes.SecretInfo)
  • func (*SecretsControlPlaneService) SecretValid(info *kubernetes.SecretInfo) bool

Constants

const (
	IngressNodeId = "traffic-ingress"
	MAX_RPS       = 10
)

Types

type AggregatedDiscoveryService

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

func NewAggregatedDiscoveryService

func NewAggregatedDiscoveryService(cds *cluster.ClustersControlPlaneService,
	eds *endpoint.EndpointsControlPlaneService,
	lds *listener.ListenersControlPlaneService,
	ilds *ingress.IngressListenersControlPlaneService,
	sds *SecretsControlPlaneService) *AggregatedDiscoveryService

func (*AggregatedDiscoveryService) DeltaAggregatedResources

func (ads *AggregatedDiscoveryService) DeltaAggregatedResources(discovery.AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error

func (*AggregatedDiscoveryService) StreamAggregatedResources

func (ads *AggregatedDiscoveryService) StreamAggregatedResources(stream discovery.AggregatedDiscoveryService_StreamAggregatedResourcesServer) error

type SecretResourceInfo

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

func (*SecretResourceInfo) Name

func (info *SecretResourceInfo) Name() string

func (*SecretResourceInfo) String

func (info *SecretResourceInfo) String() string

func (*SecretResourceInfo) Type

func (info *SecretResourceInfo) Type() string

type SecretsControlPlaneService

type SecretsControlPlaneService struct {
	*common.ControlPlaneService
}

func NewSecretsControlPlaneService

func NewSecretsControlPlaneService(k8sManager *kubernetes.K8sResourceManager) *SecretsControlPlaneService

func (*SecretsControlPlaneService) BuildResource

func (sds *SecretsControlPlaneService) BuildResource(resourceMap map[string]common.EnvoyResource, version string, node *core.Node) (*envoy_api_v2.DiscoveryResponse, error)

func (*SecretsControlPlaneService) SecretAdded

func (sds *SecretsControlPlaneService) SecretAdded(info *kubernetes.SecretInfo)

func (*SecretsControlPlaneService) SecretDeleted

func (sds *SecretsControlPlaneService) SecretDeleted(info *kubernetes.SecretInfo)

func (*SecretsControlPlaneService) SecretUpdated

func (sds *SecretsControlPlaneService) SecretUpdated(oldSecret, newSecret *kubernetes.SecretInfo)

func (*SecretsControlPlaneService) SecretValid

func (*SecretsControlPlaneService) SecretValid(info *kubernetes.SecretInfo) bool