Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AdapterOptions ¶
type AdapterOptions struct {
RedisClient *redis.RedisClient
}
type GooglePubSub ¶
type GooglePubSub struct {
Cfg Config
}
func NewGooglePubSub ¶
func NewGooglePubSub(projectId string, authJsonPath string) *GooglePubSub
func (*GooglePubSub) Strategy ¶
func (g *GooglePubSub) Strategy(model interface{}) *GooglePubSub
the strategy is optional, if you cant validate topic and subcription before setup client in your project
type GooglePubSubAdapter ¶
type GooglePubSubAdapter struct { Broker *GooglePubSub Options *AdapterOptions }
func (*GooglePubSubAdapter) Init ¶
func (ga *GooglePubSubAdapter) Init() error
func (*GooglePubSubAdapter) Publish ¶
func (ga *GooglePubSubAdapter) Publish(ctx context.Context, m messagebroker.PublishMessage) error
func (*GooglePubSubAdapter) Subscribe ¶
func (ga *GooglePubSubAdapter) Subscribe(ctx context.Context, name string, handler messagebroker.SubscribeMessageHandler)
type PublishMessage ¶
Click to show internal directories.
Click to hide internal directories.