sync

Documentation

Overview

When there is a large amount of data in Etcd, there is a query bottleneck, especially with the List interface. Therefore, the Sync package can be used to continuously synchronize data from Etcd to the MySQL database in real-time. When onex-gateway performs list queries, it can directly query from the MySQL database.

Index

• func GetMinerConfig(annotations map[string]string) (cpu int32, mem int32)
• type ChainSyncReconciler
  • func (r *ChainSyncReconciler) Reconcile(ctx context.Context, rq ctrl.Request) (ctrl.Result, error)
  • func (r *ChainSyncReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, options controller.Options) error
• type MinerSetSyncReconciler
  • func (r *MinerSetSyncReconciler) Reconcile(ctx context.Context, rq ctrl.Request) (ctrl.Result, error)
  • func (r *MinerSetSyncReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, options controller.Options) error
• type MinerSyncReconciler
  • func (r *MinerSyncReconciler) Reconcile(ctx context.Context, rq ctrl.Request) (ctrl.Result, error)
  • func (r *MinerSyncReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, options controller.Options) error

Functions

func GetMinerConfig

func GetMinerConfig(annotations map[string]string) (cpu int32, mem int32)

Types

type ChainSyncReconciler

type ChainSyncReconciler struct {
	Store store.IStore
	// contains filtered or unexported fields
}

ChainSyncReconciler sync a Chain object to database.

func (*ChainSyncReconciler) Reconcile

func (r *ChainSyncReconciler) Reconcile(ctx context.Context, rq ctrl.Request) (ctrl.Result, error)

func (*ChainSyncReconciler) SetupWithManager

func (r *ChainSyncReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, options controller.Options) error

SetupWithManager sets up the controller with the Manager.

type MinerSetSyncReconciler

type MinerSetSyncReconciler struct {
	Store store.IStore
	// contains filtered or unexported fields
}

MinerSetSyncReconciler sync a MinerSet object to database.

func (*MinerSetSyncReconciler) Reconcile

func (r *MinerSetSyncReconciler) Reconcile(ctx context.Context, rq ctrl.Request) (ctrl.Result, error)

func (*MinerSetSyncReconciler) SetupWithManager

func (r *MinerSetSyncReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, options controller.Options) error

SetupWithManager sets up the controller with the Manager.

type MinerSyncReconciler

type MinerSyncReconciler struct {
	Store store.IStore
	// contains filtered or unexported fields
}

MinerSyncReconciler sync a Miner object to database.

func (*MinerSyncReconciler) Reconcile

func (r *MinerSyncReconciler) Reconcile(ctx context.Context, rq ctrl.Request) (ctrl.Result, error)

func (*MinerSyncReconciler) SetupWithManager

func (r *MinerSyncReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, options controller.Options) error

SetupWithManager sets up the controller with the Manager.