integration

Documentation

Index

• Constants
• func Cleanup(ginkgoWriter io.Writer, kclient *kubernetes.Clientset, namespace string) error
• func CleanupNamespace(ginkgoWriter io.Writer, kclient *kubernetes.Clientset, namespace string) error
• func ClearOperatorConfig(kclient *kubernetes.Clientset, namespace string) error
• func CreateConfigMap(kclient *kubernetes.Clientset, config interface{}, key, name, namespace string) error
• func CreateOperatorConfigMapFromFile(namespace string, kclient *kubernetes.Clientset, file string) error
• func CreatePullSecret(kclient *kubernetes.Clientset, name string, namespace string, ...) error
• func DeleteNamespace(ginkgoWriter io.Writer, kclient *kubernetes.Clientset, namespace string) error
• func DeployOperator(ginkgoWriter io.Writer, signal context.Context, cfg *Config, ...) error
• func GetOperatorConfig(configs, caFiles, peerFiles, ordererFiles, consoleFiles string) *config.Config
• func InitClients(setupConfig *SetupConfig) (*kubernetes.Clientset, *ibpclient.IBPClient, error)
• func OperatorCfg() *config.Config
• func ResilientPatch(kclient *ibpclient.IBPClient, name, namespace, kind string, retry int, ...) error
• func Setup(ginkgoWriter io.Writer, cfg *Config, suffix, pathToDefaultDir string) (string, *kubernetes.Clientset, *ibpclient.IBPClient, error)
• func SetupSignalHandler() context.Context
• func ShutdownOperator(ginkgoWriter io.Writer)
• type Config
• type NativeResourcePoller
  • func (p *NativeResourcePoller) CheckForStuckPod(pod corev1.Pod) bool
  • func (p *NativeResourcePoller) ConfigMapExists() bool
  • func (p *NativeResourcePoller) Deployment() *appsv1.Deployment
  • func (p *NativeResourcePoller) DeploymentExists() bool
  • func (p *NativeResourcePoller) DeploymentList() *appsv1.DeploymentList
  • func (p *NativeResourcePoller) GetPods() []corev1.Pod
  • func (p *NativeResourcePoller) GetRunningPods() []corev1.Pod
  • func (p *NativeResourcePoller) IngressExists() bool
  • func (p *NativeResourcePoller) IsRunning() bool
  • func (p *NativeResourcePoller) NumberOfDeployments() int
  • func (p *NativeResourcePoller) NumberOfOrdererNodeDeployments() int
  • func (p *NativeResourcePoller) PVCExists() bool
  • func (p *NativeResourcePoller) PodCreated() bool
  • func (p *NativeResourcePoller) PodIsRunning() bool
  • func (p *NativeResourcePoller) ServiceExists() bool
  • func (p *NativeResourcePoller) TestAffinityRegion(dep *appsv1.Deployment) bool
  • func (p *NativeResourcePoller) TestAffinityZone(dep *appsv1.Deployment) bool
• type Operator
  • func (o *Operator) GetPod() (*corev1.Pod, error)
  • func (o *Operator) Restart() error
• type SetupConfig
  • func GetConfig() (*SetupConfig, error)

Constants

const (
	FabricCAVersion    = "1.5.3"
	FabricVersion      = "2.2.5"
	FabricVersion24    = "2.4.3"
	InitImage          = "registry.access.redhat.com/ubi8/ubi-minimal"
	InitTag            = "latest"
	CaImage            = "hyperledger/fabric-ca"
	CaTag              = FabricCAVersion
	PeerImage          = "hyperledger/fabric-peer"
	PeerTag            = FabricVersion24
	OrdererImage       = "hyperledger/fabric-orderer"
	OrdererTag         = FabricVersion24
	Orderer14Tag       = "1.4.12"
	Orderer24Tag       = FabricVersion24
	ConfigtxlatorImage = "hyperledger/fabric-tools"
	ConfigtxlatorTag   = FabricVersion24
	CouchdbImage       = "couchdb"
	CouchdbTag         = "3.2.2"
	GrpcwebImage       = "ghcr.io/hyperledger-labs/grpc-web"
	GrpcwebTag         = "latest"
	ConsoleImage       = "ghcr.io/hyperledger-labs/fabric-console"
	ConsoleTag         = "latest"
	DeployerImage      = "ghcr.io/ibm-blockchain/fabric-deployer"
	DeployerTag        = "latest-amd64"
)

const (
	TestAutomation1IngressDomain = "vcap.me"
)

Functions

func Cleanup

func Cleanup(ginkgoWriter io.Writer, kclient *kubernetes.Clientset, namespace string) error

func CleanupNamespace

func CleanupNamespace(ginkgoWriter io.Writer, kclient *kubernetes.Clientset, namespace string) error

func ClearOperatorConfig

func ClearOperatorConfig(kclient *kubernetes.Clientset, namespace string) error

func CreateConfigMap

func CreateConfigMap(kclient *kubernetes.Clientset, config interface{}, key, name, namespace string) error

CreateConfigMap creates config map

func CreateOperatorConfigMapFromFile

func CreateOperatorConfigMapFromFile(namespace string, kclient *kubernetes.Clientset, file string) error

func CreatePullSecret

func CreatePullSecret(kclient *kubernetes.Clientset, name string, namespace string, dockerConfigJson string) error

func DeleteNamespace

func DeleteNamespace(ginkgoWriter io.Writer, kclient *kubernetes.Clientset, namespace string) error

func DeployOperator

func DeployOperator(ginkgoWriter io.Writer, signal context.Context, cfg *Config, kclient *kubernetes.Clientset, namespace string) error

func GetOperatorConfig

func GetOperatorConfig(configs, caFiles, peerFiles, ordererFiles, consoleFiles string) *config.Config

GetOperatorConfig returns the operator configuration with the default templating files population and with default versions set for components.

func InitClients

func InitClients(setupConfig *SetupConfig) (*kubernetes.Clientset, *ibpclient.IBPClient, error)

func OperatorCfg

func OperatorCfg() *config.Config

func ResilientPatch

func ResilientPatch(kclient *ibpclient.IBPClient, name, namespace, kind string, retry int, into client.Object, patch func(i client.Object)) error

func Setup

func Setup(ginkgoWriter io.Writer, cfg *Config, suffix, pathToDefaultDir string) (string, *kubernetes.Clientset, *ibpclient.IBPClient, error)

func SetupSignalHandler

func SetupSignalHandler() context.Context

func ShutdownOperator

func ShutdownOperator(ginkgoWriter io.Writer)

Types

type Config

type Config struct {
	OperatorServiceAccount string
	OperatorRole           string
	OperatorRoleBinding    string
	OperatorDeployment     string
	OrdererSecret          string
	PeerSecret             string
	ConsoleTLSSecret       string
}

type NativeResourcePoller

type NativeResourcePoller struct {
	Name      string
	Namespace string
	Client    *kubernetes.Clientset
	// contains filtered or unexported fields
}

func (*NativeResourcePoller) CheckForStuckPod

func (p *NativeResourcePoller) CheckForStuckPod(pod corev1.Pod) bool

func (*NativeResourcePoller) ConfigMapExists

func (p *NativeResourcePoller) ConfigMapExists() bool

func (*NativeResourcePoller) Deployment

func (p *NativeResourcePoller) Deployment() *appsv1.Deployment

func (*NativeResourcePoller) DeploymentExists

func (p *NativeResourcePoller) DeploymentExists() bool

func (*NativeResourcePoller) DeploymentList

func (p *NativeResourcePoller) DeploymentList() *appsv1.DeploymentList

func (*NativeResourcePoller) GetPods

func (p *NativeResourcePoller) GetPods() []corev1.Pod

func (*NativeResourcePoller) GetRunningPods

func (p *NativeResourcePoller) GetRunningPods() []corev1.Pod

func (*NativeResourcePoller) IngressExists

func (p *NativeResourcePoller) IngressExists() bool

func (*NativeResourcePoller) IsRunning

func (p *NativeResourcePoller) IsRunning() bool

func (*NativeResourcePoller) NumberOfDeployments

func (p *NativeResourcePoller) NumberOfDeployments() int

func (*NativeResourcePoller) NumberOfOrdererNodeDeployments

func (p *NativeResourcePoller) NumberOfOrdererNodeDeployments() int

func (*NativeResourcePoller) PVCExists

func (p *NativeResourcePoller) PVCExists() bool

func (*NativeResourcePoller) PodCreated

func (p *NativeResourcePoller) PodCreated() bool

PodCreated returns true if pod has been created based on app name

func (*NativeResourcePoller) PodIsRunning

func (p *NativeResourcePoller) PodIsRunning() bool

func (*NativeResourcePoller) ServiceExists

func (p *NativeResourcePoller) ServiceExists() bool

func (*NativeResourcePoller) TestAffinityRegion

func (p *NativeResourcePoller) TestAffinityRegion(dep *appsv1.Deployment) bool

func (*NativeResourcePoller) TestAffinityZone

func (p *NativeResourcePoller) TestAffinityZone(dep *appsv1.Deployment) bool

type Operator

type Operator struct {
	NativeResourcePoller
}

func (*Operator) GetPod

func (o *Operator) GetPod() (*corev1.Pod, error)

func (*Operator) Restart

func (o *Operator) Restart() error

type SetupConfig

type SetupConfig struct {
	DockerConfigJson string
	KubeConfig       string
}

func GetConfig

func GetConfig() (*SetupConfig, error)