utils

Documentation

Index

• type Action
  • func ConvertAction(ctx context.Context, actionId, ruleId uint) *Action
  • func ConvertActionZ(ac *dao.Target) *Action
• type ActionOption
• type Field
• type Rule
  • func ConvertRule(ctx context.Context, id uint, userId string) (*Rule, error)

Types

type Action

type Action struct {
	Id         string
	UserId     string
	ActionType string
	Sink       string
	ErrorFlag  bool
	Metadata   map[string]string
	Body       []byte
}

func ConvertAction

func ConvertAction(ctx context.Context, actionId, ruleId uint) *Action

---------------------------------convert action

func ConvertActionZ

func ConvertActionZ(ac *dao.Target) *Action

type ActionOption

type ActionOption struct {
	Version string                 `json:"version"`
	Option  map[string]interface{} `json:"option"`
}

type Field

type Field struct {
	Type  string `json:"type"`
	Value string `json:"value"`
}

type Rule

type Rule struct {
	UserId  string
	Id      string
	Body    []byte
	Topic   string
	Actions []*Action
}

func ConvertRule

func ConvertRule(ctx context.Context, id uint, userId string) (*Rule, error)