parallel

Documentation

Index

• func QueryZgsRpc[T any](ctx context.Context, nodes []string, ...) map[string]*RpcResult[T]
• func Serial(ctx context.Context, parallelizable Interface, tasks int, ...) error
• type Interface
• type Result
• type RpcOption
• type RpcResult
• type SerialOption
  • func (opt *SerialOption) Normalize(tasks int)

Functions

func QueryZgsRpc

func QueryZgsRpc[T any](ctx context.Context, nodes []string, rpcFunc func(*node.ZgsClient, context.Context) (T, error), option ...RpcOption) map[string]*RpcResult[T]

QueryZgsRpc calls zgs RPC with given nodes in parallel.

func Serial

func Serial(ctx context.Context, parallelizable Interface, tasks int, option ...SerialOption) error

Types

type Interface

type Interface interface {
	ParallelDo(ctx context.Context, routine, task int) (interface{}, error)
	ParallelCollect(result *Result) error
}

type Result

type Result struct {
	Routine int
	Task    int
	Value   interface{}
	// contains filtered or unexported fields
}

type RpcOption

type RpcOption struct {
	Parallel       SerialOption
	Provider       providers.Option
	ReportInterval time.Duration
}

type RpcResult

type RpcResult[T any] struct {
	Data    T
	Err     error
	Latency time.Duration
}

type SerialOption

type SerialOption struct {
	Routines int
	Window   int
}

func (*SerialOption) Normalize

func (opt *SerialOption) Normalize(tasks int)