graph

Documentation

Index

• Variables
• func CancelDetachedTasks()
• func TaskWG(ctx context.Context, cliEngine *engine.Engine, task string, wg *sync.WaitGroup, ...)
• type GraphQLWriter
  • func (w GraphQLWriter) Write(p []byte) (int, error)
• type Resolver
  • func (r *Resolver) Mutation() generated.MutationResolver
  • func (r *Resolver) Query() generated.QueryResolver

Variables

var DetachedCtxMap = make(map[string]*detachedContext)

var DetachedTasksMap = make(map[string]*model.DetachedTask)

var ServerCtx context.Context

Functions

func CancelDetachedTasks

func CancelDetachedTasks()

CancelDetachedTasks call cancel on all the context

func TaskWG

func TaskWG(ctx context.Context, cliEngine *engine.Engine, task string, wg *sync.WaitGroup, errChan chan map[string]error)

Types

type GraphQLWriter

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

func (GraphQLWriter) Write

func (w GraphQLWriter) Write(p []byte) (int, error)

type Resolver

type Resolver struct{}

func (*Resolver) Mutation

func (r *Resolver) Mutation() generated.MutationResolver

Mutation returns generated.MutationResolver implementation.

func (*Resolver) Query

func (r *Resolver) Query() generated.QueryResolver

Query returns generated.QueryResolver implementation.