application

Documentation

Index

• Constants
• func AddRoutes(r *gin.Engine)
• func InitServer()
• func RouterGroup() *gin.RouterGroup
• func Run()
• func Server() *gin.Engine
• type BatchQueryJobRequest
  • func (q BatchQueryJobRequest) GetJobIdentity() common.JobIdentity
• type CreateJobRequest
  • func (q CreateJobRequest) GetJobResource() common.Job
• type Orchestrator
  • func NewOrchestrator(config appconfig.Config, group *gin.RouterGroup, logger *zap.Logger) (*Orchestrator, error)
  • func (r *Orchestrator) Close()
  • func (r *Orchestrator) GetReloadDirs() []string
  • func (r *Orchestrator) Initialize() error
  • func (r *Orchestrator) Reload()
  • func (r *Orchestrator) StartLoop() error
• type QueryJobRequest
  • func (q QueryJobRequest) GetJobIdentity() common.JobIdentity
• type QueryJobStepLogRequest
  • func (q QueryJobStepLogRequest) GetJobIdentity() common.JobIdentity

Constants

const (
	LogTimeUUIDHeader  = "logTimeUUID"
	LogCompletedHeader = "logCompleted"
)

const (
	BASE_PATH = "/v1"
)

Functions

func AddRoutes

func AddRoutes(r *gin.Engine)

func InitServer

func InitServer()

func RouterGroup

func RouterGroup() *gin.RouterGroup

func Run

func Run()

func Server

func Server() *gin.Engine

Types

type BatchQueryJobRequest

type BatchQueryJobRequest struct {
	Service string   `form:"service" json:"service" validate:"required"`
	Task    string   `form:"task" json:"task" validate:"required"`
	Domain  string   `form:"domain" json:"domain" validate:"required"`
	IDs     []string `form:"IDs" json:"IDs" validate:"required"`
}

func (BatchQueryJobRequest) GetJobIdentity

func (q BatchQueryJobRequest) GetJobIdentity() common.JobIdentity

type CreateJobRequest

type CreateJobRequest struct {
	Service string                 `form:"service" json:"service" validate:"required"`
	Task    string                 `form:"task" json:"task" validate:"required"`
	Domain  string                 `form:"domain" json:"domain" validate:"required"`
	UserID  string                 `json:"userID" json:"userID"  validate:"required"`
	Spec    map[string]interface{} `json:"spec" json:"spec" validate:"required"`
	Engine  string                 `json:"engine" json:"engine" validate:"required"`
}

func (CreateJobRequest) GetJobResource

func (q CreateJobRequest) GetJobResource() common.Job

type Orchestrator

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

func NewOrchestrator

func NewOrchestrator(config appconfig.Config, group *gin.RouterGroup, logger *zap.Logger) (*Orchestrator, error)

func (*Orchestrator) Close

func (r *Orchestrator) Close()

func (*Orchestrator) GetReloadDirs

func (r *Orchestrator) GetReloadDirs() []string

func (*Orchestrator) Initialize

func (r *Orchestrator) Initialize() error

func (*Orchestrator) Reload

func (r *Orchestrator) Reload()

func (*Orchestrator) StartLoop

func (r *Orchestrator) StartLoop() error

type QueryJobRequest

type QueryJobRequest struct {
	Service string `form:"service" json:"service" validate:"required"`
	Task    string `form:"task" json:"task" validate:"required"`
	Domain  string `form:"domain" json:"domain" validate:"required"`
	ID      string `form:"ID" json:"ID" validate:"required,uuid"`
}

func (QueryJobRequest) GetJobIdentity

func (q QueryJobRequest) GetJobIdentity() common.JobIdentity

type QueryJobStepLogRequest

type QueryJobStepLogRequest struct {
	QueryJobRequest
	StepID        string `form:"stepID" json:"stepID" validate:"required,number"`
	StartTimeUUID string `form:"startTimeUUID" json:"startTime"`
	MaxRecord     int    `form:"maxRecord" json:"maxRecord"`
}

func (QueryJobStepLogRequest) GetJobIdentity

func (q QueryJobStepLogRequest) GetJobIdentity() common.JobIdentity