helpers

package
v1.4.0-beta2 Latest Latest
Warning

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

Go to latest
Published: Oct 29, 2021 License: Apache-2.0 Imports: 25 Imported by: 20

Documentation

Index

Constants

View Source
const (

	// DefaultNamespace is the default namespace for all operations
	DefaultNamespace = "default"

	DefaultStorageclass = ""

	DefaultCAImage   = "hyperledger/fabric-ca"
	DefaultCAVersion = "1.4.9"

	DefaultPeerImage   = "quay.io/kfsoftware/fabric-peer"
	DefaultPeerVersion = "amd64-2.3.0"

	DefaultOrdererImage   = "hyperledger/fabric-orderer"
	DefaultOrdererVersion = "amd64-2.3.0"
)
View Source
const (
	PeerType    = "PEER"
	OrdererType = "ORDERER"
)

Variables

This section is empty.

Functions

func CreateConfigUpdateEnvelope added in v1.4.0

func CreateConfigUpdateEnvelope(channelID string, configUpdate *common.ConfigUpdate) ([]byte, error)

func ExecKubectl

func ExecKubectl(ctx context.Context, args ...string) ([]byte, error)

ExecKubectl executes the given command using `kubectl`

func GetClusterOrderers

func GetClusterOrderers(
	clientSet *kubernetes.Clientset,
	oclient *operatorv1.Clientset,
	ns string,
) ([]*Organization, []*ClusterOrderingService, error)

func GetClusterPeers

func GetClusterPeers(oclient *operatorv1.Clientset, ns string) ([]*Organization, []*ClusterPeer, error)

func GetCollectionConfigFromBytes

func GetCollectionConfigFromBytes(cconfBytes []byte) ([]*pb.CollectionConfig, error)

func GetConfigEnvelopeBytes added in v1.4.0

func GetConfigEnvelopeBytes(configUpdate *common.ConfigUpdate) ([]byte, error)

func GetCurrentConfigFromPeer added in v1.4.0

func GetCurrentConfigFromPeer(resClient *resmgmt.Client, channelID string) (*common.Config, error)

func GetKubeClient

func GetKubeClient() (*kubernetes.Clientset, error)

GetKubeClient provides k8s client for kubeconfig

func GetKubeExtensionClient

func GetKubeExtensionClient() (*apiextension.Clientset, error)

GetKubeExtensionClient provides k8s client for CRDs

func GetKubeOperatorClient

func GetKubeOperatorClient() (*operatorv1.Clientset, error)

GetKubeOperatorClient provides k8s client for operator

func GetOrdererPublicURL added in v1.4.0

func GetOrdererPublicURL(clientset *kubernetes.Clientset, node hlfv1alpha1.FabricOrdererNode) (string, error)

func GetURLForCA added in v1.3.1

func GetURLForCA(certAuth *ClusterCA) (string, error)

func MarshallWithoutStatus added in v1.4.0

func MarshallWithoutStatus(item interface{}) ([]byte, error)

func ToYaml

func ToYaml(objs []runtime.Object) ([]string, error)

ToYaml takes a slice of values, and returns corresponding YAML representation as a string slice

Types

type ClusterCA

type ClusterCA struct {
	Object hlfv1alpha1.FabricCA
	Spec   hlfv1alpha1.FabricCASpec
	Status hlfv1alpha1.FabricCAStatus
	Name   string
	Item   hlfv1alpha1.FabricCA
}

func GetCertAuthByFullName

func GetCertAuthByFullName(oclient *operatorv1.Clientset, name string) (*ClusterCA, error)

func GetCertAuthByName

func GetCertAuthByName(oclient *operatorv1.Clientset, name string, ns string) (*ClusterCA, error)

func GetCertAuthByURL

func GetCertAuthByURL(oclient *operatorv1.Clientset, host string, port int) (*ClusterCA, error)

func GetClusterCAs

func GetClusterCAs(oclient *operatorv1.Clientset, ns string) ([]*ClusterCA, error)

func (ClusterCA) GetFullName added in v1.2.1

func (c ClusterCA) GetFullName() string

type ClusterOrdererNode

type ClusterOrdererNode struct {
	Name      string
	PublicURL string
	Spec      hlfv1alpha1.FabricOrdererNodeSpec
	Status    hlfv1alpha1.FabricOrdererNodeStatus
	Item      hlfv1alpha1.FabricOrdererNode
}

func GetClusterOrdererNodes added in v1.2.1

func GetClusterOrdererNodes(
	oclient *operatorv1.Clientset,
	ns string,
) ([]*ClusterOrdererNode, error)

func GetOrdererNodeByFullName added in v1.2.1

func GetOrdererNodeByFullName(oclient *operatorv1.Clientset, name string) (*ClusterOrdererNode, error)

type ClusterOrderingService

type ClusterOrderingService struct {
	MSPID    string
	Name     string
	Object   hlfv1alpha1.FabricOrderingService
	Spec     hlfv1alpha1.FabricOrderingServiceSpec
	Status   hlfv1alpha1.FabricOrderingServiceStatus
	Orderers []*ClusterOrdererNode
}

func GetOrderingServiceByFullName

func GetOrderingServiceByFullName(clientSet *kubernetes.Clientset, oclient *operatorv1.Clientset, name string) (*ClusterOrderingService, error)

type ClusterPeer

type ClusterPeer struct {
	Name      string
	Spec      hlfv1alpha1.FabricPeerSpec
	Status    hlfv1alpha1.FabricPeerStatus
	PublicURL string
	TLSCACert string
	RootCert  string
	Identity  Identity
}

func GetPeerByFullName

func GetPeerByFullName(oclient *operatorv1.Clientset, name string) (*ClusterPeer, error)

type HostPort added in v1.4.0

type HostPort struct {
	Host string
	Port int
}

func GetOrdererHostPort added in v1.4.0

func GetOrdererHostPort(clientset *kubernetes.Clientset, node hlfv1alpha1.FabricOrdererNode) (*HostPort, error)

type Identity

type Identity struct {
	Key  string
	Cert string
}

type Organization

type Organization struct {
	Type             OrganizationType
	MspID            string
	OrderingServices []*ClusterOrderingService
	Peers            []*ClusterPeer
}

type OrganizationType

type OrganizationType = string

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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