svc

Documentation

Index

• type CounterSvc
  • func NewCounterSvc(ctx *ServiceContext, repo *repo.Repo, cache *redis.Redis) *CounterSvc
  • func (s *CounterSvc) AddRecord(ctx context.Context, req *counterv1.AddRecordRequest) (*counterv1.AddRecordResponse, error)
  • func (s *CounterSvc) BatchGetRecord(ctx context.Context, uidOids map[uint64][]uint64, biz int) (map[uint64][]*counterv1.Record, error)
  • func (s *CounterSvc) BatchGetSummary(ctx context.Context, req *counterv1.BatchGetSummaryRequest) (*counterv1.BatchGetSummaryResponse, error)
  • func (s *CounterSvc) CancelRecord(ctx context.Context, req *counterv1.CancelRecordRequest) (*counterv1.CancelRecordResponse, error)
  • func (s *CounterSvc) GetRecord(ctx context.Context, req *counterv1.GetRecordRequest) (*counterv1.GetRecordResponse, error)
  • func (s *CounterSvc) GetSummary(ctx context.Context, req *counterv1.GetSummaryRequest) (*counterv1.GetSummaryResponse, error)
  • func (s *CounterSvc) SyncCacheSummary(ctx context.Context) error
  • func (s *CounterSvc) SyncSummaryFromRecords(ctx context.Context) error
• type ServiceContext
  • func NewServiceContext(c *config.Config) *ServiceContext

Types

type CounterSvc

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

func NewCounterSvc

func NewCounterSvc(ctx *ServiceContext, repo *repo.Repo, cache *redis.Redis) *CounterSvc

func (*CounterSvc) AddRecord

func (s *CounterSvc) AddRecord(ctx context.Context,
	req *counterv1.AddRecordRequest) (*counterv1.AddRecordResponse, error)

新增计数记录

func (*CounterSvc) BatchGetRecord

func (s *CounterSvc) BatchGetRecord(ctx context.Context, uidOids map[uint64][]uint64, biz int) (
	map[uint64][]*counterv1.Record, error)

func (*CounterSvc) BatchGetSummary

func (s *CounterSvc) BatchGetSummary(ctx context.Context, req *counterv1.BatchGetSummaryRequest) (
	*counterv1.BatchGetSummaryResponse, error)

批量获取某个oid的计数

func (*CounterSvc) CancelRecord

func (s *CounterSvc) CancelRecord(ctx context.Context,
	req *counterv1.CancelRecordRequest) (*counterv1.CancelRecordResponse, error)

取消计数记录

func (*CounterSvc) GetRecord

func (s *CounterSvc) GetRecord(ctx context.Context,
	req *counterv1.GetRecordRequest) (*counterv1.GetRecordResponse, error)

func (*CounterSvc) GetSummary

func (s *CounterSvc) GetSummary(ctx context.Context, req *counterv1.GetSummaryRequest) (*counterv1.GetSummaryResponse, error)

获取某个oid的计数

func (*CounterSvc) SyncCacheSummary

func (s *CounterSvc) SyncCacheSummary(ctx context.Context) error

同步增量数据到数据库

func (*CounterSvc) SyncSummaryFromRecords

func (s *CounterSvc) SyncSummaryFromRecords(ctx context.Context) error

全表扫描 从record表更新summary的数据

type ServiceContext

type ServiceContext struct {
	Config    *config.Config
	RecordSvc *CounterSvc
}

func NewServiceContext

func NewServiceContext(c *config.Config) *ServiceContext

初始化一个service