envoy

Documentation

Index

• Variables
• func DetectMaxMemory() uint64
• func GenerateBootstrapFile(cfg dubboctl.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(operatingSystem string, features []string) BootstrapConfigFactoryFunc
• type BootstrapParams
• type Envoy
  • func New(opts Opts) (*Envoy, error)
  • func (e *Envoy) Start(stop <-chan struct{}) error
• 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 dubbo-cp before starting dubbo-dp or pass it to dubbo-dp run --dataplane-file=/file. If you are running on Kubernetes, please check the dubbo-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 dubboctl.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)

Types

type BootstrapConfigFactoryFunc

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

func NewRemoteBootstrapGenerator

func NewRemoteBootstrapGenerator(operatingSystem string, features []string) BootstrapConfigFactoryFunc

type BootstrapParams

type BootstrapParams struct {
	Dataplane           rest.Resource
	DNSPort             uint32
	EmptyDNSPort        uint32
	EnvoyVersion        EnvoyVersion
	DynamicMetadata     map[string]string
	Workdir             string
	MetricsSocketPath   string
	AccessLogSocketPath string
	MetricsCertPath     string
	MetricsKeyPath      string
}

type Envoy

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

func New

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

func (*Envoy) Start

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

type EnvoyVersion

type EnvoyVersion struct {
	Build             string
	Version           string
	DubboDpCompatible bool
}

func GetEnvoyVersion

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

type Opts

type Opts struct {
	Config          dubboctl.Config
	BootstrapConfig []byte
	AdminPort       uint32
	Dataplane       rest.Resource
	Stdout          io.Writer
	Stderr          io.Writer
	OnFinish        func()
}

type UIntOrString

type UIntOrString struct {
	Type   string
	UInt   uint64
	String string
}