Documentation
¶
Index ¶
- Variables
- func DefineComponent(ctx context.Context, srv *datly.Service) (*repository.Component, error)
- type Handler
- type Input
- type Output
- type Run
- func (m *Run) SetCompletedAt(v time.Time)
- func (m *Run) SetConversationId(v string)
- func (m *Run) SetConversationKind(v string)
- func (m *Run) SetCreatedAt(v time.Time)
- func (m *Run) SetErrorMessage(v string)
- func (m *Run) SetId(v string)
- func (m *Run) SetPreconditionPassed(v int)
- func (m *Run) SetPreconditionRanAt(v time.Time)
- func (m *Run) SetPreconditionResult(v string)
- func (m *Run) SetScheduleId(v string)
- func (m *Run) SetStartedAt(v time.Time)
- func (m *Run) SetStatus(v string)
- func (m *Run) SetUpdatedAt(v time.Time)
- type RunHas
- type Runs
Constants ¶
This section is empty.
Variables ¶
View Source
var FS embed.FS
View Source
var PackageName = "scheduler/run/write"
View Source
var PathURI = "/v1/api/agently/schedule-run"
Functions ¶
func DefineComponent ¶
Types ¶
type Input ¶
type Input struct {
Runs []*Run `parameter:",kind=body,in=data"`
CurRunsId *struct{ Values []string } `parameter:",kind=param,in=Runs,dataType=scheduler/run/write.Runs" codec:"structql,uri=sql/cur_runs_id.sql"`
CurRun []*Run `parameter:",kind=view,in=CurRun" view:"CurRun" sql:"uri=sql/cur_run.sql"`
CurRunById map[string]*Run
}
type Run ¶
type Run struct {
Id string `sqlx:"id,primaryKey" validate:"required"`
ScheduleId string `sqlx:"schedule_id" validate:"required"`
CreatedAt *time.Time `sqlx:"created_at" json:",omitempty"`
UpdatedAt *time.Time `sqlx:"updated_at" json:",omitempty"`
Status string `sqlx:"status" validate:"required"`
ErrorMessage *string `sqlx:"error_message" json:",omitempty"`
PreconditionRanAt *time.Time `sqlx:"precondition_ran_at" json:",omitempty"`
PreconditionPassed *int `sqlx:"precondition_passed" json:",omitempty"`
PreconditionResult *string `sqlx:"precondition_result" json:",omitempty"`
ConversationId *string `sqlx:"conversation_id" json:",omitempty"`
ConversationKind string `sqlx:"conversation_kind" validate:"required"`
StartedAt *time.Time `sqlx:"started_at" json:",omitempty"`
CompletedAt *time.Time `sqlx:"completed_at" json:",omitempty"`
Has *RunHas `setMarker:"true" format:"-" sqlx:"-" diff:"-" json:"-"`
}
func (*Run) SetCompletedAt ¶
func (*Run) SetConversationId ¶
func (*Run) SetConversationKind ¶
func (*Run) SetCreatedAt ¶
func (*Run) SetErrorMessage ¶
func (*Run) SetPreconditionPassed ¶
func (*Run) SetPreconditionRanAt ¶
func (*Run) SetPreconditionResult ¶
func (*Run) SetScheduleId ¶
func (*Run) SetStartedAt ¶
func (*Run) SetUpdatedAt ¶
Click to show internal directories.
Click to hide internal directories.