Documentation ¶
Overview ¶
Package kafka provides ...
Index ¶
- func UpdateEsClassStaff(Value []byte) error
- type BaseLogic
- type ClassStaff
- type EsConf
- type EsLogic
- func (e EsLogic) CreateDoc(id string, body string) (*esapi.Response, error)
- func (e EsLogic) DeleteDoc(id string) (*esapi.Response, error)
- func (e EsLogic) GetDoc(id string) (*esapi.Response, error)
- func (e EsLogic) SQLDoc(body string) (*esapi.Response, error)
- func (e EsLogic) Search(body string, esIndex string) (*esapi.Response, error)
- func (e EsLogic) UpdateDoc(id string, body string) (*esapi.Response, error)
- type KafkaConf
- type KafkaLogic
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func UpdateEsClassStaff ¶
Types ¶
type ClassStaff ¶
type ClassStaff struct { CompanyId string `json:"company_id"` ClassId string `json:"class_id"` StaffId string `json:"staff_id"` LearnTime int `json:"learn_time"` LastCourseId string `json:"last_course_id"` Procedure int `json:"procedure"` Status int `json:"status"` IsRemoved bool `json:"is_removed"` IsDeleted bool `json:"is_deleted"` SucceededAt interface{} `json:"succeeded_at"` StartedAt interface{} `json:"started_at"` CreatedAt interface{} `json:"created_at"` UpdatedAt interface{} `json:"updated_at"` SourceType string `json:"source_type"` TeamId string `json:"team_id"` AppSourceType string `json:"app_source_type"` RoadmapId string `json:"roadmap_id"` ClassType string `json:"class_type"` CategoryId string `json:"category_id"` IsRequired bool `json:"is_required"` }
type EsConf ¶
type EsConf struct { IP string Port string Index string Username string Passwd string Es *elasticsearch.Client }
EsConf es配置
type EsLogic ¶
type EsLogic struct { BaseLogic // contains filtered or unexported fields }
EsLogic
Click to show internal directories.
Click to hide internal directories.