discovery

Documentation

Index

• Constants
• func Start(ctx context.Context, config *Config) (func(), error)
• func StartDebugServer(port int, node string, c cache.SnapshotCache)
• type Config
  • func NewEmptyConfig() *Config
  • func (c *Config) ParseFlags()
• type ConsulConfig
• type DebugConfig
• type DebugServer
  • func (d *DebugServer) ListenAndServe(port int)
• type EnvoyConfig
• type GlobalConfig
• type SyncChans
  • func NewSyncChans() *SyncChans
• type XDS
  • func (x *XDS) Init(client *consul.Client, sn cache.SnapshotCache)
  • func (x *XDS) Start(ctx context.Context)

Constants

const XdsClusterName = "xds_cluster"

Functions

func Start

func Start(ctx context.Context, config *Config) (func(), error)

func StartDebugServer

func StartDebugServer(port int, node string, c cache.SnapshotCache)

Types

type Config

type Config struct {
	Global *GlobalConfig
	Consul *ConsulConfig
	XDS    *XDS
}

func NewEmptyConfig

func NewEmptyConfig() *Config

func (*Config) ParseFlags

func (c *Config) ParseFlags()

type ConsulConfig

type ConsulConfig struct {
	Proto string
	Host  string
	Port  int
	Token string
}

type DebugConfig

type DebugConfig struct {
	Enable bool
	Port   int
}

type DebugServer

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

func (*DebugServer) ListenAndServe

func (d *DebugServer) ListenAndServe(port int)

type EnvoyConfig

type EnvoyConfig struct {
	NodeName string

	ListenerPort                 int
	ListenerDrainType            string
	ListenTransparent            bool
	ListenTcpFastOpenQueueLength int
	ListenerPerConnBufLimitBytes int

	HttpAccessLogPath       string
	HttpIdleTimeout         int64
	HttpStreamIdleTimeout   int64
	HttpRequestTimeout      int64
	HttpDrainTimeout        int64
	HttpDelayedCloseTimeout int64
	HttpPreserveExtReqId    bool

	EnableTracing  bool
	TracingOpName  string
	TracingVerbose bool
}

type GlobalConfig

type GlobalConfig struct {
	LogLevel             string
	LogFormat            string
	MetricsSink          string
	EnableRuntimeMetrics bool
	DogstatsdAddr        string
	DogstatsdPort        int
	DogstatsdNS          string
}

type SyncChans

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

func NewSyncChans

func NewSyncChans() *SyncChans

type XDS

type XDS struct {
	ServiceName string
	ListenPort  int
	Consul      *consul.Client
	Cache       cache.SnapshotCache

	Envoy *EnvoyConfig
	Debug *DebugConfig
}

func (*XDS) Init

func (x *XDS) Init(client *consul.Client, sn cache.SnapshotCache)

func (*XDS) Start

func (x *XDS) Start(ctx context.Context)