xds

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 23, 2023 License: Apache-2.0 Imports: 35 Imported by: 0

Documentation

Index

Constants

View Source
const (
	DefaultConfigKey = "envoy.json"
)
View Source
const (
	LabelXDSKind = "xds.pf9.io/kind"
)

Variables

This section is empty.

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 (*ConfigMapClient) Set

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL