service

package

v0.5.1 Latest Latest Go to latest Published: Apr 1, 2021 License: MIT Imports: 14 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Service struct {
	// contains filtered or unexported fields
}

func New(kv *redis.Client, db *gorm.DB, rest *resty.Client, log *zap.SugaredLogger) *Service

New create a job service instance

func (s *Service) AgentAdd(uid string, info *types.AgentBasic) (*types.Agent, error)

AgentAdd create a server side agent

func (s *Service) AgentDelete(aid string) error

func (s *Service) AgentOffline(aid string)

call after the watcher found agent status switch to offline

func (s *Service) AgentOnline(aid, ip string)

call after every agent job pull

func (s *Service) AgentSecret(aid string) (string, error)

func (s *Service) AgentSecretReset(aid string) (string, error)

func (s *Service) AuthValidator(key string, c echo.Context) (bool, error)

func (s *Service) FindAgent(aid string) (*types.Agent, error)

func (s *Service) FindUserAgentByName(uid, name string) (id string, ok bool, err error)

func (s *Service) IsAgentOnline(aid string) bool

func (s *Service) JobCancel(id string)

Agent offline will cancel all job in queue

func (s *Service) JobExpire(id string)

func (s *Service) JobFail(id string, result string)

func (s *Service) JobPop(aid string) *types.JobBasic

call by agent, so will not return errors, notify the error to admin.

func (s *Service) JobPush(input *types.JobInput) error

call by upstream system

func (s *Service) JobSucceed(id string, result string)

func (s *Service) UserAgents(uid string) ([]*types.Agent, error)

UserAgents return user's all agent