executor

Documentation

Index

• func NewExecutableSchema(cfg Config) graphql.ExecutableSchema
• type ComplexityRoot
• type Config
• type DirectiveRoot
• type JobResolver
• type MutationResolver
• type QueryResolver
• type ResolverRoot
• type ServerResolver
• type TubeResolver
• type UserResolver

Functions

func NewExecutableSchema

func NewExecutableSchema(cfg Config) graphql.ExecutableSchema

NewExecutableSchema creates an ExecutableSchema from the ResolverRoot interface.

Types

type ComplexityRoot

type ComplexityRoot struct {
	BuryJobPayload struct {
		ID func(childComplexity int) int
	}

	CreateJobPayload struct {
		ID   func(childComplexity int) int
		Tube func(childComplexity int) int
	}

	DeleteJobPayload struct {
		ID func(childComplexity int) int
	}

	Job struct {
		Data  func(childComplexity int) int
		ID    func(childComplexity int) int
		Stats func(childComplexity int) int
	}

	JobStats struct {
		Age      func(childComplexity int) int
		Buries   func(childComplexity int) int
		Delay    func(childComplexity int) int
		File     func(childComplexity int) int
		Kicks    func(childComplexity int) int
		Priority func(childComplexity int) int
		Releases func(childComplexity int) int
		Reserves func(childComplexity int) int
		State    func(childComplexity int) int
		TTR      func(childComplexity int) int
		TimeLeft func(childComplexity int) int
		Timeouts func(childComplexity int) int
		Tube     func(childComplexity int) int
	}

	KickJobPayload struct {
		ID func(childComplexity int) int
	}

	Me struct {
		User func(childComplexity int) int
	}

	Mutation struct {
		BuryJob    func(childComplexity int, input *model.BuryJobInput) int
		CreateJob  func(childComplexity int, input *model.CreateJobInput) int
		DeleteJob  func(childComplexity int, input *model.DeleteJobInput) int
		KickJob    func(childComplexity int, input *model.KickJobInput) int
		ReleaseJob func(childComplexity int, input *model.ReleaseJobInput) int
	}

	Query struct {
		Job    func(childComplexity int, id int) int
		Me     func(childComplexity int) int
		Server func(childComplexity int) int
		Tube   func(childComplexity int, name string) int
		Tubes  func(childComplexity int) int
	}

	ReleaseJobPayload struct {
		ID func(childComplexity int) int
	}

	Server struct {
		Stats func(childComplexity int) int
	}

	ServerStats struct {
		BinlogCurrentIndex    func(childComplexity int) int
		BinlogMaxSize         func(childComplexity int) int
		BinlogOldestIndex     func(childComplexity int) int
		BinlogRecordsMigrated func(childComplexity int) int
		BinlogRecordsWritten  func(childComplexity int) int
		CmdBury               func(childComplexity int) int
		CmdDelete             func(childComplexity int) int
		CmdIgnore             func(childComplexity int) int
		CmdKick               func(childComplexity int) int
		CmdListTubeUsed       func(childComplexity int) int
		CmdListTubes          func(childComplexity int) int
		CmdListTubesWatched   func(childComplexity int) int
		CmdPauseTube          func(childComplexity int) int
		CmdPeek               func(childComplexity int) int
		CmdPeekBuried         func(childComplexity int) int
		CmdPeekDelayed        func(childComplexity int) int
		CmdPeekReady          func(childComplexity int) int
		CmdPut                func(childComplexity int) int
		CmdRelease            func(childComplexity int) int
		CmdReserve            func(childComplexity int) int
		CmdStats              func(childComplexity int) int
		CmdStatsJob           func(childComplexity int) int
		CmdStatsTube          func(childComplexity int) int
		CmdTouch              func(childComplexity int) int
		CmdUse                func(childComplexity int) int
		CmdWatch              func(childComplexity int) int
		CurrentConnections    func(childComplexity int) int
		CurrentJobsBuried     func(childComplexity int) int
		CurrentJobsDelayed    func(childComplexity int) int
		CurrentJobsReady      func(childComplexity int) int
		CurrentJobsReserved   func(childComplexity int) int
		CurrentJobsUrgent     func(childComplexity int) int
		CurrentProducers      func(childComplexity int) int
		CurrentTubes          func(childComplexity int) int
		CurrentWaiting        func(childComplexity int) int
		CurrentWorkers        func(childComplexity int) int
		Draining              func(childComplexity int) int
		Hostname              func(childComplexity int) int
		ID                    func(childComplexity int) int
		JobTimeouts           func(childComplexity int) int
		MaxJobSize            func(childComplexity int) int
		OS                    func(childComplexity int) int
		PID                   func(childComplexity int) int
		Platform              func(childComplexity int) int
		RUsageSTime           func(childComplexity int) int
		RUsageUTime           func(childComplexity int) int
		TotalConnections      func(childComplexity int) int
		TotalJobs             func(childComplexity int) int
		Uptime                func(childComplexity int) int
		Version               func(childComplexity int) int
	}

	Tube struct {
		BuriedJob  func(childComplexity int) int
		DelayedJob func(childComplexity int) int
		Name       func(childComplexity int) int
		ReadyJob   func(childComplexity int) int
		Stats      func(childComplexity int) int
	}

	TubeConnection struct {
		Edges func(childComplexity int) int
	}

	TubeEdge struct {
		Node func(childComplexity int) int
	}

	TubeStats struct {
		CmdDelete           func(childComplexity int) int
		CmdPauseTube        func(childComplexity int) int
		CurrentJobsBuried   func(childComplexity int) int
		CurrentJobsDelayed  func(childComplexity int) int
		CurrentJobsReady    func(childComplexity int) int
		CurrentJobsReserved func(childComplexity int) int
		CurrentJobsUrgent   func(childComplexity int) int
		CurrentUsing        func(childComplexity int) int
		CurrentWaiting      func(childComplexity int) int
		CurrentWatching     func(childComplexity int) int
		Pause               func(childComplexity int) int
		PauseTimeLeft       func(childComplexity int) int
		TotalJobs           func(childComplexity int) int
	}

	User struct {
		Name   func(childComplexity int) int
		Scopes func(childComplexity int) int
	}
}

type Config

type Config struct {
	Resolvers  ResolverRoot
	Directives DirectiveRoot
	Complexity ComplexityRoot
}

type DirectiveRoot

type DirectiveRoot struct {
}

type JobResolver

type JobResolver interface {
	Stats(ctx context.Context, obj *model.Job) (*beanstalk.StatsJob, error)
}

type MutationResolver

type MutationResolver interface {
	CreateJob(ctx context.Context, input *model.CreateJobInput) (*model.CreateJobPayload, error)
	BuryJob(ctx context.Context, input *model.BuryJobInput) (*model.BuryJobPayload, error)
	DeleteJob(ctx context.Context, input *model.DeleteJobInput) (*model.DeleteJobPayload, error)
	KickJob(ctx context.Context, input *model.KickJobInput) (*model.KickJobPayload, error)
	ReleaseJob(ctx context.Context, input *model.ReleaseJobInput) (*model.ReleaseJobPayload, error)
}

type QueryResolver

type QueryResolver interface {
	Me(ctx context.Context) (*model.Me, error)
	Server(ctx context.Context) (*model.Server, error)
	Tubes(ctx context.Context) (*model.TubeConnection, error)
	Tube(ctx context.Context, name string) (*model.Tube, error)
	Job(ctx context.Context, id int) (*model.Job, error)
}

type ResolverRoot

type ResolverRoot interface {
	Job() JobResolver
	Mutation() MutationResolver
	Query() QueryResolver
	Server() ServerResolver
	Tube() TubeResolver
	User() UserResolver
}

type ServerResolver

type ServerResolver interface {
	Stats(ctx context.Context, obj *model.Server) (*beanstalk.Stats, error)
}

type TubeResolver

type TubeResolver interface {
	Stats(ctx context.Context, obj *model.Tube) (*beanstalk.StatsTube, error)
	ReadyJob(ctx context.Context, obj *model.Tube) (*model.Job, error)
	DelayedJob(ctx context.Context, obj *model.Tube) (*model.Job, error)
	BuriedJob(ctx context.Context, obj *model.Tube) (*model.Job, error)
}

type UserResolver

type UserResolver interface {
	Scopes(ctx context.Context, obj *security.User) ([]model.Scope, error)
}