service

Documentation

Index

• Constants
• func NewPeriodConcurrent(time time.Time, add add, workersCount, dataType int, ...) periodConcurrent
• type CircleCountHandler
  • func NewCircleCountHandler(repo repository.Repository, publisher pub.EventBusPublisher, ...) CircleCountHandler
  • func (c CircleCountHandler) GetCircleCountData(ctx context.Context, in *analyticsV1.GetCircleCountDataRequest) ([]model.CircleCountData, error)
  • func (c CircleCountHandler) PopulateData(ctx context.Context, from time.Time, add add) (model.CircleCountDataList, error)
• type CircleDataHandler
  • func NewCircleDataHandler(repo repository.Repository, publisher pub.EventBusPublisher, ...) CircleDataHandler
  • func (c CircleDataHandler) GetTrackedCirclesData(ctx context.Context, circleID string, period model.Period) ([]*analyticsV1.GetCircleDataResponse_CircleDataHolder, error)
• type CircleHandler
  • func NewCircleHandler(repo repository.Repository, publisher pub.EventBusPublisher) CircleHandler
  • func (c CircleHandler) AddCircle(ctx context.Context, circle model.Circle) error
  • func (c CircleHandler) DeleteCircle(ctx context.Context, circleID string) error
  • func (c CircleHandler) GetCircles(ctx context.Context) ([]model.Circle, error)
• type ICron
• type JobHandler
  • func NewJobHandler(repo repository.Repository, publisher pub.EventBusPublisher, ...) JobHandler
  • func (j JobHandler) CheckInitialJobs(ctx context.Context) error
  • func (j JobHandler) LockJob(ctx context.Context, jobID string) error
  • func (j JobHandler) UnlockJob(ctx context.Context, jobID string) error
• type JobWorkerHandler
  • func NewJobWorkerHandler(repo repository.Repository, publisher pub.EventBusPublisher, cron ICron, ...) JobWorkerHandler
  • func (j JobWorkerHandler) ProcessJob(ctx context.Context, job model.Job) error
  • func (j JobWorkerHandler) StartJobWorker() error
• type Service
  • func New(repo repository.Repository, eventPublisher pub.EventBusPublisher, cron ICron, ...) Service
• type UserDataHandler
  • func NewUserDataHandler(repo repository.Repository, profileClient profilePb.ProfileAPIClient, ...) UserDataHandler
  • func (c UserDataHandler) GetUserCountData(ctx context.Context, in *analyticsV1.GetUserCountDataRequest) ([]model.CountData, error)

Constants

const (
	Circle dataType = iota
	User   dataType = iota
)

Functions

func NewPeriodConcurrent

func NewPeriodConcurrent(
	time time.Time, add add, workersCount, dataType int,
	circleClient circlePb.CircleAPIClient,
	profileClient profilePb.ProfileAPIClient,
) periodConcurrent

Types

type CircleCountHandler

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

func NewCircleCountHandler

func NewCircleCountHandler(
	repo repository.Repository,
	publisher pub.EventBusPublisher,
	circleClient circlePb.CircleAPIClient,
) CircleCountHandler

func (CircleCountHandler) GetCircleCountData

func (c CircleCountHandler) GetCircleCountData(ctx context.Context, in *analyticsV1.GetCircleCountDataRequest) (
	[]model.CircleCountData, error,
)

func (CircleCountHandler) PopulateData

func (c CircleCountHandler) PopulateData(ctx context.Context, from time.Time, add add) (
	model.CircleCountDataList, error,
)

type CircleDataHandler

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

func NewCircleDataHandler

func NewCircleDataHandler(
	repo repository.Repository,
	publisher pub.EventBusPublisher,
	circleClient circlePb.CircleAPIClient,
) CircleDataHandler

func (CircleDataHandler) GetTrackedCirclesData

func (c CircleDataHandler) GetTrackedCirclesData(
	ctx context.Context, circleID string, period model.Period) (
	[]*analyticsV1.GetCircleDataResponse_CircleDataHolder, error,
)

type CircleHandler

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

func NewCircleHandler

func NewCircleHandler(
	repo repository.Repository,
	publisher pub.EventBusPublisher,
) CircleHandler

func (CircleHandler) AddCircle

func (c CircleHandler) AddCircle(ctx context.Context, circle model.Circle) error

func (CircleHandler) DeleteCircle

func (c CircleHandler) DeleteCircle(ctx context.Context, circleID string) error

func (CircleHandler) GetCircles

func (c CircleHandler) GetCircles(ctx context.Context) ([]model.Circle, error)

type ICron

type ICron interface {
	DoConcurrently(ctx context.Context, interval model.Period, do func()) error
}

type JobHandler

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

func NewJobHandler

func NewJobHandler(
	repo repository.Repository,
	publisher pub.EventBusPublisher,
	circleClient circlePb.CircleAPIClient,
) JobHandler

func (JobHandler) CheckInitialJobs

func (j JobHandler) CheckInitialJobs(ctx context.Context) error

func (JobHandler) LockJob

func (j JobHandler) LockJob(ctx context.Context, jobID string) error

func (JobHandler) UnlockJob

func (j JobHandler) UnlockJob(ctx context.Context, jobID string) error

type JobWorkerHandler

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

func NewJobWorkerHandler

func NewJobWorkerHandler(
	repo repository.Repository,
	publisher pub.EventBusPublisher,
	cron ICron,
	circleClient circlePb.CircleAPIClient,
) JobWorkerHandler

func (JobWorkerHandler) ProcessJob

func (j JobWorkerHandler) ProcessJob(ctx context.Context, job model.Job) error

func (JobWorkerHandler) StartJobWorker

func (j JobWorkerHandler) StartJobWorker() error

type Service

type Service struct {
	JobHandler
	JobWorkerHandler
	CircleHandler
	CircleDataHandler
	CircleCountHandler
	UserDataHandler
	ICron
}

func New

func New(
	repo repository.Repository,
	eventPublisher pub.EventBusPublisher,
	cron ICron,
	circleClient circlePb.CircleAPIClient,
	profileClient profilePb.ProfileAPIClient,
) Service

type UserDataHandler

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

func NewUserDataHandler

func NewUserDataHandler(
	repo repository.Repository,
	profileClient profilePb.ProfileAPIClient,
	circleClient circlePb.CircleAPIClient,
) UserDataHandler

func (UserDataHandler) GetUserCountData

func (c UserDataHandler) GetUserCountData(
	ctx context.Context, in *analyticsV1.GetUserCountDataRequest,
) ([]model.CountData, error)