execution

type Cause uint

type DbContext interface {
	GetScriptsRepository(projectID string) (scripts.Repository, error)
}

type Event struct {
	ProjectID string
	ScriptID  string
	CausedBy  Cause
}

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

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

type Job struct {
	ID        string
	ProjectID string
	CausedBy  Cause
	Script    scripts.ScriptEntity
}

type LogWriter interface {
	Write(job Job, data []byte) (n int, err error)
}

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

type OutputWriter interface {
	Write(job Job, data []byte) error
}

type Queue interface {
	Enqueue(ctx context.Context, job Job) error
	Dequeue(ctx context.Context) (<-chan Job, error)
}

type Result struct {
	State
	Data []byte
}

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

type Settings struct {
	PoolSize uint64
}

type State struct {
	Job       Job
	Timestamp time.Time
	Status    Status
	Error     error
}

type StateWriter interface {
	Write(state State) error
}

type Status uint

type Worker interface {
	IsRunning() bool
	Process() ([]byte, error)
	Interrupt()
}

type WorkerFactory func(job Job) Worker

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