Documentation
¶
Index ¶
Constants ¶
View Source
const ( InputDataSourceFile = "file" InputDataSourceArgs = "args" InputDataSourceStdin = "stdin" )
View Source
const (
ArgForkID = "fork-id"
)
Variables ¶
View Source
var Cmd = &cobra.Command{ Use: "publish", Short: "Publish transactions to the network with high-throughput.", Long: cmdUsage, PreRunE: func(cmd *cobra.Command, args []string) (err error) { publishInputArgs.rpcURL, err = flag.GetRPCURL(cmd) if err != nil { return err } return nil }, RunE: publish, }
Functions ¶
This section is empty.
Types ¶
type WorkerPool ¶
type WorkerPool struct {
// contains filtered or unexported fields
}
WorkerPool manages a pool of worker goroutines
func NewWorkerPool ¶
func NewWorkerPool(numWorkers, queueSize uint64) *WorkerPool
NewWorkerPool creates a new worker pool
func (*WorkerPool) Start ¶
func (wp *WorkerPool) Start(ctx context.Context)
Start starts the worker pool
func (*WorkerPool) Stop ¶
func (wp *WorkerPool) Stop()
Stop stops the worker pool and waits for all workers to finish
func (*WorkerPool) SubmitJob ¶
func (wp *WorkerPool) SubmitJob(job JobFn)
SubmitJob submits a job to the worker pool
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.