helpers

package
v1.5.0-beta3 Latest Latest
Warning

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

 Go to latest Published: Jan 26, 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"

	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 {
	Name       string
	PublicURL  string
	PrivateURL 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
	PrivateURL string
	TLSCACert  string
	RootCert   string
	Identity   Identity
	MSPID      string
}

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
	OrderingServices []*ClusterOrderingService
	Peers            []*ClusterPeer
}

type OrganizationType 

type OrganizationType = string

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.