envoymanager

Documentation

Index

• Constants
• func ServiceKey(svc *corev1.Service) string
• func ServicePortKey(serviceKey string, servicePort *corev1.ServicePort) string
• func SortServicesByCreationTimestamp(items []corev1.Service)
• type Options
  • func (o Options) IsSNIEnabled() bool
  • func (o Options) IsTunnelingEnabled() bool
• type Reconciler
  • func NewReconciler(ctx context.Context, log *zap.SugaredLogger, client ctrlruntimeclient.Client, ...) (*Reconciler, envoycachev3.SnapshotCache, error)
  • func (r *Reconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *Reconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

const (
	UpgradeType = "CONNECT"
)

Functions

func ServiceKey

func ServiceKey(svc *corev1.Service) string

ServiceKey returns a string used to identify the given v1.Service.

func ServicePortKey

func ServicePortKey(serviceKey string, servicePort *corev1.ServicePort) string

ServicePortKey returns a string used to identify the given v1.ServicePort.

func SortServicesByCreationTimestamp

func SortServicesByCreationTimestamp(items []corev1.Service)

SortServicesByCreationTimestamp sorts the Service slice in descending order by creation timestamp (i.e. from oldest to newest). UID alphanumeric ordering is used to break ties.

Types

type Options

type Options struct {
	// Namespace where Services and Endpoints are watched.
	Namespace string
	// NodeName is the name used to retrieve the xds configuration.
	// It is supposed to match the id (AKA service-node) of the Envoy instance
	// being controlled.
	EnvoyNodeName string
	// ExposeAnnotationKey is the annotation used to expose services.
	ExposeAnnotationKey string

	// EnvoyAdminPort port used to exposed Envoy admin interface.
	EnvoyAdminPort int
	// EnvoyStatsPort is the port used to expose Envoy stats.
	EnvoyStatsPort int

	// EnvoySNIListenerPort is the port used by the SNI Listener.
	// When the value is less or equal than 0 the SNI Listener is disabled and
	// won't be configured in Envoy.
	EnvoySNIListenerPort int
	// EnvoyTunnelingListenerPort is the port used to listen for HTTP/2
	// CONNECT requests.
	// When the value is less or equal than 0 the HTTP/2 CONNECT Listener is
	// disabled and won't be configured in Envoy.
	EnvoyTunnelingListenerPort int
}

func (Options) IsSNIEnabled

func (o Options) IsSNIEnabled() bool

func (Options) IsTunnelingEnabled

func (o Options) IsTunnelingEnabled() bool

type Reconciler

type Reconciler struct {
	ctrlruntimeclient.Client
	Options
	// contains filtered or unexported fields
}

func NewReconciler

func NewReconciler(ctx context.Context, log *zap.SugaredLogger, client ctrlruntimeclient.Client, opts Options) (*Reconciler, envoycachev3.SnapshotCache, error)

NewReconciler returns a new Reconciler or an error if something goes wrong during the initial snapshot setup.

func (*Reconciler) Reconcile

func (r *Reconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)

func (*Reconciler) SetupWithManager

func (r *Reconciler) SetupWithManager(mgr ctrl.Manager) error