publish

Documentation

Index

• Constants
• Variables
• type JobFn
• type WorkerPool
  • func NewWorkerPool(numWorkers, queueSize uint64) *WorkerPool
  • func (wp *WorkerPool) Start(ctx context.Context)
  • func (wp *WorkerPool) Stop()
  • func (wp *WorkerPool) SubmitJob(job JobFn)

Constants

const (
	InputDataSourceFile  = "file"
	InputDataSourceArgs  = "args"
	InputDataSourceStdin = "stdin"
)

const (
	ArgRpcURL = "rpc-url"
	ArgForkID = "fork-id"
)

Variables

var Cmd = &cobra.Command{
	Use:   "publish",
	Short: "Publish transactions to the network with high-throughput",
	Long:  cmdUsage,
	PersistentPreRun: func(cmd *cobra.Command, args []string) {
		publishInputArgs.rpcURL = flag_loader.GetRpcUrlFlagValue(cmd)
	},
	RunE: publish,
}

Types

type JobFn

type JobFn func(ctx context.Context, workerID uint64)

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