util

package

v1.3.3-testnet Latest Latest Go to latest Published: Mar 28, 2024 License: MIT Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

func GracefulShutdown(wg *sync.WaitGroup, cancel context.CancelFunc)

GracefulShutdown supports to clean up goroutines after termination signal captured.

func StartAndGracefulShutdown(run func(ctx context.Context, wg *sync.WaitGroup))

StartAndGracefulShutdown starts to run the specified task in a goroutine and wait for termination signal to shutdown gracefully.

Note, this method is not suitable for any non-blocking task that release resources in defer way.

type GracefulShutdownContext struct {
	Ctx context.Context
	Wg  *sync.WaitGroup
}

GracefulShutdownContext wraps context and wait group which can be utilized to handle graceful shutdown on termination signal received.

type StoreContext struct {
	CfxDB    *mysql.MysqlStore
	EthDB    *mysql.MysqlStore
	CfxCache *redis.RedisStore
}

StoreContext context to hold store instances

func MustInitStoreContext() StoreContext

func (ctx *StoreContext) Close()

func (ctx *StoreContext) GetMysqlStore(network string) (store *mysql.MysqlStore, err error)

GetMysqlStore returns mysql store by network space

type SyncContext struct {
	StoreContext

	SyncCfx *sdk.Client
	SubCfx  *sdk.Client
	SyncEth *web3go.Client
}

SyncContext context to hold sdk clients for blockchain interoperation.

func MustInitSyncContext(storeCtx StoreContext) SyncContext

func (ctx *SyncContext) Close()