execution

Documentation

Index

• func ContextDone(ctx context.Context, env string) error
• func ExecuteParallel(ctx context.Context, requests []Request) error
• type ErrQueryCanceled
  • func (e ErrQueryCanceled) Error() string
• type ErrQueryTimeout
  • func (e ErrQueryTimeout) Error() string
• type Request
• type RequestResponse
• type Response

Functions

func ContextDone

func ContextDone(ctx context.Context, env string) error

ContextDone returns an error if the context was canceled or timed out.

func ExecuteParallel

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

ExecuteParallel executes a slice of requests in parallel

Types

type ErrQueryCanceled

type ErrQueryCanceled string

ErrQueryCanceled is returned if a query was canceled during processing.

func (ErrQueryCanceled) Error

func (e ErrQueryCanceled) Error() string

type ErrQueryTimeout

type ErrQueryTimeout string

ErrQueryTimeout is returned if a query timed out during processing.

func (ErrQueryTimeout) Error

func (e ErrQueryTimeout) Error() string

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