environment

May 26, 2022

Changes in this version

type Environment

+ func DeployRemoteRunnerToEnv(env *Environment, ...) (*Environment, error)

May 19, 2022

Changes in this version

+ func CommonRemoteRunnerValues(testTag, slackAPI, slackChannel, slackUser string) map[string]interface

May 17, 2022

Changes in this version

type Config

+ func NewPerformanceChainlinkConfig(chainlinkValues map[string]interface{}, optionalNamespacePrefix string, ...) *Config

May 13, 2022

Changes in this version

type Config

+ func (m *Config) Decode(path string) error

+ func (m *Config) ToJSON() ([]byte, error)

type Environment

+ func DeployRemoteRunnerEnvironment(config *Config, ...) (*Environment, error)

May 9, 2022

Changes in this version

+ var ChartsFS embed.FS

Apr 25, 2022

Changes in this version

type Config

+ func NewChainlinkCCIPReorgConfig(chainlinkValues map[string]interface{}) *Config

Apr 21, 2022

Changes in this version

+ func FindRemoteURLs(e *Environment, prefix string, portName string, connectionType Protocol) func(e *Environment) ([]*url.URL, error)

type HelmChart

+ func (hc *HelmChart) Uninstall() error

Apr 6, 2022

Changes in this version

+ func DefaultGeth() (string, map[string]interface{})

+ func PerformanceGeth() (string, map[string]interface{})

+ func RealisticGeth() (string, map[string]interface{})

+ type SimulatedNetwork func() (string, map[string]interface{})

Mar 31, 2022

Changes in this version

+ const AppEnumerationLabelKey

+ const DefaultK8sConfigPath

+ const HelmInstallTimeout

+ const InstanceEnumerationLabelKey

+ func ChainlinkReplicas(count int, values map[string]interface{}) map[string]interface

+ func ChainlinkVersion(version string, values map[string]interface{}) map[string]interface

+ func DumpConfig(cfg *Config, path string) error

+ func DumpConfigJson(cfg *Config, path string) error

+ func GetLocalK8sDeps() (*kubernetes.Clientset, *rest.Config, error)

+ type Artifacts struct

+ DBName string

+ func NewArtifacts(env *Environment) (*Artifacts, error)

+ func (a *Artifacts) DumpTestResult(testDir string, dbName string) error

+ type ChartConnection struct

+ LocalPorts map[string]int

+ PodIP string

+ PodName string

+ RemotePorts map[string]int

+ type ChartConnections map[string]*ChartConnection

+ func (cc *ChartConnections) LoadByPort(port int) ([]*ChartConnection, error)

+ func (cc *ChartConnections) LoadByPortName(portName string) ([]*ChartConnection, error)

+ func (cc *ChartConnections) LocalURLByPort(portName string, protocol Protocol) (*url.URL, error)

+ func (cc *ChartConnections) LocalURLs(stringDirective string, portName string) ([]*url.URL, error)

+ func (cc *ChartConnections) LocalURLsByPort(portName string, protocol Protocol) ([]*url.URL, error)

+ func (cc *ChartConnections) RemoteURLByPort(portName string, protocol Protocol) (*url.URL, error)

+ func (cc *ChartConnections) RemoteURLs(stringDirective string, portName string) ([]*url.URL, error)

+ func (cc *ChartConnections) RemoteURLsByPort(portName string, protocol Protocol) ([]*url.URL, error)

+ func (cc ChartConnections) Load(app, instance, name string) (*ChartConnection, error)

+ func (cc ChartConnections) Range(f func(key string, chartConnection *ChartConnection) bool)

+ func (cc ChartConnections) Store(app, instance, name string, chartConnection *ChartConnection) error

+ type Charts map[string]*HelmChart

+ func (c Charts) Connections(chart string) *ChartConnections

+ func (c Charts) Decode(value string) error

+ func (c Charts) ExecuteInPod(chartName string, podNameSubstring string, podIndex int, containerName string, ...) error

+ func (c Charts) Get(chartName string) (*HelmChart, error)

+ func (c Charts) OrderedKeys() [][]string

+ type Config struct

+ Burst int

+ Charts Charts

+ Experiments map[string]*chaos.ExperimentInfo

+ MarshalSafeTimeout MarshalSafeDuration

+ Namespace string

+ NamespacePrefix string

+ Path string

+ Persistent bool

+ QPS float32

+ Timeout time.Duration

+ func NewChainlinkCCIPConfig(chainlinkValues map[string]interface{}) *Config

+ func NewChainlinkConfig(chainlinkValues map[string]interface{}, optionalNamespacePrefix string) *Config

+ func NewChainlinkReorgConfig(chainlinkValues map[string]interface{}) *Config

+ func NewTerraChainlinkConfig(chainlinkValues map[string]interface{}) *Config

+ type Environment struct

+ Artifacts *Artifacts

+ Chaos *chaos.Controller

+ func DeployEnvironment(config *Config, chartDirectory string) (*Environment, error)

+ func DeployLongTestEnvironment(config *Config, ...) (*Environment, error)

+ func DeployOrLoadEnvironment(config *Config, chartDirectory string) (*Environment, error)

+ func DeployOrLoadEnvironmentFromConfigFile(chartDirectory, configFilePath string) (*Environment, error)

+ func LoadEnvironment(config *Config) (*Environment, error)

+ func NewEnvironment(config *Config) (*Environment, error)

+ func (k *Environment) AddChart(chart *HelmChart) error

+ func (k *Environment) AddLabel(selector string, label string) error

+ func (k *Environment) ApplyChaosExperiment(exp chaos.Experimentable) (string, error)

+ func (k *Environment) ApplyChaosExperimentFromTemplate(tmplPath string) error

+ func (k *Environment) ClearAllChaosExperiments() error

+ func (k *Environment) ClearAllChaosStandaloneExperiments(expInfos map[string]*chaos.ExperimentInfo) error

+ func (k *Environment) ClearConfig() error

+ func (k *Environment) ClearConfigLocalPorts() error

+ func (k *Environment) Connect(chartName string) error

+ func (k *Environment) ConnectAll() error

+ func (k *Environment) DeferTeardown()

+ func (k *Environment) Deploy(chartName string) error

+ func (k *Environment) DeployAll() error

+ func (k *Environment) Disconnect()

+ func (k *Environment) GetSecretField(namespace string, secretName string, fieldName string) (string, error)

+ func (k *Environment) Init(namespacePrefix string) error

+ func (k *Environment) StopChaosExperiment(id string) error

+ func (k *Environment) StopChaosStandaloneExperiment(expInfo *chaos.ExperimentInfo) error

+ func (k *Environment) SyncConfig() error

+ func (k *Environment) SyncConfigJson() error

+ func (k *Environment) Teardown() error

+ func (k *Environment) Upgrade(chartName string) error

+ type HelmChart struct

+ AfterHook Hook

+ AutoConnect bool

+ BeforeHook Hook

+ ChartConnections ChartConnections

+ Index int

+ Path string

+ ReleaseName string

+ URL string

+ Values map[string]interface{}

+ func NewChainlinkChart(index int, values map[string]interface{}) *HelmChart

+ func (hc *HelmChart) Connect() error

+ func (hc *HelmChart) CopyToPod(src, destination, containername string) (*bytes.Buffer, *bytes.Buffer, *bytes.Buffer, error)

+ func (hc *HelmChart) Deploy() error

+ func (hc *HelmChart) ExecuteInPod(podName string, containerName string, command []string) ([]byte, []byte, error)

+ func (hc *HelmChart) GetPodsByNameSubstring(nameSubstring string) ([]v1.Pod, error)

+ func (hc *HelmChart) Init(env *Environment) error

+ func (hc *HelmChart) Upgrade() error

+ type Hook func(environment *Environment) error

+ type MarshalSafeDuration time.Duration

+ func (d *MarshalSafeDuration) UnmarshalJSON(b []byte) error

+ func (d MarshalSafeDuration) AsTimeDuration() time.Duration

+ func (d MarshalSafeDuration) MarshalJSON() ([]byte, error)

+ type Protocol int

+ const HTTP

+ const HTTPS

+ const WS

+ const WSS