Documentation ¶
Index ¶
- Constants
- func CreateConfigUpdateEnvelope(channelID string, configUpdate *common.ConfigUpdate) ([]byte, error)
- func ExecKubectl(ctx context.Context, args ...string) ([]byte, error)
- func GetClusterOrderers(clientSet *kubernetes.Clientset, oclient *operatorv1.Clientset, ns string) ([]*Organization, []*ClusterOrderingService, error)
- func GetClusterPeers(oclient *operatorv1.Clientset, ns string) ([]*Organization, []*ClusterPeer, error)
- func GetCollectionConfigFromBytes(cconfBytes []byte) ([]*pb.CollectionConfig, error)
- func GetConfigEnvelopeBytes(configUpdate *common.ConfigUpdate) ([]byte, error)
- func GetCurrentConfigFromPeer(resClient *resmgmt.Client, channelID string) (*common.Config, error)
- func GetKubeClient() (*kubernetes.Clientset, error)
- func GetKubeExtensionClient() (*apiextension.Clientset, error)
- func GetKubeOperatorClient() (*operatorv1.Clientset, error)
- func GetOrdererPublicURL(clientset *kubernetes.Clientset, node hlfv1alpha1.FabricOrdererNode) (string, error)
- func GetURLForCA(certAuth *ClusterCA) (string, error)
- func MarshallWithoutStatus(item interface{}) ([]byte, error)
- func ToYaml(objs []runtime.Object) ([]string, error)
- type ClusterCA
- func GetCertAuthByFullName(oclient *operatorv1.Clientset, name string) (*ClusterCA, error)
- func GetCertAuthByName(oclient *operatorv1.Clientset, name string, ns string) (*ClusterCA, error)
- func GetCertAuthByURL(oclient *operatorv1.Clientset, host string, port int) (*ClusterCA, error)
- func GetClusterCAs(oclient *operatorv1.Clientset, ns string) ([]*ClusterCA, error)
- type ClusterOrdererNode
- type ClusterOrderingService
- type ClusterPeer
- type HostPort
- type Identity
- type Organization
- type OrganizationType
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 ¶
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 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 MarshallWithoutStatus ¶ added in v1.4.0
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 GetCertAuthByURL ¶
func GetClusterCAs ¶
func GetClusterCAs(oclient *operatorv1.Clientset, ns string) ([]*ClusterCA, error)
func (ClusterCA) GetFullName ¶ added in v1.2.1
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
func GetOrdererHostPort ¶ added in v1.4.0
func GetOrdererHostPort(clientset *kubernetes.Clientset, node hlfv1alpha1.FabricOrdererNode) (*HostPort, error)
type Organization ¶
type Organization struct { Type OrganizationType MspID string OrderingServices []*ClusterOrderingService Peers []*ClusterPeer }
type OrganizationType ¶
type OrganizationType = string
Source Files ¶
Click to show internal directories.
Click to hide internal directories.