service

Documentation

Index

• type ItemCFJob
  • func (j *ItemCFJob) Run()
• type Service
  • func New(c *conf.Config) (s *Service)
  • func (s *Service) Close()
  • func (s *Service) Ping(ctx context.Context) (err error)
  • func (s *Service) RunCrontab()
• type UserAreaJob
  • func (j *UserAreaJob) Run()

Types

type ItemCFJob

type ItemCFJob struct {
	Conf       *conf.JobConfig
	RedisConf  *redis.Config
	HadoopConf *conf.HadoopConfig
}

ItemCFJob 把 hadoop 的数据写到redis

func (*ItemCFJob) Run

func (j *ItemCFJob) Run()

Run ...

type Service

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

Service struct

func New

func New(c *conf.Config) (s *Service)

New init

func (*Service) Close

func (s *Service) Close()

Close Service

func (*Service) Ping

func (s *Service) Ping(ctx context.Context) (err error)

Ping Service

func (*Service) RunCrontab

func (s *Service) RunCrontab()

RunCrontab ...

type UserAreaJob

type UserAreaJob struct {
	JobConf    *conf.JobConfig
	RedisConf  *redis.Config
	HadoopConf *conf.HadoopConfig
}

UserAreaJob 把用户分区偏好导入到redis

func (*UserAreaJob) Run

func (j *UserAreaJob) Run()

Run ...