envoy

package
v1.8.1 Latest Latest
Warning

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

Go to latest
Published: Oct 5, 2022 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	DpNotFoundErr = errors.New("Dataplane entity not found. If you are running on Universal please create a Dataplane entity on kuma-cp before starting kuma-dp or pass it to kuma-dp run --dataplane-file=/file. If you are running on Kubernetes, please check the kuma-cp logs to determine why the Dataplane entity could not be created by the automatic sidecar injection.")
)

Functions

func DetectMaxMemory added in v1.8.1

func DetectMaxMemory() uint64

func GenerateBootstrapFile

func GenerateBootstrapFile(cfg kuma_dp.DataplaneRuntime, config []byte) (string, error)

func InvalidRequestErr

func InvalidRequestErr(msg string) error

func IsInvalidRequestErr

func IsInvalidRequestErr(err error) bool

func VersionCompatible added in v1.8.1

func VersionCompatible(expectedVersion string, envoyVersion string) (bool, error)

VersionCompatible returns true if the given version of envoy is compatible with this DP, false otherwise, expectedVersion is in Masterminds/semver/v3 format.

Types

type BootstrapConfigFactoryFunc

type BootstrapConfigFactoryFunc func(ctx context.Context, url string, cfg kuma_dp.Config, params BootstrapParams) (*envoy_bootstrap_v3.Bootstrap, *types.KumaSidecarConfiguration, error)

func NewRemoteBootstrapGenerator

func NewRemoteBootstrapGenerator(client *http.Client, operatingSystem string, features []string) BootstrapConfigFactoryFunc

type BootstrapParams

type BootstrapParams struct {
	Dataplane       *rest.Resource
	DNSPort         uint32
	EmptyDNSPort    uint32
	EnvoyVersion    EnvoyVersion
	DynamicMetadata map[string]string
}

type Envoy

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

func New

func New(opts Opts) (*Envoy, error)

func (*Envoy) DrainConnections added in v1.8.1

func (e *Envoy) DrainConnections() error

func (*Envoy) NeedLeaderElection

func (e *Envoy) NeedLeaderElection() bool

func (*Envoy) Start

func (e *Envoy) Start(stop <-chan struct{}) error

func (*Envoy) WaitForDone added in v1.8.1

func (e *Envoy) WaitForDone()

type EnvoyVersion

type EnvoyVersion struct {
	Build            string
	Version          string
	KumaDpCompatible bool
}

func GetEnvoyVersion added in v1.8.1

func GetEnvoyVersion(binaryPath string) (*EnvoyVersion, error)

type Opts

type Opts struct {
	Config          kuma_dp.Config
	BootstrapConfig []byte
	AdminPort       uint32
	Dataplane       *rest.Resource
	Stdout          io.Writer
	Stderr          io.Writer
	Quit            chan struct{}
}

type UIntOrString added in v1.8.1

type UIntOrString struct {
	Type   string
	UInt   uint64
	String string
}

Jump to

Keyboard shortcuts

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