dirx

Documentation

Index

• func Subscriber(ctx context.Context, client dir.DirectoryClient, s <-chan *api.User, ...)
• func UserExtSubscriber(ctx context.Context, client dir.DirectoryClient, s <-chan *api.User, ...)
• type Producer
• type Result

Functions

func Subscriber

func Subscriber(ctx context.Context, client dir.DirectoryClient, s <-chan *api.User, r chan<- *Result, errc chan<- error, inclAttrSets bool)

Subscriber subscribes to the api.User channel and sends the users instance to the directory using the gRPC LoadUsers API.

func UserExtSubscriber

func UserExtSubscriber(ctx context.Context, client dir.DirectoryClient, s <-chan *api.User, r chan<- *Result, errc chan<- error)

UserExtSubscriber subscribes to the api.User channel and sends user extensions (api.UserExt message) to the directory using the gRPC LoadUser API.

Types

type Producer

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

Producer interface.

type Result

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