dto

Documentation

Index

• Variables
• type ConfigResp
  • func GetConfig(cfg *config.AppConfig) ConfigResp
• type CreateUpdateJobRequest
• type DequeueRequest
• type FilterBy
• type FilterSql
• type JobResponse
• type SortAndFilterRequest
• type SortBy
• type UpdateJobHistoryRequest
• type UpdateJobStatusRequest

Variables

var Operators = []string{"eq", "neq", "ct", "sw", "ew", "gt", "lt", "gte", "lte"}

var SqlOperatorReplacement = map[string]FilterSql{
	"eq": {
		SqlOperator:  "=",
		ValueReplace: "@@"},
	"neq": {
		SqlOperator:  "!=",
		ValueReplace: "@@",
	},
	"ct": {
		SqlOperator:  "LIKE",
		ValueReplace: "%@@%",
	},
	"sw": {
		SqlOperator:  "LIKE",
		ValueReplace: "@@%",
	},
	"ew": {
		SqlOperator:  "LIKE",
		ValueReplace: "%@@",
	},
	"gt": {
		SqlOperator:  ">",
		ValueReplace: "@@",
	},
	"lt": {
		SqlOperator:  "<",
		ValueReplace: "@@",
	},
	"gte": {
		SqlOperator:  ">=",
		ValueReplace: "@@",
	},
	"lte": {
		SqlOperator:  "<=",
		ValueReplace: "@@",
	},
}

Types

type ConfigResp

type ConfigResp struct {
	ServerHost                 string
	ServerPort                 string
	ServerTlsPort              string
	ServerGracefulShutdownTime int
	ServerUseTls               bool
	ServerCertFile             string
	ServerKeyFile              string
	GinMode                    string
	DbUsername                 string
	DbHost                     string
	DbPort                     int32
	DbName                     string
	DbJobTable                 string
	MaxResultLimit             int
	StartDate                  time.Time
}

func GetConfig

func GetConfig(cfg *config.AppConfig) ConfigResp

type CreateUpdateJobRequest

type CreateUpdateJobRequest struct {
	CorrelationId string `json:"correlationId" san:"trim,xss"`
	Name          string `json:"name" san:"trim,xss"`
	Source        string `json:"source" san:"trim,xss"`
	Destination   string `json:"destination" san:"trim,xss"`
	Type          string `json:"type" san:"trim,xss"`
	SubType       string `json:"sub_type" san:"trim,xss"`
	Action        string `json:"action" san:"trim,xss"`
	ActionDetails string `json:"action_details" san:"trim,xss"`
	ExtraData     string `json:"extra_data" san:"trim,xss"`
	Priority      string `json:"priority" san:"trim,xss,lower"`
	Rank          int32  `json:"rank" san:"def=0,min=0,max=2147483647"`
}

type DequeueRequest

type DequeueRequest struct {
	Type string `json:"type" san:"trim,xss"`
}

type FilterBy

type FilterBy struct {
	Field    string
	Operator string
	Value    interface{}
}

type FilterSql

type FilterSql struct {
	SqlOperator  string
	ValueReplace string
}

type JobResponse

type JobResponse struct {
	Id            string    `json:"id"`
	CorrelationId string    `json:"correlationId"`
	Name          string    `json:"name"`
	CreatedAt     time.Time `json:"createdAt"`
	CreatedBy     string    `json:"createdBy"`
	ModifiedAt    time.Time `json:"modifiedAt"`
	ModifiedBy    string    `json:"modifiedBy"`
	Status        string    `json:"status"`
	Source        string    `json:"source"`
	Destination   string    `json:"destination"`
	Type          string    `json:"type"`
	SubType       string    `json:"subType"`
	Action        string    `json:"action"`
	ActionDetails string    `json:"actionDetails"`
	Progress      int32     `json:"progress"`
	History       string    `json:"history"`
	ExtraData     string    `json:"extraData"`
	Priority      string    `json:"priority"`
	Rank          int32     `json:"rank"`
}

type SortAndFilterRequest

type SortAndFilterRequest struct {
	Sorts   SortBy
	Filters []FilterBy
	Limit   int
	Offset  int
}

type SortBy

type SortBy struct {
	Field string
	Dir   string
}

type UpdateJobHistoryRequest

type UpdateJobHistoryRequest struct {
	Message string `json:"message" san:"trim,xss"`
}

type UpdateJobStatusRequest

type UpdateJobStatusRequest struct {
	Status  string `json:"status" san:"trim,xss,lower"`
	Message string `json:"message" san:"trim,xss"`
}