services

package
v0.11.2 Latest Latest
Warning

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

 Go to latest Published: Mar 19, 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
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.
JackTT - Gopher 🇻🇳