controller

package

v0.0.0-...-28c0fd5 Latest Latest Go to latest Published: Mar 10, 2024 License: MIT Imports: 34 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/launchboxio/cloudscale

Links

Open Source Insights

Documentation ¶

Constants ¶

View Source

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

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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
}

Source Files ¶

View all Source files

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