ordnode

Documentation

Index

• Variables
• func CreateSignCryptoMaterial(conf *hlfv1alpha1.FabricOrdererNode, caName string, caurl string, ...) (*x509.Certificate, *ecdsa.PrivateKey, *x509.Certificate, error)
• func CreateTLSAdminCryptoMaterial(conf *hlfv1alpha1.FabricOrdererNode, caName string, caurl string, ...) (*x509.Certificate, *ecdsa.PrivateKey, *x509.Certificate, *x509.Certificate, ...)
• func CreateTLSCryptoMaterial(conf *hlfv1alpha1.FabricOrdererNode, caName string, caurl string, ...) (*x509.Certificate, *ecdsa.PrivateKey, *x509.Certificate, error)
• func GetOrdererDeployment(conf *action.Configuration, config *rest.Config, releaseName string, ns string) (*appsv1.Deployment, error)
• func GetOrdererState(conf *action.Configuration, config *rest.Config, releaseName string, ns string, ...) (*hlfv1alpha1.FabricOrdererNodeStatus, error)
• func ReenrollSignCryptoMaterial(conf *hlfv1alpha1.FabricOrdererNode, caName string, caurl string, ...) (*x509.Certificate, *ecdsa.PrivateKey, *x509.Certificate, error)
• func ReenrollTLSAdminCryptoMaterial(conf *hlfv1alpha1.FabricOrdererNode, caName string, caurl string, ...) (*x509.Certificate, *ecdsa.PrivateKey, *x509.Certificate, *x509.Certificate, ...)
• func ReenrollTLSCryptoMaterial(conf *hlfv1alpha1.FabricOrdererNode, caName string, caurl string, ...) (*x509.Certificate, *ecdsa.PrivateKey, *x509.Certificate, error)
• type FabricOrdererNodeReconciler
  • func (r *FabricOrdererNodeReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *FabricOrdererNodeReconciler) SetupWithManager(mgr ctrl.Manager) error
• type GRPCProxy
• type HostAlias
• type Istio
• type Limits
• type Logging
• type Requests
• type Resources
• type ServiceMonitor

Variables

var (
	ErrClientK8s = errors.New("k8sAPIClientError")
)

Functions

func CreateSignCryptoMaterial

func CreateSignCryptoMaterial(conf *hlfv1alpha1.FabricOrdererNode, caName string, caurl string, enrollID string, enrollSecret string, tlsCertString string) (*x509.Certificate, *ecdsa.PrivateKey, *x509.Certificate, error)

func CreateTLSAdminCryptoMaterial

func CreateTLSAdminCryptoMaterial(conf *hlfv1alpha1.FabricOrdererNode, caName string, caurl string, enrollID string, enrollSecret string, tlsCertString string, hosts []string) (*x509.Certificate, *ecdsa.PrivateKey, *x509.Certificate, *x509.Certificate, error)

func CreateTLSCryptoMaterial

func CreateTLSCryptoMaterial(conf *hlfv1alpha1.FabricOrdererNode, caName string, caurl string, enrollID string, enrollSecret string, tlsCertString string, hosts []string) (*x509.Certificate, *ecdsa.PrivateKey, *x509.Certificate, error)

func GetOrdererDeployment

func GetOrdererDeployment(conf *action.Configuration, config *rest.Config, releaseName string, ns string) (*appsv1.Deployment, error)

func GetOrdererState

func GetOrdererState(conf *action.Configuration, config *rest.Config, releaseName string, ns string, ordNode *hlfv1alpha1.FabricOrdererNode) (*hlfv1alpha1.FabricOrdererNodeStatus, error)

func ReenrollSignCryptoMaterial

func ReenrollSignCryptoMaterial(
	conf *hlfv1alpha1.FabricOrdererNode,
	caName string,
	caurl string,
	enrollID string,
	tlsCertString string,
	signCertPem string,
	privateKey *ecdsa.PrivateKey,
) (*x509.Certificate, *ecdsa.PrivateKey, *x509.Certificate, error)

func ReenrollTLSAdminCryptoMaterial

func ReenrollTLSAdminCryptoMaterial(
	conf *hlfv1alpha1.FabricOrdererNode,
	caName string,
	caurl string,
	enrollID string,
	tlsCertString string,
	hosts []string,
	tlsCertPem string,
	tlsKey *ecdsa.PrivateKey,
) (*x509.Certificate, *ecdsa.PrivateKey, *x509.Certificate, *x509.Certificate, error)

func ReenrollTLSCryptoMaterial

func ReenrollTLSCryptoMaterial(
	conf *hlfv1alpha1.FabricOrdererNode,
	caName string,
	caurl string,
	enrollID string,
	tlsCertString string,
	hosts []string,
	tlsCertPem string,
	tlsKey *ecdsa.PrivateKey,
) (*x509.Certificate, *ecdsa.PrivateKey, *x509.Certificate, error)

Types

type FabricOrdererNodeReconciler

type FabricOrdererNodeReconciler struct {
	client.Client
	ChartPath                  string
	Log                        logr.Logger
	Scheme                     *runtime.Scheme
	Config                     *rest.Config
	AutoRenewCertificates      bool
	AutoRenewCertificatesDelta time.Duration
}

FabricOrdererNodeReconciler reconciles a FabricOrdererNode object

func (*FabricOrdererNodeReconciler) Reconcile

func (r *FabricOrdererNodeReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+kubebuilder:rbac:groups=hlf.kungfusoftware.es,resources=fabricorderernodes,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=hlf.kungfusoftware.es,resources=fabricorderernodes/status,verbs=get;update;patch +kubebuilder:rbac:groups=hlf.kungfusoftware.es,resources=fabricorderernodes/finalizers,verbs=get;update;patch

func (*FabricOrdererNodeReconciler) SetupWithManager

func (r *FabricOrdererNodeReconciler) SetupWithManager(mgr ctrl.Manager) error

type GRPCProxy

type GRPCProxy struct {
	Enabled          bool                          `json:"enabled"`
	Image            string                        `json:"image"`
	Tag              string                        `json:"tag"`
	PullPolicy       string                        `json:"pullPolicy"`
	ImagePullSecrets []corev1.LocalObjectReference `json:"imagePullSecrets"`
	Istio            Istio                         `json:"istio"`

	// +optional
	// +nullable
	Resources *corev1.ResourceRequirements `json:"resources"`
}

type HostAlias

type HostAlias struct {
	IP        string   `json:"ip"`
	Hostnames []string `json:"hostnames"`
}

type Istio

type Istio struct {
	Port           int      `json:"port"`
	Hosts          []string `json:"hosts"`
	IngressGateway string   `json:"ingressGateway"`
}

type Limits

type Limits struct {
	CPU    string `json:"cpu"`
	Memory string `json:"memory"`
}

type Logging

type Logging struct {
	Spec string `json:"spec"`
}

type Requests

type Requests struct {
	CPU    string `json:"cpu"`
	Memory string `json:"memory"`
}

type Resources

type Resources struct {
	Limits   Limits   `json:"limits"`
	Requests Requests `json:"requests"`
}

type ServiceMonitor

type ServiceMonitor struct {
	Enabled           bool              `json:"enabled"`
	Labels            map[string]string `json:"labels"`
	Interval          string            `json:"interval"`
	ScrapeTimeout     string            `json:"scrapeTimeout"`
	Scheme            string            `json:"scheme"`
	Relabelings       []interface{}     `json:"relabelings"`
	TargetLabels      []interface{}     `json:"targetLabels"`
	MetricRelabelings []interface{}     `json:"metricRelabelings"`
	SampleLimit       int               `json:"sampleLimit"`
}