Documentation
¶
Index ¶
- func AdvanceBindPort(p *uint32) uint32
- func AllocateGlooPort() int32
- func NextBindPort() uint32
- func RunPetstore(ctx context.Context, port int) error
- type ConsulFactory
- type ConsulInstance
- func (i *ConsulInstance) AddConfig(svcId, content string) error
- func (i *ConsulInstance) AddConfigFromStruct(svcId string, cfg interface{}) error
- func (i *ConsulInstance) Binary() string
- func (i *ConsulInstance) Clean() error
- func (i *ConsulInstance) RegisterService(svcName, svcId, address string, tags []string, port uint32) error
- func (i *ConsulInstance) ReloadConfig() error
- func (i *ConsulInstance) Run() error
- func (i *ConsulInstance) Silence()
- type DockerOptions
- type EnvoyFactory
- type EnvoyInstance
- func (ei *EnvoyInstance) Binary() string
- func (ei *EnvoyInstance) Clean() error
- func (ei *EnvoyInstance) DisablePanicMode() error
- func (ei *EnvoyInstance) EnablePanicMode() error
- func (ei *EnvoyInstance) LocalAddr() string
- func (ei *EnvoyInstance) Logs() (string, error)
- func (ei *EnvoyInstance) Run(port int) error
- func (ei *EnvoyInstance) RunWith(eic EnvoyInstanceConfig) error
- func (ei *EnvoyInstance) RunWithConfig(port int, configFile string) error
- func (ei *EnvoyInstance) RunWithId(id string) error
- func (ei *EnvoyInstance) RunWithRole(role string, port int) error
- type EnvoyInstanceConfig
- type NatsStreamingFactory
- type NatsStreamingInstance
- type PrometheusFactory
- type PrometheusInstance
- type QuoteUnquoteMesh
- type RunOptions
- type Runner
- type Service
- type StaticConfigs
- type TestClients
- type VaultFactory
- type VaultInstance
- type What
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AdvanceBindPort ¶ added in v1.2.15
func AllocateGlooPort ¶
func AllocateGlooPort() int32
func NextBindPort ¶
func NextBindPort() uint32
Types ¶
type ConsulFactory ¶
type ConsulFactory struct {
// contains filtered or unexported fields
}
func NewConsulFactory ¶
func NewConsulFactory() (*ConsulFactory, error)
func (*ConsulFactory) Clean ¶
func (ef *ConsulFactory) Clean() error
func (*ConsulFactory) NewConsulInstance ¶
func (ef *ConsulFactory) NewConsulInstance() (*ConsulInstance, error)
type ConsulInstance ¶
type ConsulInstance struct {
// contains filtered or unexported fields
}
func (*ConsulInstance) AddConfig ¶
func (i *ConsulInstance) AddConfig(svcId, content string) error
func (*ConsulInstance) AddConfigFromStruct ¶
func (i *ConsulInstance) AddConfigFromStruct(svcId string, cfg interface{}) error
func (*ConsulInstance) Binary ¶
func (i *ConsulInstance) Binary() string
func (*ConsulInstance) Clean ¶
func (i *ConsulInstance) Clean() error
func (*ConsulInstance) RegisterService ¶ added in v0.17.4
func (i *ConsulInstance) RegisterService(svcName, svcId, address string, tags []string, port uint32) error
func (*ConsulInstance) ReloadConfig ¶
func (i *ConsulInstance) ReloadConfig() error
func (*ConsulInstance) Run ¶
func (i *ConsulInstance) Run() error
func (*ConsulInstance) Silence ¶
func (i *ConsulInstance) Silence()
type DockerOptions ¶ added in v1.5.0
type DockerOptions struct { // Extra volume arguments Volumes []string // Extra env arguments. // see https://docs.docker.com/engine/reference/run/#env-environment-variables for more info Env []string }
Extra options for running in docker
type EnvoyFactory ¶
type EnvoyFactory struct {
// contains filtered or unexported fields
}
func NewEnvoyFactory ¶
func NewEnvoyFactory() (*EnvoyFactory, error)
func (*EnvoyFactory) Clean ¶
func (ef *EnvoyFactory) Clean() error
func (*EnvoyFactory) EnvoyPath ¶
func (ef *EnvoyFactory) EnvoyPath() string
func (*EnvoyFactory) MustEnvoyInstance ¶ added in v1.2.15
func (ef *EnvoyFactory) MustEnvoyInstance() *EnvoyInstance
func (*EnvoyFactory) NewEnvoyInstance ¶
func (ef *EnvoyFactory) NewEnvoyInstance() (*EnvoyInstance, error)
type EnvoyInstance ¶
type EnvoyInstance struct { AccessLogAddr string AccessLogPort uint32 RatelimitAddr string RatelimitPort uint32 ID string Role string UseDocker bool GlooAddr string // address for gloo and services Port uint32 AdminPort uint32 // Path to access logs for binary run AccessLogs string // Envoy API Version to use, default to V3 ApiVersion string DockerOptions // contains filtered or unexported fields }
func (*EnvoyInstance) Binary ¶
func (ei *EnvoyInstance) Binary() string
func (*EnvoyInstance) Clean ¶
func (ei *EnvoyInstance) Clean() error
func (*EnvoyInstance) DisablePanicMode ¶ added in v1.6.0
func (ei *EnvoyInstance) DisablePanicMode() error
func (*EnvoyInstance) EnablePanicMode ¶ added in v1.6.0
func (ei *EnvoyInstance) EnablePanicMode() error
func (*EnvoyInstance) LocalAddr ¶
func (ei *EnvoyInstance) LocalAddr() string
func (*EnvoyInstance) Logs ¶
func (ei *EnvoyInstance) Logs() (string, error)
func (*EnvoyInstance) Run ¶
func (ei *EnvoyInstance) Run(port int) error
func (*EnvoyInstance) RunWith ¶ added in v1.2.15
func (ei *EnvoyInstance) RunWith(eic EnvoyInstanceConfig) error
func (*EnvoyInstance) RunWithConfig ¶ added in v1.5.0
func (ei *EnvoyInstance) RunWithConfig(port int, configFile string) error
func (*EnvoyInstance) RunWithId ¶
func (ei *EnvoyInstance) RunWithId(id string) error
func (*EnvoyInstance) RunWithRole ¶
func (ei *EnvoyInstance) RunWithRole(role string, port int) error
type EnvoyInstanceConfig ¶ added in v1.2.15
type NatsStreamingFactory ¶
type NatsStreamingFactory struct {
// contains filtered or unexported fields
}
func NewNatsStreamingFactory ¶
func NewNatsStreamingFactory() (*NatsStreamingFactory, error)
func (*NatsStreamingFactory) Clean ¶
func (gf *NatsStreamingFactory) Clean() error
func (*NatsStreamingFactory) NewNatsStreamingInstance ¶
func (gf *NatsStreamingFactory) NewNatsStreamingInstance() (*NatsStreamingInstance, error)
type NatsStreamingInstance ¶
type NatsStreamingInstance struct {
// contains filtered or unexported fields
}
func (*NatsStreamingInstance) Clean ¶
func (nsi *NatsStreamingInstance) Clean() error
func (*NatsStreamingInstance) ClusterId ¶
func (nsi *NatsStreamingInstance) ClusterId() string
func (*NatsStreamingInstance) NatsPort ¶
func (nsi *NatsStreamingInstance) NatsPort() uint32
func (*NatsStreamingInstance) Run ¶
func (nsi *NatsStreamingInstance) Run() error
type PrometheusFactory ¶
type PrometheusFactory struct {
// contains filtered or unexported fields
}
func NewPrometheusFactory ¶
func NewPrometheusFactory() (*PrometheusFactory, error)
func (*PrometheusFactory) Clean ¶
func (pf *PrometheusFactory) Clean() error
func (*PrometheusFactory) NewPrometheusInstance ¶
func (pf *PrometheusFactory) NewPrometheusInstance() *PrometheusInstance
type PrometheusInstance ¶
type PrometheusInstance struct { Port int32 // contains filtered or unexported fields }
func (*PrometheusInstance) AddEnvoy ¶
func (pi *PrometheusInstance) AddEnvoy(ei *EnvoyInstance)
func (*PrometheusInstance) AddMesh ¶
func (pi *PrometheusInstance) AddMesh(m *QuoteUnquoteMesh)
func (*PrometheusInstance) Clean ¶
func (pi *PrometheusInstance) Clean() error
func (*PrometheusInstance) Client ¶
func (pi *PrometheusInstance) Client() promv1.API
type QuoteUnquoteMesh ¶
type QuoteUnquoteMesh struct { Envoys []*EnvoyInstance // contains filtered or unexported fields }
func (*QuoteUnquoteMesh) AddFault ¶
func (m *QuoteUnquoteMesh) AddFault(svcIndex int, percent float32)
func (*QuoteUnquoteMesh) RemoveFault ¶
func (m *QuoteUnquoteMesh) RemoveFault(svcIndex int)
func (*QuoteUnquoteMesh) Start ¶
func (m *QuoteUnquoteMesh) Start(ef *EnvoyFactory, testClients TestClients, services []*Service)
func (*QuoteUnquoteMesh) UpdateSelfListener ¶
func (m *QuoteUnquoteMesh) UpdateSelfListener(svcIndex int, l *gloov1.Listener)
type RunOptions ¶
type RunOptions struct { NsToWrite string NsToWatch []string WhatToRun What GlooPort int32 ValidationPort int32 Settings *gloov1.Settings Extensions syncer.Extensions Cache memory.InMemoryResourceCache KubeClient kubernetes.Interface ConsulClient consul.ConsulWatcher ConsulDnsAddress string }
type StaticConfigs ¶
type StaticConfigs []*targetgroup.Group
type TestClients ¶
type TestClients struct { GatewayClient gatewayv1.GatewayClient VirtualServiceClient gatewayv1.VirtualServiceClient ProxyClient gloov1.ProxyClient UpstreamClient gloov1.UpstreamClient SecretClient gloov1.SecretClient ServiceClient skkube.ServiceClient GlooPort int }
func RunGateway ¶
func RunGateway(ctx context.Context, justGloo bool) TestClients
func RunGlooGatewayUdsFds ¶
func RunGlooGatewayUdsFds(ctx context.Context, runOptions *RunOptions) TestClients
noinspection GoUnhandledErrorResult
type VaultFactory ¶
type VaultFactory struct {
// contains filtered or unexported fields
}
func NewVaultFactory ¶
func NewVaultFactory() (*VaultFactory, error)
func (*VaultFactory) Clean ¶
func (ef *VaultFactory) Clean() error
func (*VaultFactory) NewVaultInstance ¶
func (ef *VaultFactory) NewVaultInstance() (*VaultInstance, error)
type VaultInstance ¶
type VaultInstance struct {
// contains filtered or unexported fields
}
func (*VaultInstance) Binary ¶
func (i *VaultInstance) Binary() string
func (*VaultInstance) Clean ¶
func (i *VaultInstance) Clean() error
func (*VaultInstance) Run ¶
func (i *VaultInstance) Run() error
func (*VaultInstance) RunWithPort ¶
func (i *VaultInstance) RunWithPort() error
func (*VaultInstance) Token ¶
func (i *VaultInstance) Token() string
Click to show internal directories.
Click to hide internal directories.