hazelcast

package

v1.9.7 Latest Latest Go to latest Published: Feb 1, 2023 License: Apache-2.0 Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

func NewHazelcastPubSub(logger logger.Logger) pubsub.PubSub

NewHazelcastPubSub returns a new hazelcast pub-sub implementation.

type Hazelcast struct {
	// contains filtered or unexported fields
}

func (p *Hazelcast) Close() error

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

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

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

func (p *Hazelcast) Subscribe(subscribeCtx context.Context, req pubsub.SubscribeRequest, handler pubsub.Handler) error