dirx

type LoadUsersRequestFactory func(*api.User) *dir.LoadUsersRequest

type Producer interface {
	Producer(chan<- *api.User, chan<- error)
	Count() int
}

type Result struct {
	Counts *dir.LoadUsersResponse
	Err    error
}

type UserSubscriber struct {
	Ctx           context.Context
	DirClient     dir.DirectoryClient
	SourceChannel chan *api.User
	ResultChannel chan *Result
	ErrorChannel  chan error
}