core

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

type CreateWorkflowRequest struct {
	Workflows []*WorkFlow
}

type CreateWorkflowResponse struct {
	Ids []string `json:"ids"`
}

type DecodeRequestFunc func(r *http.Request) (interface{}, error)

type DeleteWorkflowRequest struct {
	Ids []string `json:"ids"`
}

type DeleteWorkflowResponse struct {
}

type Endpoint func(ctx context.Context, req interface{}) (resp interface{}, err error)

type Errors []error

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

type EtcdConfig struct {
	Uri     string `yaml:"uri"`
	Timeout int    `json:"timeout" yaml:"timeout" `
}

type Executor struct {
	CheckWorkFlowTicker *time.Ticker
	// contains filtered or unexported fields
}

type ExecutorConfig struct {
	Name                  string `json:"name" yaml:"name" `
	CheckWorkFlowInterval int    `json:"checkWorkFlowInterval" yaml:"checkWorkFlowInterval" `
	MetricPort            int    `json:"metricPort" yaml:"metricPort" `
	Separate              string `json:"separate,omitempty" yaml:"separate" `
}

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

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

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

type GetCronRequest struct {
	Expr      string `json:"expr,omitempty" yaml:"expr" `
	NextCount int    `json:"next_count,omitempty" yaml:"next_count" `
}

type GetCronResponse struct {
	Expr  string   `json:"expr,omitempty" yaml:"expr" `
	Nexts []string `json:"nexts,omitempty" yaml:"nexts" `
}

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

type GetJobResponse struct {
	JobStats []*JobDescription `json:"jobStats"`
}

type GetWorkflowRequest struct {
	Ids []string `json:"ids"`
}

type GetWorkflowResponse struct {
	Workflows []*WorkFlow `json:"workflows"`
}

type HandleFunc func(w http.ResponseWriter, r *http.Request)

type Header interface {
	Headers() http.Header
}

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

type HttpConfig struct {
	Port      int `json:"port" yaml:"port" `
	PProfPort int `json:"pprofPort" yaml:"pprofPort" `
}

type ICounter interface {
	With(labelValues ...string) ICounter
	Add(delta float64)
}

type IGauge interface {
	With(labelValues ...string) IGauge
	Set(value float64)
	Add(delta float64)
}

type IHistogram interface {
	With(labelValues ...string) IHistogram
	Observe(value float64)
}

type Job interface {
	Name() string
	Exec(ctx context.Context, req string) (resp string, err error)
}

type JobConfig struct {
	Ids  map[string]string `json:"ids" yaml:"ids" `
	Host string            `json:"host" yaml:"host" `
}

type JobDescription struct {
	Id          string `json:"id"`
	Name        string `json:"name"`
	Host        string `json:"host"`
	Port        int    `json:"port"`
	ServicePath string `json:"servicePath"`
	JobPath     string `json:"jobPath"`
}

type JobError struct {
	Name    string
	Code    int
	Message string
}

type JobMiddlewareRequest struct {
	Name      string
	Parameter []string
}

type JobRequest struct {
	Meta map[string]interface{} `json:"meta,omitempty"`
	//Values  []string               `json:"values,omitempty"`
	Values  map[string][]string `json:"values,omitempty"`
	Pattern string              `json:"pattern,omitempty"`
	// contains filtered or unexported fields
}

type JobResponse JobRequest

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

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

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

type KV struct {
	Key   string `json:"key,omitempty"`
	Value string `json:"value,omitempty"`
}

type LabelValues []string

type ListJobRequest struct{}

type ListJobResponse struct {
	JobStats []*JobDescription `json:"jobStats"`
}

type ListWorkflowRequest struct {
	Header      int      `json:"header"`
	Names       []string `json:"names"`
	States      []string `json:"states"`
	StartTime   int64    `json:"startTime"`
	EndTime     int64    `json:"endTime"`
	CurrentPage uint64   `json:"currentPage"`
	PageSize    uint64   `json:"pageSize"`
}

type ListWorkflowResponse struct {
	Headers   []*KV       `json:"headers,omitempty"`
	Workflows []*WorkFlow `json:"workflows,omitempty"`
}

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

type MergeFunc func(sep string, paras ...string) (string, error)

type Middleware func(Endpoint) Endpoint

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

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

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

type PostgresConfig struct {
	Uri     string `yaml:"uri"`
	MaxIdle int    `yaml:"maxIdle" default:"10"`
	MaxOpen int    `yaml:"maxOpen" default:"100"`
}

type ScheduleConfig struct {
	Etcd     EtcdConfig
	Postgres PostgresConfig
	Http     HttpConfig
	Executor ExecutorConfig
	Job      JobConfig
}

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

type SplitFunc func(sep string, paras string) ([]string, error)

type Stack []string

type StatusCoder interface {
	StatusCode() int
}

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

type SyncMap struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type SyncRequest struct {
	SrcHost   string
	SrcFiles  []string
	DestHost  string
	DestFiles []string
}

type UpdateWorkflowRequest struct {
	WorkFlows []*WorkFlow `json:"workflows"`
}

type UpdateWorkflowResponse struct {
}

type WorkFlow struct {
	Id          string `json:"id,omitempty"`
	Name        string `json:"name,omitempty"`
	Description string `json:"description,omitempty"`
	Expression  string `json:"expression,omitempty"`
	Cron        string `json:"cron,omitempty"`
	Para        string `json:"para"`

	ExecutorWhenDeployed      bool  `json:"executor_when_deployed" yaml:"executor_when_deployed" `
	ExecutorWhenDeployedDelay int64 `json:"executor_when_deployed_delay" yaml:"executor_when_deployed_delay" `

	// 执行几次结束
	SuccessLimit int64 `json:"successLimit" yaml:"successLimit" `
	// 碰到错误的方式
	FailedLimit int64 `json:"failedLimit" yaml:"failedLimit"`
	// 可以指定由哪个执行器执行
	BelongExecutor string `json:"belongExecutor" yaml:"belongExecutor" `
	State          string `json:"state,omitempty"`
	CreateTime     int64  `json:"createTime,omitempty"`
	UpdateTime     int64  `json:"updateTime,omitempty"`
}

type WorkFlowStatus struct {
	Id                  string
	Executing           bool
	MaxExecuteCount     int64
	SuccessExecuteCount int64
	FailedExecuteCount  int64
	LastExecuteDuration int64
}

type WorkerRole uint8

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