service

Documentation

Index

• Variables
• type BaseService
  • func (b *BaseService) DeleteBase(obj interface{}) error
  • func (b *BaseService) DeleteByMultiFieldValue(obj interface{}, conditions map[string]interface{}) error
  • func (b *BaseService) GetBase(obj interface{}) error
  • func (b *BaseService) GetBy(obj interface{}, field string) error
  • func (b *BaseService) GetByIds(obj interface{}, list interface{}, ids []int) error
  • func (b *BaseService) GetByMultiFieldValue(obj interface{}, conditions map[string]interface{}) error
  • func (b *BaseService) GetByMultiIds(obj interface{}, list interface{}, field string, ids []int) error
  • func (b *BaseService) GetByStringValues(obj interface{}, list interface{}, field string, values []string) error
  • func (b *BaseService) GetCount(obj interface{}, filterkey string, filtervalue interface{}) (int, error)
  • func (b *BaseService) InsertBase(obj interface{}) error
  • func (b *BaseService) ListByPage(page, pageSize int, obj interface{}, list interface{}) (int, error)
  • func (b *BaseService) ListByPageWithFilter(page int, pageSize int, obj interface{}, list interface{}, filterkey string, ...) (int, error)
  • func (b *BaseService) ListByPageWithSort(page, pageSize int, obj interface{}, list interface{}, sortstr ...string) (int, error)
  • func (b *BaseService) UpdateBase(obj interface{}) error
• type ClusterService
  • func (c *ClusterService) AppendIpList(ips []string, pool *models.Pool) []int
  • func (c *ClusterService) GetAllExecTask() ([]*models.ExecTask, error)
  • func (c *ClusterService) ListNodesByType(pool_id int, node_type string) ([]models.Node, error)
  • func (c *ClusterService) SearchPoolByIP(ips []string) map[string]int
• type FlowService
  • func (f *FlowService) GetActionImplByName(name string) (*models.ActionImpl, error)
  • func (f *FlowService) GetFlowImplWithRel(id int) (*models.FlowImpl, error)
  • func (f *FlowService) GetFlowWithRel(id int) (*models.Flow, error)
  • func (f *FlowService) GetNodeByIp(ip string) (*models.Node, error)
  • func (f *FlowService) GetNodeStatusByFlowId(flowId int) ([]*models.NodeState, error)
• type LogsService
  • func (store *LogsService) Debug(Fid int, BatchId int, correlationId string, v ...interface{})
  • func (store *LogsService) Error(Fid int, BatchId int, correlationId string, v ...interface{})
  • func (store *LogsService) Info(Fid int, BatchId int, correlationId string, v ...interface{})
  • func (store *LogsService) Warn(Fid int, BatchId int, correlationId string, v ...interface{})
• type RemoteStepService
  • func (f *RemoteStepService) ActionDelete(id int) error
  • func (f *RemoteStepService) CheckActionDelete(id int) error
  • func (f *RemoteStepService) CheckStepDelete(id int) error
• type TaskService
  • func (t *TaskService) GetAllTaskByPool(pool_id int, task_type string) (*models.ExecTask, error)
  • func (t *TaskService) GetCronTaskById(id int) (*models.CronItem, error)
  • func (t *TaskService) GetDependTaskById(id int) (*models.DependItem, error)

Variables

var (
	Cluster = &ClusterService{}
	Flow    = &FlowService{}
	Remote  = &RemoteStepService{}
	Logs    = &LogsService{}
	Task    = &TaskService{}
)

Types

type BaseService

type BaseService struct {
}

func (*BaseService) DeleteBase

func (b *BaseService) DeleteBase(obj interface{}) error

func (*BaseService) DeleteByMultiFieldValue

func (b *BaseService) DeleteByMultiFieldValue(obj interface{}, conditions map[string]interface{}) error

func (*BaseService) GetBase

func (b *BaseService) GetBase(obj interface{}) error

func (*BaseService) GetBy

func (b *BaseService) GetBy(obj interface{}, field string) error

func (*BaseService) GetByIds

func (b *BaseService) GetByIds(obj interface{}, list interface{}, ids []int) error

* Get by objects by ids

func (*BaseService) GetByMultiFieldValue

func (b *BaseService) GetByMultiFieldValue(obj interface{}, conditions map[string]interface{}) error

func (*BaseService) GetByMultiIds

func (b *BaseService) GetByMultiIds(obj interface{}, list interface{},
	field string, ids []int) error

* Get by objects by field & ids

func (*BaseService) GetByStringValues

func (b *BaseService) GetByStringValues(obj interface{}, list interface{}, field string, values []string) error

* load data by value list of specified field

func (*BaseService) GetCount

func (b *BaseService) GetCount(obj interface{}, filterkey string, filtervalue interface{}) (int, error)

func (*BaseService) InsertBase

func (b *BaseService) InsertBase(obj interface{}) error

func (*BaseService) ListByPage

func (b *BaseService) ListByPage(page, pageSize int, obj interface{}, list interface{}) (int, error)

func (*BaseService) ListByPageWithFilter

func (b *BaseService) ListByPageWithFilter(page int, pageSize int, obj interface{}, list interface{},
	filterkey string, filtervalue interface{}) (int, error)

func (*BaseService) ListByPageWithSort

func (b *BaseService) ListByPageWithSort(page, pageSize int, obj interface{}, list interface{}, sortstr ...string) (int, error)

* * query table by page with sort * page: page index to query * pageSize: page size per page * obj: object to query * list: query result * sortstr: sort field names, multiple fields sorting is available. default is asc and field name with previous '-' means

func (*BaseService) UpdateBase

func (b *BaseService) UpdateBase(obj interface{}) error

type ClusterService

type ClusterService struct {
	BaseService
}

func (*ClusterService) AppendIpList

func (c *ClusterService) AppendIpList(ips []string, pool *models.Pool) []int

func (*ClusterService) GetAllExecTask

func (c *ClusterService) GetAllExecTask() ([]*models.ExecTask, error)

func (*ClusterService) ListNodesByType

func (c *ClusterService) ListNodesByType(pool_id int, node_type string) ([]models.Node, error)

func (*ClusterService) SearchPoolByIP

func (c *ClusterService) SearchPoolByIP(ips []string) map[string]int

SearchPoolByIP returs the pool id of the ip given, if it exists

type FlowService

type FlowService struct {
	BaseService
}

func (*FlowService) GetActionImplByName

func (f *FlowService) GetActionImplByName(name string) (*models.ActionImpl, error)

func (*FlowService) GetFlowImplWithRel

func (f *FlowService) GetFlowImplWithRel(id int) (*models.FlowImpl, error)

func (*FlowService) GetFlowWithRel

func (f *FlowService) GetFlowWithRel(id int) (*models.Flow, error)

func (*FlowService) GetNodeByIp

func (f *FlowService) GetNodeByIp(ip string) (*models.Node, error)

func (*FlowService) GetNodeStatusByFlowId

func (f *FlowService) GetNodeStatusByFlowId(flowId int) ([]*models.NodeState, error)

type LogsService

type LogsService struct {
	BaseService
}

func (*LogsService) Debug

func (store *LogsService) Debug(Fid int, BatchId int, correlationId string, v ...interface{})

func (*LogsService) Error

func (store *LogsService) Error(Fid int, BatchId int, correlationId string, v ...interface{})

func (*LogsService) Info

func (store *LogsService) Info(Fid int, BatchId int, correlationId string, v ...interface{})

func (*LogsService) Warn

func (store *LogsService) Warn(Fid int, BatchId int, correlationId string, v ...interface{})

type RemoteStepService

type RemoteStepService struct {
	BaseService
}

func (*RemoteStepService) ActionDelete

func (f *RemoteStepService) ActionDelete(id int) error

* * load all actions from db

func (*RemoteStepService) CheckActionDelete

func (f *RemoteStepService) CheckActionDelete(id int) error

* * check step then delete actions from db * * if step is using.. return error

func (*RemoteStepService) CheckStepDelete

func (f *RemoteStepService) CheckStepDelete(id int) error

* * check template then delete step from db * * if step is using.. return error

type TaskService

type TaskService struct {
	BaseService
}

func (*TaskService) GetAllTaskByPool

func (t *TaskService) GetAllTaskByPool(pool_id int, task_type string) (*models.ExecTask, error)

func (*TaskService) GetCronTaskById

func (t *TaskService) GetCronTaskById(id int) (*models.CronItem, error)

func (*TaskService) GetDependTaskById

func (t *TaskService) GetDependTaskById(id int) (*models.DependItem, error)