hr

Documentation

Index

• type HRUsersModify
  • func (x *HRUsersModify) HREvent() kafkaemployees.ProtoEvent
  • func (x *HRUsersModify) Len() int
  • func (x *HRUsersModify) TopicName() string
• type SourceUser
  • func (e SourceUser) GetId() string
• type UsersTask
  • 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

Types

type HRUsersModify

type HRUsersModify kafkaemployees.HRUsersModify

func (*HRUsersModify) HREvent

func (x *HRUsersModify) HREvent() kafkaemployees.ProtoEvent

func (*HRUsersModify) Len

func (x *HRUsersModify) Len() int

func (*HRUsersModify) TopicName

func (x *HRUsersModify) TopicName() string

type SourceUser

type SourceUser struct {
	Id        string     `json:"id"`
	CreatedAt time.Time  `json:"createdAt"`
	UpdatedAt time.Time  `json:"updatedAt"`
	DeletedAt *time.Time `json:"deletedAt,omitempty"`

	Login          string `json:"userName"`
	FullName       string `json:"fullName"`
	Email          string `json:"email"`
	Phone          string `json:"phone"`
	SupervisorID   string `json:"supervisorID"`
	OrganizationID string `json:"organizationID"`
	PositionTitle  string `json:"positionTitle"`
	UnitID         string `json:"unitID"`
	LocationID     string `json:"locationID"`
}

func (SourceUser) GetId

func (e SourceUser) GetId() string

type UsersTask

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

func NewUsersTask

func NewUsersTask(kfk *kafkaframe.Kafka) *UsersTask

func (*UsersTask) ConvertUser

func (s *UsersTask) ConvertUser(ctx context.Context) func(SourceUser) *kafkaemployees.HRUser

func (*UsersTask) ExecuteSync

func (s *UsersTask) ExecuteSync(ctx context.Context) error

func (*UsersTask) FullSync

func (s *UsersTask) FullSync(ctx context.Context, taskId xid.ID, chbun chan etl.SyncObjer) time.Time

func (*UsersTask) String

func (s *UsersTask) String() string