Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

controllers

package

Go to main page

Versions in this module

v0

v0.0.3

Apr 27, 2022

Changes in this version

+ const ConsensusRPCPort

+ const ControllerRPCPort

+ const ExecutorRPCPort

+ const KmsRPCPort

+ const NetworkRPCPort

+ const StorageRPCPort

v0.0.2

Apr 18, 2022

v0.0.1

Mar 25, 2022

Changes in this version

+ const AccountVolumeMountPath

+ const AccountVolumeName

+ const CaCert

+ const CaKey

+ const ConsensusContainer

+ const ConsensusLogConfigFile

+ const ControllerContainer

+ const ControllerLogConfigFile

+ const ControllerPort

+ const DataVolumeMountPath

+ const DataVolumeName

+ const ExecutorContainer

+ const ExecutorLogConfigFile

+ const ExecutorPort

+ const KmsContainer

+ const KmsLogConfigFile

+ const LogConfigVolumeMountPath

+ const LogConfigVolumeName

+ const LogDir

+ const NetworkContainer

+ const NetworkLogConfigFile

+ const NetworkPort

+ const NodeCert

+ const NodeConfigFile

+ const NodeConfigVolumeMountPath

+ const NodeConfigVolumeName

+ const NodeCsr

+ const NodeKey

+ const StorageContainer

+ const StorageLogConfigFile

+ func DiffObject(old, new client.Object) ([]byte, error)

+ func GeneratePVC(chainNode *citacloudv1.ChainNode) []corev1.PersistentVolumeClaim

+ func GetAccountCertAndKeySecretName(account string) string

+ func GetAccountConfigmap(account string) string

+ func GetCaSecretName(chainName string) string

+ func GetLogConfigName(nodeName string) string

+ func GetNodeConfigName(nodeName string) string

+ func GetNodePortServiceName(nodeName string) string

+ func GetVolumes(chainNode *citacloudv1.ChainNode) []corev1.Volume

+ func IsEqual(obj1, obj2 interface{}) bool

+ func LabelsForChain(name string) map[string]string

+ func LabelsForNode(chainName, nodeName string) map[string]string

+ func MergeLabels(allLabels ...map[string]string) map[string]string

+ type AccountReconciler struct

+ Scheme *runtime.Scheme

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

+ func (r *AccountReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type ChainConfigReconciler struct

+ Scheme *runtime.Scheme

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

+ func (r *ChainConfigReconciler) SetDefaultSpec(chainConfig *citacloudv1.ChainConfig) error

+ func (r *ChainConfigReconciler) SetDefaultStatus(ctx context.Context, chainConfig *citacloudv1.ChainConfig) (bool, error)

+ func (r *ChainConfigReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type ChainNodeReconciler struct

+ Scheme *runtime.Scheme

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

+ func (r *ChainNodeReconciler) ReconcileAllRecourse(ctx context.Context, chainConfig *citacloudv1.ChainConfig, ...) error

+ func (r *ChainNodeReconciler) ReconcileConfigMap(ctx context.Context, chainConfig *citacloudv1.ChainConfig, ...) (bool, error)

+ func (r *ChainNodeReconciler) ReconcileLogConfigMap(ctx context.Context, chainConfig *citacloudv1.ChainConfig, ...) (bool, error)

+ func (r *ChainNodeReconciler) ReconcileService(ctx context.Context, chainConfig *citacloudv1.ChainConfig, ...) error

+ func (r *ChainNodeReconciler) ReconcileStatefulSet(ctx context.Context, chainConfig *citacloudv1.ChainConfig, ...) (bool, error)

+ func (r *ChainNodeReconciler) SetDefaultSpec(ctx context.Context, chainConfig *citacloudv1.ChainConfig, ...) error

+ func (r *ChainNodeReconciler) SetDefaultStatus(ctx context.Context, chainNode *citacloudv1.ChainNode) (bool, error)

+ func (r *ChainNodeReconciler) SetupWithManager(mgr ctrl.Manager) error

+ func (r *ChainNodeReconciler) SyncRunningStatus(ctx context.Context, chainConfig *citacloudv1.ChainConfig, ...) error

+ func (r *ChainNodeReconciler) SyncStopStatus(ctx context.Context, chainNode *citacloudv1.ChainNode) error

+ type ChainNodeService struct

+ Account *citacloudv1.Account

+ CaSecret *corev1.Secret

+ ChainConfig *citacloudv1.ChainConfig

+ ChainNode *citacloudv1.ChainNode

+ NodeCertAndKeySecret *corev1.Secret

+ func NewChainNodeServiceForLog(chainConfig *citacloudv1.ChainConfig, chainNode *citacloudv1.ChainNode) *ChainNodeService

+ func NewChainNodeServiceForP2P(chainConfig *citacloudv1.ChainConfig, chainNode *citacloudv1.ChainNode, ...) *ChainNodeService

+ func NewChainNodeServiceForTls(chainConfig *citacloudv1.ChainConfig, chainNode *citacloudv1.ChainNode, ...) *ChainNodeService

+ func (cns *ChainNodeService) GenerateConsensusLogConfig() string

+ func (cns *ChainNodeService) GenerateControllerLogConfig() string

+ func (cns *ChainNodeService) GenerateExecutorLogConfig() string

+ func (cns *ChainNodeService) GenerateKmsLogConfig() string

+ func (cns *ChainNodeService) GenerateNetworkLogConfig() string

+ func (cns *ChainNodeService) GenerateNodeConfig() string

+ func (cns *ChainNodeService) GenerateStorageLogConfig() string

+ type ChainNodeServiceImpl interface

+ GenerateConsensusLogConfig func() string

+ GenerateControllerLogConfig func() string

+ GenerateExecutorLogConfig func() string

+ GenerateKmsLogConfig func() string

+ GenerateNetworkLogConfig func() string

+ GenerateNodeConfig func() string

+ GenerateStorageLogConfig func() string