producer

Documentation

Index

• type ProduceController
  • func NewProduceController(ctx context.Context, notifyProducer <-chan pushconfig.PushConfig, ...) *ProduceController
  • func (p *ProduceController) Assign(ctx context.Context, cfg pushconfig.PushConfig)
  • func (p *ProduceController) CancelProduce()
  • func (p *ProduceController) ListenDismissCond(ctx context.Context, wg *sync.WaitGroup)
  • func (p *ProduceController) ListenEngageCond(ctx context.Context, wg *sync.WaitGroup)
  • func (p *ProduceController) WatchLeftTask(ctx context.Context, wg *sync.WaitGroup, key string, interval time.Duration)
  • func (p *ProduceController) WatchTask(ctx context.Context, wg *sync.WaitGroup)
• type Producer
  • func NewProducer(repo repository.ProducerRepository) *Producer
  • func (p *Producer) Produce(ctx context.Context, cfg pushconfig.PushConfig)

Types

type ProduceController

type ProduceController struct {
	CancelFuncs *sync.Map
	// contains filtered or unexported fields
}

func NewProduceController

func NewProduceController(ctx context.Context, notifyProducer <-chan pushconfig.PushConfig,
	notifyLoadBalancer chan<- pushconfig.PushConfig,
	start, stop *cond.CondAtomic, repo repository.ProducerRepository,
	interceptor *interceptor.Interceptor,
) *ProduceController

func (*ProduceController) Assign

func (p *ProduceController) Assign(ctx context.Context, cfg pushconfig.PushConfig)

func (*ProduceController) CancelProduce

func (p *ProduceController) CancelProduce()

func (*ProduceController) ListenDismissCond

func (p *ProduceController) ListenDismissCond(ctx context.Context, wg *sync.WaitGroup)

ListenDismissCond 这边收到了停止信号，是不知道什么原因让停止的 /没拿到锁 应该传黑匣子/手动停止 应该传黑匣子/服务关闭 应该传黑匣子--统一了 不需要知道原因

func (*ProduceController) ListenEngageCond

func (p *ProduceController) ListenEngageCond(ctx context.Context, wg *sync.WaitGroup)

func (*ProduceController) WatchLeftTask

func (p *ProduceController) WatchLeftTask(ctx context.Context, wg *sync.WaitGroup, key string, interval time.Duration)

func (*ProduceController) WatchTask

func (p *ProduceController) WatchTask(ctx context.Context, wg *sync.WaitGroup)

type Producer

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

func NewProducer

func NewProducer(repo repository.ProducerRepository) *Producer

func (*Producer) Produce

func (p *Producer) Produce(ctx context.Context, cfg pushconfig.PushConfig)