controller

Documentation

Index

• Constants
• type Callbacks
  • func (cb *Callbacks) OnDeltaStreamClosed(id int64, node *corev3.Node)
  • func (cb *Callbacks) OnDeltaStreamOpen(ctx context.Context, id int64, typ string) error
  • func (cb *Callbacks) OnFetchRequest(ctx context.Context, req *discoverygrpc.DiscoveryRequest) error
  • func (cb *Callbacks) OnFetchResponse(req *discoverygrpc.DiscoveryRequest, resp *discoverygrpc.DiscoveryResponse)
  • func (cb *Callbacks) OnStreamClosed(id int64, node *corev3.Node)
  • func (cb *Callbacks) OnStreamDeltaRequest(i int64, request *discoverygrpc.DeltaDiscoveryRequest) error
  • func (cb *Callbacks) OnStreamDeltaResponse(i int64, request *discoverygrpc.DeltaDiscoveryRequest, ...)
  • func (cb *Callbacks) OnStreamOpen(_ context.Context, id int64, typ string) error
  • func (cb *Callbacks) OnStreamRequest(id int64, r *discoverygrpc.DiscoveryRequest) error
  • func (cb *Callbacks) OnStreamResponse(ctx context.Context, id int64, req *discoverygrpc.DiscoveryRequest, ...)
  • func (cb *Callbacks) Report()
• type Controller
  • func New(opts *Options) *Controller
  • func (c *Controller) Run() error
• type Options
• type SnapshotInfo

Constants

const (
	XdsCluster = "xds_cluster"
	Ads        = "ads"
	Xds        = "xds"
	Rest       = "rest"
)

Types

type Callbacks

type Callbacks struct {
	Signal   chan struct{}
	Debug    bool
	Fetches  int
	Requests int
	// contains filtered or unexported fields
}

func (*Callbacks) OnDeltaStreamClosed

func (cb *Callbacks) OnDeltaStreamClosed(id int64, node *corev3.Node)

func (*Callbacks) OnDeltaStreamOpen

func (cb *Callbacks) OnDeltaStreamOpen(ctx context.Context, id int64, typ string) error

func (*Callbacks) OnFetchRequest

func (cb *Callbacks) OnFetchRequest(ctx context.Context, req *discoverygrpc.DiscoveryRequest) error

func (*Callbacks) OnFetchResponse

func (cb *Callbacks) OnFetchResponse(req *discoverygrpc.DiscoveryRequest, resp *discoverygrpc.DiscoveryResponse)

func (*Callbacks) OnStreamClosed

func (cb *Callbacks) OnStreamClosed(id int64, node *corev3.Node)

func (*Callbacks) OnStreamDeltaRequest

func (cb *Callbacks) OnStreamDeltaRequest(i int64, request *discoverygrpc.DeltaDiscoveryRequest) error

func (*Callbacks) OnStreamDeltaResponse

func (cb *Callbacks) OnStreamDeltaResponse(i int64, request *discoverygrpc.DeltaDiscoveryRequest, response *discoverygrpc.DeltaDiscoveryResponse)

func (*Callbacks) OnStreamOpen

func (cb *Callbacks) OnStreamOpen(_ context.Context, id int64, typ string) error

func (*Callbacks) OnStreamRequest

func (cb *Callbacks) OnStreamRequest(id int64, r *discoverygrpc.DiscoveryRequest) error

func (*Callbacks) OnStreamResponse

func (cb *Callbacks) OnStreamResponse(ctx context.Context, id int64, req *discoverygrpc.DiscoveryRequest, resp *discoverygrpc.DiscoveryResponse)

func (*Callbacks) Report

func (cb *Callbacks) Report()

type Controller

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

func New

func New(opts *Options) *Controller

func (*Controller) Run

func (c *Controller) Run() error

Run will start the controller service, which exposes an xDS endpoint for Envoy configuration. It will also start the API server for handling external configurations

type Options

type Options struct {
	GrpcAddress string
	HttpAddress string
}

type SnapshotInfo

type SnapshotInfo struct {
	Version      string
	Listeners    []*api.Listener
	TargetGroups []*api.TargetGroup
	Certificates []*api.Certificate
}