Documentation
¶
Index ¶
- func GetCoreFromConfigMap(client k8sclient.Client, instance *current.IBPPeer) (*corev1.ConfigMap, error)
- type Config
- type CoreConfig
- type CoreConfigMap
- type IBPPeer
- type Initializer
- func (i *Initializer) CheckIfAdminCertsUpdated(instance *current.IBPPeer) (bool, error)
- func (i *Initializer) CoreConfigMap() *CoreConfigMap
- func (i *Initializer) Create(overrides CoreConfig, peer IBPPeer, storagePath string) (*Response, error)
- func (i *Initializer) CreateOrUpdateSecret(instance *current.IBPPeer, name string, data map[string][]byte) error
- func (i *Initializer) GenerateOrdererCACertsSecret(instance *current.IBPPeer, certs map[string][]byte) error
- func (i *Initializer) GenerateSecrets(prefix common.SecretType, instance metav1.Object, crypto *config.Response) error
- func (i *Initializer) GenerateSecretsFromResponse(instance *current.IBPPeer, cryptoResponse *config.CryptoResponse) error
- func (i *Initializer) GetCrypto(instance *current.IBPPeer) (*config.CryptoResponse, error)
- func (i *Initializer) GetEnrollers(cryptos *config.Cryptos, instance *current.IBPPeer, storagePath string) error
- func (i *Initializer) GetInitPeer(instance *current.IBPPeer, storagePath string) (*Peer, error)
- func (i *Initializer) GetMSPCrypto(cryptos *config.Cryptos, instance *current.IBPPeer) error
- func (i *Initializer) GetUpdatedPeer(instance *current.IBPPeer) (*Peer, error)
- func (i *Initializer) MissingCrypto(instance *current.IBPPeer) bool
- func (i *Initializer) Update(overrides CoreConfig, peer IBPPeer) (*Response, error)
- func (i *Initializer) UpdateAdminSecret(instance *current.IBPPeer) error
- func (i *Initializer) UpdateSecrets(prefix common.SecretType, instance *current.IBPPeer, crypto *config.Response) error
- func (i *Initializer) UpdateSecretsFromResponse(instance *current.IBPPeer, cryptoResponse *config.CryptoResponse) error
- type Peer
- type PeerConfig
- type Response
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Config ¶
type Config struct {
OUFile string
InterOUFile string
CorePeerFile string
CorePeerV2File string
DeploymentFile string
PVCFile string
CouchDBPVCFile string
ServiceFile string
RoleFile string
ServiceAccountFile string
RoleBindingFile string
FluentdConfigMapFile string
CouchContainerFile string
CouchInitContainerFile string
IngressFile string
Ingressv1beta1File string
CCLauncherFile string
RouteFile string
StoragePath string
}
type CoreConfig ¶
type CoreConfig interface {
MergeWith(interface{}, bool) error
GetAddressOverrides() []v1.AddressOverride
ToBytes() ([]byte, error)
UsingPKCS11() bool
SetPKCS11Defaults(bool)
GetBCCSPSection() *commonapi.BCCSP
SetBCCSPLibrary(string)
}
func GetCoreConfigFromBytes ¶
func GetCoreConfigFromBytes(instance *current.IBPPeer, bytes []byte) (CoreConfig, error)
func GetCoreConfigFromFile ¶
func GetCoreConfigFromFile(instance *current.IBPPeer, file string) (CoreConfig, error)
type CoreConfigMap ¶
type CoreConfigMap struct {
Config *Config
Scheme *runtime.Scheme
GetLabels func(instance metav1.Object) map[string]string
Client k8sclient.Client
}
func (*CoreConfigMap) AddNodeOU ¶
func (c *CoreConfigMap) AddNodeOU(instance *current.IBPPeer) error
func (*CoreConfigMap) CreateOrUpdate ¶
func (c *CoreConfigMap) CreateOrUpdate(instance *current.IBPPeer, peer CoreConfig) error
func (*CoreConfigMap) GetCoreConfig ¶
type IBPPeer ¶
type IBPPeer interface {
DeliveryClientCrypto() map[string][]byte
OverrideConfig(CoreConfig) error
GenerateCrypto() (*config.CryptoResponse, error)
GetConfig() CoreConfig
}
type Initializer ¶
type Initializer struct {
Config *Config
Scheme *runtime.Scheme
GetLabels func(instance metav1.Object) map[string]string
Timeouts enroller.HSMEnrollJobTimeouts
Client k8sclient.Client
Validator common.CryptoValidator
SecretManager *secretmanager.SecretManager
// contains filtered or unexported fields
}
func New ¶
func New(config *Config, scheme *runtime.Scheme, client k8sclient.Client, labels func(instance metav1.Object) map[string]string, validator common.CryptoValidator, timeouts enroller.HSMEnrollJobTimeouts) *Initializer
func (*Initializer) CheckIfAdminCertsUpdated ¶
func (i *Initializer) CheckIfAdminCertsUpdated(instance *current.IBPPeer) (bool, error)
func (*Initializer) CoreConfigMap ¶
func (i *Initializer) CoreConfigMap() *CoreConfigMap
func (*Initializer) Create ¶
func (i *Initializer) Create(overrides CoreConfig, peer IBPPeer, storagePath string) (*Response, error)
func (*Initializer) CreateOrUpdateSecret ¶
func (*Initializer) GenerateOrdererCACertsSecret ¶
func (*Initializer) GenerateSecrets ¶
func (i *Initializer) GenerateSecrets(prefix common.SecretType, instance metav1.Object, crypto *config.Response) error
func (*Initializer) GenerateSecretsFromResponse ¶
func (i *Initializer) GenerateSecretsFromResponse(instance *current.IBPPeer, cryptoResponse *config.CryptoResponse) error
func (*Initializer) GetCrypto ¶
func (i *Initializer) GetCrypto(instance *current.IBPPeer) (*config.CryptoResponse, error)
func (*Initializer) GetEnrollers ¶
func (*Initializer) GetInitPeer ¶
func (*Initializer) GetMSPCrypto ¶
func (*Initializer) GetUpdatedPeer ¶
func (i *Initializer) GetUpdatedPeer(instance *current.IBPPeer) (*Peer, error)
func (*Initializer) MissingCrypto ¶
func (i *Initializer) MissingCrypto(instance *current.IBPPeer) bool
func (*Initializer) Update ¶
func (i *Initializer) Update(overrides CoreConfig, peer IBPPeer) (*Response, error)
func (*Initializer) UpdateAdminSecret ¶
func (i *Initializer) UpdateAdminSecret(instance *current.IBPPeer) error
func (*Initializer) UpdateSecrets ¶
func (i *Initializer) UpdateSecrets(prefix common.SecretType, instance *current.IBPPeer, crypto *config.Response) error
func (*Initializer) UpdateSecretsFromResponse ¶
func (i *Initializer) UpdateSecretsFromResponse(instance *current.IBPPeer, cryptoResponse *config.CryptoResponse) error
type Peer ¶
type Peer struct {
Config CoreConfig
Cryptos *commonconfig.Cryptos
UsingHSMProxy bool
}
func (*Peer) DeliveryClientCrypto ¶
func (*Peer) GenerateCrypto ¶
func (p *Peer) GenerateCrypto() (*commonconfig.CryptoResponse, error)
func (*Peer) GetConfig ¶
func (p *Peer) GetConfig() CoreConfig
func (*Peer) OverrideConfig ¶
func (p *Peer) OverrideConfig(newConfig CoreConfig) (err error)
type PeerConfig ¶
type Response ¶
type Response struct {
Config CoreConfig
Crypto *config.CryptoResponse
DeliveryClientCerts map[string][]byte
}
Directories
¶
| Path | Synopsis |
|---|---|
|
config
|
|
|
commoncore
* Copyright contributors to the Hyperledger Fabric Operator project * * SPDX-License-Identifier: Apache-2.0 * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License.
|
* Copyright contributors to the Hyperledger Fabric Operator project * * SPDX-License-Identifier: Apache-2.0 * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. |
|
Code generated by counterfeiter.
|
Code generated by counterfeiter. |
Click to show internal directories.
Click to hide internal directories.