write

package
v0.2.21 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 14, 2025 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var PackageName = "scheduler/run/write"
View Source
var PathURI = "/v1/api/agently/schedule-run"

Functions

func DefineComponent

func DefineComponent(ctx context.Context, srv *datly.Service) (*repository.Component, error)

Types

type Handler

type Handler struct{}

func (*Handler) Exec

func (h *Handler) Exec(ctx context.Context, sess handler.Session) (interface{}, error)

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
}

func (*Input) EmbedFS

func (i *Input) EmbedFS() (fs *embed.FS)

func (*Input) Init

func (i *Input) Init(ctx context.Context, sess handler.Session, _ *Output) error

func (*Input) Validate

func (i *Input) Validate(ctx context.Context, sess handler.Session, out *Output) error

type Output

type Output struct {
	response.Status `parameter:",kind=output,in=status" anonymous:"true"`
	Data            []*Run                 `parameter:",kind=body"`
	Violations      []*validator.Violation `parameter:",kind=transient"`
}

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 (m *Run) SetCompletedAt(v time.Time)

func (*Run) SetConversationId

func (m *Run) SetConversationId(v string)

func (*Run) SetConversationKind

func (m *Run) SetConversationKind(v string)

func (*Run) SetCreatedAt

func (m *Run) SetCreatedAt(v time.Time)

func (*Run) SetErrorMessage

func (m *Run) SetErrorMessage(v string)

func (*Run) SetId

func (m *Run) SetId(v string)

func (*Run) SetPreconditionPassed

func (m *Run) SetPreconditionPassed(v int)

func (*Run) SetPreconditionRanAt

func (m *Run) SetPreconditionRanAt(v time.Time)

func (*Run) SetPreconditionResult

func (m *Run) SetPreconditionResult(v string)

func (*Run) SetScheduleId

func (m *Run) SetScheduleId(v string)

func (*Run) SetStartedAt

func (m *Run) SetStartedAt(v time.Time)

func (*Run) SetStatus

func (m *Run) SetStatus(v string)

func (*Run) SetUpdatedAt

func (m *Run) SetUpdatedAt(v time.Time)

type RunHas

type RunHas struct {
	Id, ScheduleId, CreatedAt, UpdatedAt                      bool
	Status, ErrorMessage                                      bool
	PreconditionRanAt, PreconditionPassed, PreconditionResult bool
	ConversationId, ConversationKind                          bool
	StartedAt, CompletedAt                                    bool
}

type Runs added in v0.2.2

type Runs []Run

Runs is a helper slice type referenced by datly `dataType` tags to drive structql markers for the Runs collection in Input.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL