inkpub

Documentation

Index

• Constants
• func InkPublish(ctx workflow.Context, inkId int64, uid int64) error
• func WorkflowId(inkId int64, pubTime time.Time) string
• type Activities
  • func NewActivities(inkSvc ink.Service, intrSvc interactive.Service, reviewSvc review.AsyncService, ...) *Activities
  • func (a *Activities) CreateIntr(ctx context.Context, biz string, bizId int64) error
  • func (a *Activities) FindInkInfo(ctx context.Context, inkId, uid int64) (ink.Ink, error)
  • func (a *Activities) NotifyRejected(ctx context.Context, ink ink.Ink, reason string) error
  • func (a *Activities) SubmitReview(ctx context.Context, ink review.Ink) error
  • func (a *Activities) SyncToFeed(ctx context.Context, ink ink.Ink) error
  • func (a *Activities) SyncToLive(ctx context.Context, inkInfo ink.Ink) error
  • func (a *Activities) SyncToRecommend(ctx context.Context, ink ink.Ink) error
  • func (a *Activities) SyncToSearch(ctx context.Context, ink ink.Ink) error
  • func (a *Activities) UpdateInkToRejected(ctx context.Context, inkId int64, uid int64) error
  • func (a *Activities) UpdateToPublished(ctx context.Context, inkId, uid int64) error

Constants

const ReviewSignal = "review-signal"

Functions

func InkPublish

func InkPublish(ctx workflow.Context, inkId int64, uid int64) error

func WorkflowId

func WorkflowId(inkId int64, pubTime time.Time) string

Types

type Activities

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

func NewActivities

func NewActivities(
	inkSvc ink.Service,
	intrSvc interactive.Service,
	reviewSvc review.AsyncService,
	searchSyncSvc search.SyncService,
	recommendSyncSvc recommend.SyncService,
	notificationSvc notification.Service,
	feedSvc feed.Service,
) *Activities

func (*Activities) CreateIntr

func (a *Activities) CreateIntr(ctx context.Context, biz string, bizId int64) error

func (*Activities) FindInkInfo

func (a *Activities) FindInkInfo(ctx context.Context, inkId, uid int64) (ink.Ink, error)

func (*Activities) NotifyRejected

func (a *Activities) NotifyRejected(ctx context.Context, ink ink.Ink, reason string) error

func (*Activities) SubmitReview

func (a *Activities) SubmitReview(ctx context.Context, ink review.Ink) error

func (*Activities) SyncToFeed

func (a *Activities) SyncToFeed(ctx context.Context, ink ink.Ink) error

func (*Activities) SyncToLive

func (a *Activities) SyncToLive(ctx context.Context, inkInfo ink.Ink) error

func (*Activities) SyncToRecommend

func (a *Activities) SyncToRecommend(ctx context.Context, ink ink.Ink) error

func (*Activities) SyncToSearch

func (a *Activities) SyncToSearch(ctx context.Context, ink ink.Ink) error

func (*Activities) UpdateInkToRejected

func (a *Activities) UpdateInkToRejected(ctx context.Context, inkId int64, uid int64) error

func (*Activities) UpdateToPublished

func (a *Activities) UpdateToPublished(ctx context.Context, inkId, uid int64) error