services

package
v1.6.0-beta1 Latest Latest
Warning

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

Go to latest
Published: Oct 9, 2020 License: Apache-2.0 Imports: 63 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AdvanceBindPort added in v1.2.15

func AdvanceBindPort(p *uint32) uint32

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 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 {
	MetricsAddr   string
	MetricsPort   uint32
	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

	DockerOptions
	// 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) 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

func (*EnvoyInstance) SetPanicThreshold added in v0.18.36

func (ei *EnvoyInstance) SetPanicThreshold() error

type EnvoyInstanceConfig added in v1.2.15

type EnvoyInstanceConfig interface {
	Role() string
	Port() uint32

	Context() context.Context
}

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

Jump to

Keyboard shortcuts

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