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
	AccessLogPath  string
	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)