services

package
v0.13.23 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 10, 2019 License: Apache-2.0 Imports: 52 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AllocateGlooPort

func AllocateGlooPort() int32

func DefaultGlooOpts

func DefaultGlooOpts(ctx context.Context, runOptions *RunOptions) bootstrap.Opts

func DefaultTestConstructOpts

func DefaultTestConstructOpts(ctx context.Context, runOptions *RunOptions) gatewaysyncer.Opts

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(name, content string)

func (*ConsulInstance) AddConfigFromStruct

func (i *ConsulInstance) AddConfigFromStruct(name string, cfg interface{})

func (*ConsulInstance) Binary

func (i *ConsulInstance) Binary() string

func (*ConsulInstance) Clean

func (i *ConsulInstance) Clean() error

func (*ConsulInstance) ReloadConfig

func (i *ConsulInstance) ReloadConfig()

func (*ConsulInstance) Run

func (i *ConsulInstance) Run() error

func (*ConsulInstance) Silence

func (i *ConsulInstance) Silence()

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) NewEnvoyInstance

func (ef *EnvoyFactory) NewEnvoyInstance() (*EnvoyInstance, error)

type EnvoyInstance

type EnvoyInstance struct {
	RatelimitAddr string
	RatelimitPort uint32
	ID            string
	Role          string

	GlooAddr  string // address for gloo and services
	Port      uint32
	AdminPort uint32
	// contains filtered or unexported fields
}

func (*EnvoyInstance) Binary

func (ei *EnvoyInstance) Binary() string

func (*EnvoyInstance) Clean

func (ei *EnvoyInstance) Clean() error

func (*EnvoyInstance) LocalAddr

func (ei *EnvoyInstance) LocalAddr() string

func (*EnvoyInstance) Logs

func (ei *EnvoyInstance) Logs() string

func (*EnvoyInstance) Run

func (ei *EnvoyInstance) Run(port int) error

func (*EnvoyInstance) RunWithId

func (ei *EnvoyInstance) RunWithId(id string) error

func (*EnvoyInstance) RunWithRole

func (ei *EnvoyInstance) RunWithRole(role string, port int) error

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
	ExtensionConfigs *gloov1.Extensions
	Extensions       syncer.Extensions
	Cache            memory.InMemoryResourceCache
	KubeClient       kubernetes.Interface
}

type Runner

type Runner struct {
	Sourcepath    string
	ComponentName string
}

type Service

type Service struct {
	Name    string
	Process string

	// these will be filled by Start
	Port     uint32
	MeshPort uint32
}

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
	GlooPort             int
}

func GetTestClients

func GetTestClients(cache memory.InMemoryResourceCache) TestClients

func RunGateway

func RunGateway(ctx context.Context, justgloo bool) TestClients

func RunGlooGatewayUdsFds

func RunGlooGatewayUdsFds(ctx context.Context, runOptions *RunOptions) TestClients

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) Exec

func (i *VaultInstance) Exec(args ...string) (string, 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

type What

type What struct {
	DisableGateway bool
	DisableUds     bool
	DisableFds     bool
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL