db

Documentation

Index

• func NotDeleted(db *gorm.DB) *gorm.DB
• type ActionParams
  • func (p *ActionParams) Scan(value interface{}) error
  • func (p ActionParams) Value() (driver.Value, error)
• type DBClient
  • func (db *DBClient) BatchCreateRuleExecRecords(r []RuleExecRecord) error
  • func (db *DBClient) CreateRule(r *Rule) error
  • func (db *DBClient) CreateRuleExecRecord(r *RuleExecRecord) error
  • func (db *DBClient) DeleteRule(id string) error
  • func (db *DBClient) GetRule(id string) (*Rule, error)
  • func (db *DBClient) ListRuleExecRecords(req *pb.ListRuleExecHistoryRequest) ([]RuleExecRecord, int64, error)
  • func (db *DBClient) ListRules(req *pb.ListRulesRequest, withSystem bool) ([]Rule, int64, error)
  • func (db *DBClient) UpdateRule(r *Rule) error
• type Env
  • func (p *Env) Scan(value interface{}) error
  • func (p Env) Value() (driver.Value, error)
• type Rule
  • func (Rule) TableName() string
• type RuleExecRecord
  • func (RuleExecRecord) TableName() string

Functions

func NotDeleted

func NotDeleted(db *gorm.DB) *gorm.DB

Types

type ActionParams

type ActionParams pb.ActionParams

func (*ActionParams) Scan

func (p *ActionParams) Scan(value interface{}) error

func (ActionParams) Value

func (p ActionParams) Value() (driver.Value, error)

type DBClient

type DBClient struct {
	*dao.DBClient
}

func (*DBClient) BatchCreateRuleExecRecords

func (db *DBClient) BatchCreateRuleExecRecords(r []RuleExecRecord) error

func (*DBClient) CreateRule

func (db *DBClient) CreateRule(r *Rule) error

func (*DBClient) CreateRuleExecRecord

func (db *DBClient) CreateRuleExecRecord(r *RuleExecRecord) error

func (*DBClient) DeleteRule

func (db *DBClient) DeleteRule(id string) error

func (*DBClient) GetRule

func (db *DBClient) GetRule(id string) (*Rule, error)

func (*DBClient) ListRuleExecRecords

func (db *DBClient) ListRuleExecRecords(req *pb.ListRuleExecHistoryRequest) ([]RuleExecRecord, int64, error)

func (*DBClient) ListRules

func (db *DBClient) ListRules(req *pb.ListRulesRequest, withSystem bool) ([]Rule, int64, error)

func (*DBClient) UpdateRule

func (db *DBClient) UpdateRule(r *Rule) error

type Env

type Env map[string]interface{}

func (*Env) Scan

func (p *Env) Scan(value interface{}) error

func (Env) Value

func (p Env) Value() (driver.Value, error)

type Rule

type Rule struct {
	ID            string `gorm:"primary_key"`
	CreatedAt     time.Time
	UpdatedAt     time.Time
	Name          string
	Scope         string
	ScopeID       string
	EventType     string
	Enabled       *bool
	Code          string
	Params        ActionParams
	Actor         string
	SoftDeletedAt uint64
}

func (Rule) TableName

func (Rule) TableName() string

type RuleExecRecord

type RuleExecRecord struct {
	ID            string `gorm:"primary_key"`
	CreatedAt     time.Time
	UpdatedAt     time.Time
	Scope         string
	ScopeID       string
	RuleID        string
	Code          string
	Env           Env
	Succeed       *bool
	ActionOutput  string
	SoftDeletedAt uint64
	Actor         string
}

func (RuleExecRecord) TableName

func (RuleExecRecord) TableName() string