event

Documentation

Index

• Constants
• type KnowledgeBaseConsumer
  • func NewKnowledgeBaseConsumer(svc knowledge_base.RepositoryBaseSvc, q mq.MQ) (*KnowledgeBaseConsumer, error)
  • func (k *KnowledgeBaseConsumer) Consume(ctx context.Context) error
  • func (k *KnowledgeBaseConsumer) Start(ctx context.Context)
  • func (k *KnowledgeBaseConsumer) Stop(_ context.Context) error
• type KnowledgeBaseUploadEvent

Constants

const (
	KnowledgeBaseUploadTopic = "knowledge_base_upload_topic"
)

Types

type KnowledgeBaseConsumer

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

func NewKnowledgeBaseConsumer

func NewKnowledgeBaseConsumer(svc knowledge_base.RepositoryBaseSvc, q mq.MQ) (*KnowledgeBaseConsumer, error)

func (*KnowledgeBaseConsumer) Consume

func (k *KnowledgeBaseConsumer) Consume(ctx context.Context) error

func (*KnowledgeBaseConsumer) Start

func (k *KnowledgeBaseConsumer) Start(ctx context.Context)

func (*KnowledgeBaseConsumer) Stop

func (k *KnowledgeBaseConsumer) Stop(_ context.Context) error

type KnowledgeBaseUploadEvent

type KnowledgeBaseUploadEvent struct {
	Biz   string `json:"biz"`
	BizID int64  `json:"bizID"`
	// 文件名
	Name string `json:"name"`
	// 文件内容
	Data []byte `json:"data"`
	// 用途
	Type            string `json:"type"`
	KnowledgeBaseID string `json:"knowledgeBaseID"`
}

KnowledgeBaseUploadEvent 知识库上传事件