asynctaskrunner

Documentation

Index

• type AsyncTaskRunner
  • func NewAsyncTaskRunner(t *testing.T, service *service.Service) *AsyncTaskRunner
  • func (runner *AsyncTaskRunner) Run(ctx context.Context, path string, query url.Values, queueName string) *asynctask.AsyncTask

Types

type AsyncTaskRunner

type AsyncTaskRunner struct {
	// contains filtered or unexported fields
}

AsyncTaskRunner is a runner object to run async tasks in your test.

func NewAsyncTaskRunner

func NewAsyncTaskRunner(t *testing.T, service *service.Service) *AsyncTaskRunner

NewAsyncTaskRunner returns a new *AsyncTaskRunner object to run async tasks.

func (*AsyncTaskRunner) Run

func (runner *AsyncTaskRunner) Run(ctx context.Context, path string, query url.Values, queueName string) *asynctask.AsyncTask

Run executes the task and wait for the completion.