execution

Documentation

Index

• func ExecuteParallel(ctx context.Context, requests []Request) error
• type Request
• type RequestResponse
• type Response

Functions

func ExecuteParallel

func ExecuteParallel(ctx context.Context, requests []Request) error

ExecuteParallel executes a slice of requests in parallel

Types

type Request

type Request interface {
	Process(ctx context.Context) error
}

Request is input for parallel execution

type RequestResponse

type RequestResponse struct {
	Request  Request
	Response *Response
}

RequestResponse is used to combine both request and response in output

type Response

type Response struct {
	Value interface{}
	Err   error
}

Response is returned from parallel execution