helpers

package
v1.10.0 Latest Latest
Warning

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

 Go to latest Published: Feb 13, 2024 License: Apache-2.0 Imports: 26 Imported by: 2

Documentation

Index

Constants

View Source 
const (

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

	DefaultStorageclass = ""

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

	DefaultPeerImage   = "hyperledger/fabric-peer"
	DefaultPeerVersion = "2.5.5"

	DefaultOperationsConsoleImage   = "ghcr.io/hyperledger-labs/fabric-console"
	DefaultOperationsConsoleVersion = "latest"

	DefaultOperationsOperatorUIImage   = "ghcr.io/kfsoftware/hlf-operator-ui"
	DefaultOperationsOperatorUIVersion = "0.0.16"

	DefaultOperationsOperatorAPIImage   = "ghcr.io/kfsoftware/hlf-operator-api"
	DefaultOperationsOperatorAPIVersion = "v0.0.16"

	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 = "2.5.5"
)
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 GetAdminOrdererPublicURL added in v1.10.0 

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

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
	Namespace  string
}

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 MapClusterCA added in v1.7.0 

func MapClusterCA(clientSet *kubernetes.Clientset, certAuth hlfv1alpha1.FabricCA) (*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
	AdminURL   string
	Spec       hlfv1alpha1.FabricOrdererNodeSpec
	Status     hlfv1alpha1.FabricOrdererNodeStatus
	Item       hlfv1alpha1.FabricOrdererNode
	Namespace  string
}

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)

func MapClusterOrdererNode added in v1.7.0 

func MapClusterOrdererNode(clientSet *kubernetes.Clientset, ordNode hlfv1alpha1.FabricOrdererNode) (*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
	Object     hlfv1alpha1.FabricPeer
	Spec       hlfv1alpha1.FabricPeerSpec
	Status     hlfv1alpha1.FabricPeerStatus
	PublicURL  string
	PrivateURL string
	TLSCACert  string
	RootCert   string
	Identity   Identity
	MSPID      string
	ObjectMeta v1.ObjectMeta
	Namespace  string
}

func GetPeerByFullName 

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

func MapClusterPeer added in v1.7.0 

func MapClusterPeer(clientSet *kubernetes.Clientset, peer hlfv1alpha1.FabricPeer) (*ClusterPeer, error)

type HLFLoggerProvider added in v1.10.0 

type HLFLoggerProvider struct{}

func (HLFLoggerProvider) GetLogger added in v1.10.0 

func (f HLFLoggerProvider) GetLogger(module string) api.Logger

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 OrgUser added in v1.9.0 

type OrgUser struct {
	Name string
	Cert string
	Key  string
}

type Organization 

type Organization struct {
	Type         OrganizationType
	MspID        string
	OrdererNodes []*ClusterOrdererNode
	Peers        []*ClusterPeer
	Users        []OrgUser
}

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.