repository

Documentation

Index

• Variables
• type ProducerRepository
  • func NewProducerRepository(local cache.LocalCache, rdb redis.Cmdable) ProducerRepository
• type Task
  • func NewTask(businessName string) *Task
  • func (t *Task) Add(msg domain.Message)
  • func (t *Task) Keys(biz string) (res []string)

Variables

var (
	ErrKeyNotExist = redis.Nil
	NoMessage      = cache.ErrNoMessage
)

Types

type ProducerRepository

type ProducerRepository interface {
	// Store 暂存消息到本地缓存中
	Store(ctx context.Context, msg domain.Message) error
	// WriteBack 刷新本地缓存到存储介质中
	WriteBack(ctx context.Context, businessName string) error
	// WriteBackLeftTask 如果生产被打断，只把受影响的任务写到黑匣子，由下一任生产者启动时先根据黑匣子生产遗留任务
	WriteBackLeftTask(ctx context.Context, businessName string) error
	GetLeftTask(ctx context.Context) (pushconfig.PushConfig, error)
}

func NewProducerRepository

func NewProducerRepository(local cache.LocalCache, rdb redis.Cmdable) ProducerRepository

type Task

type Task struct {
	BusinessName string
	// map key: deviceType val:id列表
	DeviceMap map[string][]string
}

func NewTask

func NewTask(businessName string) *Task

func (*Task) Add

func (t *Task) Add(msg domain.Message)

func (*Task) Keys

func (t *Task) Keys(biz string) (res []string)