event

Documentation

Index

• Constants
• type SyncConsumer
  • func NewSyncConsumer(svc service.SyncService, q mq.MQ) (*SyncConsumer, error)
  • func (s *SyncConsumer) Consume(ctx context.Context) error
  • func (s *SyncConsumer) Start(ctx context.Context)
  • func (s *SyncConsumer) Stop(_ context.Context) error
• type SyncEvent

Constants

const (
	SyncTopic = "sync_data_to_search"
)

Types

type SyncConsumer

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

func NewSyncConsumer

func NewSyncConsumer(svc service.SyncService, q mq.MQ) (*SyncConsumer, error)

func (*SyncConsumer) Consume

func (s *SyncConsumer) Consume(ctx context.Context) error

func (*SyncConsumer) Start

func (s *SyncConsumer) Start(ctx context.Context)

func (*SyncConsumer) Stop

func (s *SyncConsumer) Stop(_ context.Context) error

type SyncEvent

type SyncEvent struct {
	Biz   string `json:"biz"`
	BizID int    `json:"bizID"`
	// 具体内容
	Data string `json:"data"`
}