xds

Documentation

Index

• Constants
• func RunServer(srv server.Server, port int)
• func ToMap(d *bootstrapv3.Bootstrap) map[resource.Type][]types.Resource
• type ConfigClient
• type ConfigMapClient
  • func NewConfigMapClient(client client.Client) *ConfigMapClient
  • func (c *ConfigMapClient) Get(ctx context.Context, ref apitypes.NamespacedName) (*bootstrapv3.Bootstrap, error)
  • func (c *ConfigMapClient) Set(ctx context.Context, ref apitypes.NamespacedName, cfg *bootstrapv3.Bootstrap) error
• type ConfigMapReconciler
  • func (r *ConfigMapReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ConfigMapReconciler) SetupWithManager(mgr ctrl.Manager) error
• type Server
  • func NewServer(ctx context.Context, cache cache.Cache, cb *test.Callbacks) *Server
  • func (s *Server) Run(port uint)

Constants

const (
	DefaultConfigKey = "envoy.json"
)

const (
	LabelXDSKind = "xds.pf9.io/kind"
)

Functions

func RunServer

func RunServer(srv server.Server, port int)

RunServer starts an xDS server at the given port.

func ToMap

func ToMap(d *bootstrapv3.Bootstrap) map[resource.Type][]types.Resource

Types

type ConfigClient

type ConfigClient interface {
	Get(ctx context.Context, ref apitypes.NamespacedName) (*bootstrapv3.Bootstrap, error)
	Set(ctx context.Context, ref apitypes.NamespacedName, cfg *bootstrapv3.Bootstrap) error
}

type ConfigMapClient

type ConfigMapClient struct {
	Client client.Client
}

func NewConfigMapClient

func NewConfigMapClient(client client.Client) *ConfigMapClient

func (*ConfigMapClient) Get

func (c *ConfigMapClient) Get(ctx context.Context, ref apitypes.NamespacedName) (*bootstrapv3.Bootstrap, error)

func (*ConfigMapClient) Set

func (c *ConfigMapClient) Set(ctx context.Context, ref apitypes.NamespacedName, cfg *bootstrapv3.Bootstrap) error

type ConfigMapReconciler

type ConfigMapReconciler struct {
	Client        client.Client
	Scheme        *runtime.Scheme
	SnapshotCache cache.SnapshotCache
	ConfigClient  ConfigClient
}

func (*ConfigMapReconciler) Reconcile

func (r *ConfigMapReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*ConfigMapReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type Server

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

func NewServer

func NewServer(ctx context.Context, cache cache.Cache, cb *test.Callbacks) *Server

func (*Server) Run

func (s *Server) Run(port uint)