environment

Nov 8, 2021

Changes in this version

+ const KafkaRestAPIPort

+ func GetKafkaRestClientFromEnv(env Environment) (*client.KafkaRestClient, error)

type K8sEnvSpecInit

+ func AtlasEvmBlocksGroup() K8sEnvSpecInit

+ func AtlasEvmEventsAndReceiptsGroup() K8sEnvSpecInit

+ func NewChainlinkClusterForAtlasTesting(nodeCount int) K8sEnvSpecInit

type K8sManifest

+ func NewAtlasEvmBlocksManifest() *K8sManifest

+ func NewAtlasEvmEventsManifest() *K8sManifest

+ func NewAtlasEvmReceiptsManifest() *K8sManifest

+ func NewKafkaRestManifest() *K8sManifest

+ func NewSchemaRegistryManifest() *K8sManifest

Oct 29, 2021

Changes in this version

+ func GetFreePort() uint16

+ func NewExternalBlockchainClient(clientFunc types.NewClientHook, env Environment, ...) (client.BlockchainClient, error)

+ type ChartDeploymentConfig struct

+ Name string

+ Path string

+ SetValuesFunc SetValuesHelmFunc

+ Values map[string]interface{}

type Environment

+ Networks func() []client.BlockchainNetwork

type HelmChart

+ func NewExternalChart(cfg ChartDeploymentConfig) *HelmChart

+ func (k *HelmChart) Environment() *K8sEnvironment

type K8sEnvResource

+ Environment func() *K8sEnvironment

type K8sEnvSpecInit

+ func NewChainlinkCustomNetworksCluster(nodeCount int, networkDeploymentConfigs []ChartDeploymentConfig) K8sEnvSpecInit

+ func NewExternalCharts(chartConfigs []ChartDeploymentConfig) K8sEnvSpecInit

type K8sEnvironment

+ func (env *K8sEnvironment) Networks() []client.BlockchainNetwork

type K8sManifest

+ func (m *K8sManifest) Environment() *K8sEnvironment

type K8sManifestGroup

+ func (mg *K8sManifestGroup) Environment() *K8sEnvironment

Oct 22, 2021

Changes in this version

+ const TerraFCDPort

+ const TerraLCDPort

+ var DefaultChainlinkAuthMap = map[string][]byte

type HelmChart

+ func NewLocalTerraHelmChart(networkCount int, network *config.NetworkConfig) *HelmChart

+ func NewTerraRelayHelmChart(idx int) *HelmChart

type K8sEnvSpecInit

+ func NewChainlinkHeadlessCluster(nodeCount int) K8sEnvSpecInit

+ func NewRelays(nodeCount int) K8sEnvSpecInit

type K8sManifest

+ func NewHeadlessChainlinkManifest() *K8sManifest

Oct 14, 2021

Changes in this version

+ const DefaultEVMRPCPort

+ const GanacheRPCPort

+ const GethRPCPort

+ const HardhatRPCPort

type K8sManifest

+ Network *config.NetworkConfig

Oct 5, 2021

Changes in this version

+ const MinersRPCPort

+ const MockserverAPIPort

+ const OtherMinersRPCPort

+ const PrivateNetworksInfoSecret

+ const PrometheusAPIPort

+ func GetMockserverClientFromEnv(env Environment) (*client.MockserverClient, error)

+ func GetPrometheusClientFromEnv(env Environment) (*client.Prometheus, error)

+ func NewBlockchainClients(env Environment, network client.BlockchainNetwork) (client.BlockchainClient, error)

type Environment

+ DeploySpecs func(init K8sEnvSpecInit) error

+ GetSecretField func(namespace string, secretName string, privateKey string) (string, error)

type HelmChart

+ func NewKafkaHelmChart() *HelmChart

+ func NewMockserverConfigHelmChart() *HelmChart

+ func NewMockserverHelmChart() *HelmChart

type K8sEnvSpecInit

+ func NewChainlinkClusterForObservabilityTesting(nodeCount int) K8sEnvSpecInit

+ func OtpeGroup() K8sEnvSpecInit

+ func PrometheusGroup() K8sEnvSpecInit

type K8sEnvironment

+ func (env *K8sEnvironment) DeploySpecs(init K8sEnvSpecInit) error

+ func (env K8sEnvironment) GetSecretField(namespace string, secretName string, fieldName string) (string, error)

type K8sManifest

+ func NewOTPEManifest() *K8sManifest

+ func NewPrometheusManifest() *K8sManifest

Sep 8, 2021

Changes in this version

+ const ExplorerAPIPort

+ func GetExplorerClientFromEnv(env Environment) (*client.ExplorerClient, error)

+ func NewExplorerClient(localUrl string) (*client.ExplorerClient, error)

type K8sEnvSpecInit

+ func NewChainlinkClusterForAlertsTesting(nodeCount int) K8sEnvSpecInit

type K8sManifest

+ func (m *K8sManifest) ExecuteInPod(podName string, containerName string, command []string) ([]byte, []byte, error)

type K8sManifestGroup

+ SetValuesFunc manifestGroupSetValuesFunc

type PodForwardedInfo

+ PodName string

+ type TemplateValuesArray struct

+ Values []interface{}

Sep 2, 2021

Changes in this version

+ const DefaultK8sConfigPath

+ const HelmInstallTimeout

+ const ReleasePrefix

+ func K8sConfig() (*rest.Config, error)

type Environment

+ ApplyChaos func(exp chaos.Experimentable) (string, error)

+ StopAllChaos func() error

+ StopChaos func(name string) error

+ type HelmChart struct

+ SetValuesHelmFunc SetValuesHelmFunc

+ func NewGethReorgHelmChart() *HelmChart

+ func (k *HelmChart) Deploy(_ map[string]interface{}) error

+ func (k *HelmChart) GetConfig() *config.Config

+ func (k *HelmChart) ID() string

+ func (k *HelmChart) ServiceDetails() ([]*ServiceDetails, error)

+ func (k *HelmChart) SetEnvironment(k8sClient *kubernetes.Clientset, k8sConfig *rest.Config, config *config.Config, ...) error

+ func (k *HelmChart) SetValue(key string, val interface{})

+ func (k *HelmChart) Teardown() error

+ func (k *HelmChart) Values() map[string]interface{}

+ func (k *HelmChart) WaitUntilHealthy() error

type K8sEnvResource

+ GetConfig func() *config.Config

+ SetValue func(key string, val interface{})

type K8sEnvironment

+ func (env K8sEnvironment) ApplyChaos(exp chaos.Experimentable) (string, error)

+ func (env K8sEnvironment) StopAllChaos() error

+ func (env K8sEnvironment) StopChaos(name string) error

type K8sManifest

+ func NewPostgresManifest() *K8sManifest

+ func (m *K8sManifest) GetConfig() *config.Config

+ func (m *K8sManifest) SetValue(key string, val interface{})

type K8sManifestGroup

+ func (mg *K8sManifestGroup) GetConfig() *config.Config

+ func (mg *K8sManifestGroup) SetValue(key string, val interface{})

+ type PodForwardedInfo struct

+ ForwardedPorts []portforward.ForwardedPort

+ PodIP string

+ type SetValuesHelmFunc func(resource *HelmChart) error

Aug 30, 2021

Changes in this version

+ const AdapterAPIPort

+ const ChainlinkP2PPort

+ const ChainlinkWebPort

+ const EVMRPCPort

+ const ExplorerWSPort

+ const SelectorLabelKey

+ func GetChainlinkClients(env Environment) ([]client.Chainlink, error)

+ func GetExplorerMockClient(env Environment) (*client.ExplorerClient, error)

+ func NewBlockchainClient(env Environment, network client.BlockchainNetwork) (client.BlockchainClient, error)

+ func NewPrivateKeyStoreFromEnv(env Environment, network *config.NetworkConfig) (config.PrivateKeyStore, error)

+ type Environment interface

+ GetAllServiceDetails func(remotePort uint16) ([]*ServiceDetails, error)

+ GetPrivateKeyFromSecret func(namespace string, privateKey string) (string, error)

+ GetServiceDetails func(remotePort uint16) (*ServiceDetails, error)

+ ID func() string

+ TearDown func()

+ WriteArtifacts func(testLogFolder string)

+ func NewK8sEnvironment(init K8sEnvSpecInit, cfg *config.Config, network client.BlockchainNetwork) (Environment, error)

+ type ExternalAdapter interface

+ ClusterURL func() string

+ LocalURL func() string

+ SetVariable func(variable int) error

+ TriggerValueChange func(i int) (int, error)

+ func GetExternalAdapter(env Environment) (ExternalAdapter, error)

+ type K8sEnvResource interface

+ Deploy func(values map[string]interface{}) error

+ ID func() string

+ ServiceDetails func() ([]*ServiceDetails, error)

+ SetEnvironment func(k8sClient *kubernetes.Clientset, k8sConfig *rest.Config, config *config.Config, ...) error

+ Teardown func() error

+ Values func() map[string]interface{}

+ WaitUntilHealthy func() error

+ type K8sEnvSpecInit func(*config.NetworkConfig) (string, K8sEnvSpecs)

+ func NewChainlinkCluster(nodeCount int) K8sEnvSpecInit

+ func NewMixedVersionChainlinkCluster(nodeCount, pastVersionsCount int) K8sEnvSpecInit

+ type K8sEnvSpecs map[int]K8sEnvResource

+ type K8sEnvironment struct

+ func (env K8sEnvironment) GetAllServiceDetails(remotePort uint16) ([]*ServiceDetails, error)

+ func (env K8sEnvironment) GetPrivateKeyFromSecret(namespace string, privateKey string) (string, error)

+ func (env K8sEnvironment) GetServiceDetails(remotePort uint16) (*ServiceDetails, error)

+ func (env K8sEnvironment) ID() string

+ func (env K8sEnvironment) TearDown()

+ func (env K8sEnvironment) WriteArtifacts(testLogFolder string)

+ type K8sManifest struct

+ ConfigMap *coreV1.ConfigMap

+ ConfigMapFile string

+ Deployment *appsV1.Deployment

+ DeploymentFile string

+ Secret *coreV1.Secret

+ SecretFile string

+ Service *coreV1.Service

+ ServiceFile string

+ SetValuesFunc k8sSetValuesFunc

+ func NewAdapterManifest() *K8sManifest

+ func NewChainlinkManifest() *K8sManifest

+ func NewExplorerManifest() *K8sManifest

+ func NewGanacheManifest() *K8sManifest

+ func NewGethManifest() *K8sManifest

+ func NewHardhatManifest() *K8sManifest

+ func (m *K8sManifest) Deploy(values map[string]interface{}) error

+ func (m *K8sManifest) ID() string

+ func (m *K8sManifest) ServiceDetails() ([]*ServiceDetails, error)

+ func (m *K8sManifest) SetEnvironment(k8sClient *kubernetes.Clientset, k8sConfig *rest.Config, config *config.Config, ...) error

+ func (m *K8sManifest) Teardown() error

+ func (m *K8sManifest) Values() map[string]interface{}

+ func (m *K8sManifest) WaitUntilHealthy() error

+ type K8sManifestGroup struct

+ func (mg *K8sManifestGroup) Deploy(values map[string]interface{}) error

+ func (mg *K8sManifestGroup) ID() string

+ func (mg *K8sManifestGroup) ServiceDetails() ([]*ServiceDetails, error)

+ func (mg *K8sManifestGroup) SetEnvironment(k8sClient *kubernetes.Clientset, k8sConfig *rest.Config, config *config.Config, ...) error

+ func (mg *K8sManifestGroup) Teardown() error

+ func (mg *K8sManifestGroup) Values() map[string]interface{}

+ func (mg *K8sManifestGroup) WaitUntilHealthy() error

+ type ServiceDetails struct

+ LocalURL *url.URL

+ RemoteURL *url.URL