graph

Documentation

Index

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

Variables

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

DetachedCtxMap stores the context of each task using an id

var DetachedLoggerMap = make(map[string]*detachedLogger)

DetachedLoggerMap stores the output of each task using an id

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

DetachedTasksMap links detached task with an id

var ServerCtx context.Context

ServerCtx stores the context on which the server is running

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)

TaskWG run a working group of tasks

Types

type ContextKey

type ContextKey int

ContextKey is a type for the values that are send on each request

const (
	// ElkFileKey stores which is the file path used to run the server
	ElkFileKey ContextKey = iota

	// TokenKey token that is sent by the user request
	TokenKey ContextKey = iota

	// AuthorizationKey stores the valid authorization key
	AuthorizationKey ContextKey = iota
)

type QLWriter

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

QLWriter writes the logs from a task to an specific output

func (QLWriter) Write

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

type Resolver

type Resolver struct{}

Resolver injects dependency for graphql This file will not be regenerated automatically.

It serves as dependency injection for your app, add any dependencies you require here.

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.

func (*Resolver) Subscription

func (r *Resolver) Subscription() generated.SubscriptionResolver

Subscription returns generated.SubscriptionResolver implementation.