concurrent

Documentation

Index

• Constants
• func NewAsyncLocalClient(app types.Application, log log.Logger, rwLock *sync.RWMutex, ...) *asyncLocalClient
• func NewAsyncLocalClientCreator(app types.Application, log log.Logger) proxy.ClientCreator
• type ApplicationCC
• type WorkItem

Constants

const (
	WorkerPoolSize  = 16
	WorkerPoolSpawn = 4
	WorkerPoolQueue = 16
)

Functions

func NewAsyncLocalClient

func NewAsyncLocalClient(app types.Application, log log.Logger,
	rwLock *sync.RWMutex, wgCommit *sync.WaitGroup,
	commitLock, checkTxLowLock, checkTxMidLock *sync.Mutex) *asyncLocalClient

func NewAsyncLocalClientCreator

func NewAsyncLocalClientCreator(app types.Application, log log.Logger) proxy.ClientCreator

Types

type ApplicationCC

type ApplicationCC interface {
	types.Application
	PreCheckTx(req types.RequestCheckTx) types.ResponseCheckTx
	PreDeliverTx(req types.RequestDeliverTx) types.ResponseDeliverTx
}

type WorkItem

type WorkItem struct {
	// contains filtered or unexported fields
}