flow

Documentation

Index

• type CrontabFlowEntity
  • func Create(ctx context.Context, id, name, info, spec, desc string, flowType, status int32) (*CrontabFlowEntity, error)
  • func DetailById(ctx context.Context, id string) (*CrontabFlowEntity, error)
  • func DetailByIds(ctx context.Context, ids []string) ([]*CrontabFlowEntity, error)
  • func List(ctx context.Context, id, name string, flowType, status int32, sortValue string, ...) ([]*CrontabFlowEntity, int64, error)
  • func Update(ctx context.Context, id, name, info, spec, desc string, flowType, status int32) (*CrontabFlowEntity, error)
  • func UpdateStatus(ctx context.Context, id string, status int32) (*CrontabFlowEntity, error)
  • func (CrontabFlowEntity) TableName() string

Types

type CrontabFlowEntity

type CrontabFlowEntity struct {
	Id         string `gorm:"not null; column:id" json:"id"`
	Name       string `gorm:"not null; column:name" json:"name"`
	Info       string `gorm:"not null; column:info" json:"info"`
	FlowType   int32  `gorm:"not null; column:flow_type" json:"flow_type"`
	Spec       string `gorm:"not null; column:spec" json:"spec"`
	Desc       string `gorm:"not null; column:desc" json:"desc"`
	Status     int32  `gorm:"not null; column:status" json:"status"`
	CreateTime int64  `gorm:"not null; column:create_time" json:"create_time"`
	UpdateTime int64  `gorm:"not null; column:update_time" json:"update_time"`
}

func Create

func Create(ctx context.Context, id, name, info, spec, desc string, flowType, status int32) (*CrontabFlowEntity, error)

func DetailById

func DetailById(ctx context.Context, id string) (*CrontabFlowEntity, error)

func DetailByIds

func DetailByIds(ctx context.Context, ids []string) ([]*CrontabFlowEntity, error)

func List

func List(ctx context.Context, id, name string, flowType, status int32, sortValue string, offset, limit int64) ([]*CrontabFlowEntity, int64, error)

func Update

func Update(ctx context.Context, id, name, info, spec, desc string, flowType, status int32) (*CrontabFlowEntity, error)

func UpdateStatus

func UpdateStatus(ctx context.Context, id string, status int32) (*CrontabFlowEntity, error)

func (CrontabFlowEntity) TableName

func (CrontabFlowEntity) TableName() string