Versions in this module Expand all Collapse all v1 v1.0.0 May 31, 2023 Changes in this version + type HRUsersModify kafkaemployees.HRUsersModify + func (x *HRUsersModify) HREvent() kafkaemployees.ProtoEvent + func (x *HRUsersModify) Len() int + func (x *HRUsersModify) TopicName() string + type SourceUser struct + CreatedAt time.Time + DeletedAt *time.Time + Email string + FullName string + Id string + LocationID string + Login string + OrganizationID string + Phone string + PositionTitle string + SupervisorID string + UnitID string + UpdatedAt time.Time + func (e SourceUser) GetId() string + type UsersTask struct + func NewUsersTask(kfk *kafkaframe.Kafka) *UsersTask + func (s *UsersTask) ConvertUser(ctx context.Context) func(SourceUser) *kafkaemployees.HRUser + func (s *UsersTask) ExecuteSync(ctx context.Context) error + func (s *UsersTask) FullSync(ctx context.Context, taskId xid.ID, chbun chan etl.SyncObjer) time.Time + func (s *UsersTask) String() string
Go to main page