helpers

package
v1.6.3-beta7 Latest Latest
Warning

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

Go to latest
Published: May 10, 2022 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 = "2.3.0-v0.0.2"

	DefaultFSServerImage   = "quay.io/kfsoftware/fs-peer"
	DefaultFSServerVersion = "amd64-2.2.0-0.0.1"

	DefaultCouchDBImage   = "couchdb"
	DefaultCouchDBVersion = "3.1.1"

	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 GetCAPrivateURL added in v1.4.0

func GetCAPrivateURL(node hlfv1alpha1.FabricCA) string

func GetCAPublicURL added in v1.4.0

func GetCAPublicURL(clientset *kubernetes.Clientset, node hlfv1alpha1.FabricCA) (string, error)

func GetClusterOrderers

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

func GetClusterPeers

func GetClusterPeers(
	clientSet *kubernetes.Clientset,
	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 GetOrdererAdminHostAndPort added in v1.5.0

func GetOrdererAdminHostAndPort(clientset *kubernetes.Clientset, nodeSpec hlfv1alpha1.FabricOrdererNodeSpec, nodeStatus hlfv1alpha1.FabricOrdererNodeStatus) (string, int, error)

func GetOrdererHostAndPort added in v1.5.0

func GetOrdererHostAndPort(clientset *kubernetes.Clientset, nodeSpec hlfv1alpha1.FabricOrdererNodeSpec, nodeStatus hlfv1alpha1.FabricOrdererNodeStatus) (string, int, error)

func GetOrdererPrivateURL added in v1.4.0

func GetOrdererPrivateURL(node hlfv1alpha1.FabricOrdererNode) string

func GetOrdererPublicURL added in v1.4.0

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

func GetPeerHostAndPort added in v1.5.0

func GetPeerHostAndPort(clientset *kubernetes.Clientset, nodeSpec hlfv1alpha1.FabricPeerSpec, nodeStatus hlfv1alpha1.FabricPeerStatus) (string, int, error)

func GetPeerPrivateURL added in v1.4.0

func GetPeerPrivateURL(node hlfv1alpha1.FabricPeer) string

func GetPeerPublicURL added in v1.4.0

func GetPeerPublicURL(clientset *kubernetes.Clientset, node hlfv1alpha1.FabricPeer) (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
	PublicURL  string
	PrivateURL string
	EnrollID   string
	EnrollPWD  string
	Item       hlfv1alpha1.FabricCA
}

func GetCertAuthByFullName

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

func GetCertAuthByName

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

func GetCertAuthByURL

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

func GetClusterCAs

func GetClusterCAs(clientSet *kubernetes.Clientset, 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 {
	ObjectMeta v1.ObjectMeta
	Name       string
	PublicURL  string
	PrivateURL string
	Spec       hlfv1alpha1.FabricOrdererNodeSpec
	Status     hlfv1alpha1.FabricOrdererNodeStatus
	Item       hlfv1alpha1.FabricOrdererNode
}

func GetClusterOrdererNodes added in v1.2.1

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

func GetOrdererNodeByFullName added in v1.2.1

func GetOrdererNodeByFullName(clientSet *kubernetes.Clientset, 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
	PrivateURL string
	TLSCACert  string
	RootCert   string
	Identity   Identity
	MSPID      string
	ObjectMeta v1.ObjectMeta
}

func GetPeerByFullName

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

type HostPort added in v1.4.0

type HostPort struct {
	Host string
	Port int
}

func GetCAHostPort added in v1.4.0

func GetCAHostPort(clientset *kubernetes.Clientset, node hlfv1alpha1.FabricCA) (*HostPort, error)

func GetOrdererHostPort added in v1.4.0

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

func GetPeerHostPort added in v1.4.0

func GetPeerHostPort(clientset *kubernetes.Clientset, node hlfv1alpha1.FabricPeer) (*HostPort, error)

type Identity

type Identity struct {
	Key  string
	Cert string
}

type Organization

type Organization struct {
	Type         OrganizationType
	MspID        string
	OrdererNodes []*ClusterOrdererNode
	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