hazelcast

Feb 12, 2021

Changes in this version

type Hazelcast

+ func (p *Hazelcast) Close() error

+ func (p *Hazelcast) Features() []pubsub.Feature

May 29, 2020

Changes in this version

+ func NewHazelcastPubSub(logger logger.Logger) pubsub.PubSub

+ type Hazelcast struct

+ func (p *Hazelcast) Init(metadata pubsub.Metadata) error

+ func (p *Hazelcast) Publish(req *pubsub.PublishRequest) error

+ func (p *Hazelcast) Subscribe(req pubsub.SubscribeRequest, handler func(msg *pubsub.NewMessage) error) error