services

package
v0.18.4 Latest Latest
Warning

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

 Go to latest Published: Jul 30, 2019 License: Apache-2.0 Imports: 60 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AllocateGlooPort 

func AllocateGlooPort() int32

func NextBindPort 

func NextBindPort() uint32

func RunPetstore added in v0.18.3 

func RunPetstore(ctx context.Context, port int) error

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

	UseDocker bool
	GlooAddr  string // address for gloo and services
	Port      uint32
	AdminPort uint32
	// Path to access logs for binary run
	AccessLogs string
	// 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, error)

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
	ConsulClient     consul.ConsulWatcher
}

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        gatewayv2.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) 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.