model

Documentation

Index

• Variables
• type BuryJobInput
• type BuryJobPayload
• type CreateJobInput
• type CreateJobPayload
• type DeleteJobInput
• type DeleteJobPayload
• type Job
• type KickJobInput
• type KickJobPayload
• type Me
• type ReleaseJobInput
• type ReleaseJobPayload
• type Scope
  • func MapScope(scope security.Scope) (Scope, error)
  • func (e Scope) IsValid() bool
  • func (e Scope) MarshalGQL(w io.Writer)
  • func (e Scope) String() string
  • func (e *Scope) UnmarshalGQL(v interface{}) error
• type Server
• type Tube
• type TubeConnection
• type TubeEdge

Variables

var AllScope = []Scope{
	ScopeReadServer,
	ScopeReadTubes,
	ScopeReadJobs,
	ScopeWriteJobs,
}

var ErrNotMappable = errors.New("enum can not be mapped")

Types

type BuryJobInput

type BuryJobInput struct {
	ID       int `json:"id"`
	Priority int `json:"priority"`
}

type BuryJobPayload

type BuryJobPayload struct {
	ID int `json:"id"`
}

type CreateJobInput

type CreateJobInput struct {
	Tube     string `json:"tube"`
	Priority int    `json:"priority"`
	Delay    int    `json:"delay"`
	Ttr      int    `json:"ttr"`
	Data     string `json:"data"`
}

type CreateJobPayload

type CreateJobPayload struct {
	Tube string `json:"tube"`
	ID   int    `json:"id"`
}

type DeleteJobInput

type DeleteJobInput struct {
	ID int `json:"id"`
}

type DeleteJobPayload

type DeleteJobPayload struct {
	ID int `json:"id"`
}

type Job

type Job struct {
	ID    int                 `json:"id"`
	Data  string              `json:"data"`
	Stats *beanstalk.StatsJob `json:"stats"`
}

type KickJobInput

type KickJobInput struct {
	ID int `json:"id"`
}

type KickJobPayload

type KickJobPayload struct {
	ID int `json:"id"`
}

type Me

type Me struct {
	User *security.User `json:"user"`
}

type ReleaseJobInput

type ReleaseJobInput struct {
	ID       int `json:"id"`
	Priority int `json:"priority"`
	Delay    int `json:"delay"`
}

type ReleaseJobPayload

type ReleaseJobPayload struct {
	ID int `json:"id"`
}

type Scope

type Scope string

const (
	ScopeReadServer Scope = "READ_SERVER"
	ScopeReadTubes  Scope = "READ_TUBES"
	ScopeReadJobs   Scope = "READ_JOBS"
	ScopeWriteJobs  Scope = "WRITE_JOBS"
)

func MapScope

func MapScope(scope security.Scope) (Scope, error)

func (Scope) IsValid

func (e Scope) IsValid() bool

func (Scope) MarshalGQL

func (e Scope) MarshalGQL(w io.Writer)

func (Scope) String

func (e Scope) String() string

func (*Scope) UnmarshalGQL

func (e *Scope) UnmarshalGQL(v interface{}) error

type Server

type Server struct {
	Stats *beanstalk.Stats `json:"stats"`
}

type Tube

type Tube struct {
	Name       string               `json:"name"`
	Stats      *beanstalk.StatsTube `json:"stats"`
	ReadyJob   *Job                 `json:"readyJob"`
	DelayedJob *Job                 `json:"delayedJob"`
	BuriedJob  *Job                 `json:"buriedJob"`
}

type TubeConnection

type TubeConnection struct {
	Edges []TubeEdge `json:"edges"`
}

type TubeEdge

type TubeEdge struct {
	Node *Tube `json:"node"`
}