envoy

Documentation

Index

• Variables
• func DetectMaxMemory() uint64
• func GenerateBootstrapFile(cfg kuma_dp.DataplaneRuntime, config []byte) (string, error)
• func InvalidRequestErr(msg string) error
• func IsInvalidRequestErr(err error) bool
• func VersionCompatible(expectedVersion string, envoyVersion string) (bool, error)
• type BootstrapConfigFactoryFunc
  • func NewRemoteBootstrapGenerator(client *http.Client, operatingSystem string, features []string) BootstrapConfigFactoryFunc
• type BootstrapParams
• type Envoy
  • func New(opts Opts) (*Envoy, error)
  • func (e *Envoy) DrainConnections() error
  • func (e *Envoy) NeedLeaderElection() bool
  • func (e *Envoy) Start(stop <-chan struct{}) error
  • func (e *Envoy) WaitForDone()
• type EnvoyVersion
  • func GetEnvoyVersion(binaryPath string) (*EnvoyVersion, error)
• type Opts
• type UIntOrString

Variables

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

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

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

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

func (e *Envoy) WaitForDone()

type EnvoyVersion

type EnvoyVersion struct {
	Build            string
	Version          string
	KumaDpCompatible bool
}

func GetEnvoyVersion

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

type UIntOrString struct {
	Type   string
	UInt   uint64
	String string
}