Versions in this module Expand all Collapse all v1 v1.0.0 May 31, 2023 Changes in this version + type ExecuteContext struct + Kfk *kafkaframe.Kafka + Loader FullAndDeltaLoader + func (s ExecuteContext) ExecuteSync(ctx context.Context) error + type FullAndDeltaLoader interface + FullSync func(ctx context.Context, taskId xid.ID, chbun chan SyncObjer) time.Time + type FullSyncContext struct + Builder func(taskId xid.ID, els []R) SyncObjer + Convertor func(hrel T) R + Fetcher func(ctx context.Context, ch chan []T) + func (s FullSyncContext[T, R]) FullSync(ctx context.Context, taskId xid.ID, chout chan SyncObjer) time.Time + type HRGCliModel interface + GetId func() string + type HRModel interface + GetUpdatedAt func() *timestamppb.Timestamp + IsZero func() bool + type SyncObjer interface + HREvent func() kafkaemployees.ProtoEvent + Len func() int + TopicName func() string
Go to main page