goku 不同提供者的惯用队列
悟空不同提供者的惯用队列。 Goku尝试通过使用通道来统一队列交互(目前仅支持SQS)。用法首先,您需要初始化库,指定一个提供程序,在本例中sqs_provider是一个实例。 q := goku . NewQueue ( tgoku . Reader ( sqs_provider ), tgoku . Writer ( sqs_provider ), ) goku.Queue将公开两个通道,一个用于读取消息Sender() ,另一个用于写入消息Receiver() 。之后,您应该能够与队列交换消息,如下所示: q . Receiver () <- "Message" msg := <- q . Sender ()有关更多信息,请阅读。
用户评论