dirx

Documentation

Index

• func Subscriber(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)

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

Types

type Producer

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

Producer interface.