groupsync

Documentation

Index

• func Command() *cli.Command
• func Sender(ch *amqp.Channel, logger log.Logger) (event.Publisher, error)
• func StartConsumer(ctx context.Context, appCtx *appContext, args *arguments) (safeExit chan struct{}, err error)

Functions

func Command

func Command() *cli.Command

Return a command that starts a process to synchronize group membership of user resources.

func Sender

func Sender(ch *amqp.Channel, logger log.Logger) (event.Publisher, error)

Create a new sender that listens to membership changes and publishes group sync messages.

func StartConsumer

func StartConsumer(ctx context.Context, appCtx *appContext, args *arguments) (safeExit chan struct{}, err error)

Start the message consuming process with the cancellable context and return a safe exit channel. The cancellable context can be used to notify the consumer that it should abort. However, the consumer only checks for this signal before processing each message and hence may not immediately abort. The returned safe exit channel can be received by the caller process when the consumer is truly ready to exit.