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

Functions

func Subscriber

func Subscriber(ctx context.Context, client dir.DirectoryClient, s <-chan *api.User, done chan<- bool, 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, done chan<- bool, 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.