pubsub_factory

Documentation

Index

• Constants
• func MakeSingletonInmemPubsub(serializer message.Serializer, app app_context.Context, ...) (*pubsub_inmem.PubsubInmem, error)
• func ResetSingletonInmemPubsub()
• type PubsubConfig
  • func (p *PubsubConfig) GetConfigKeyPath() string
  • func (p *PubsubConfig) GetPoolService() *pool.PoolServiceBinding
• type PubsubConfigI
• type PubsubFactory
  • func DefaultPubsubFactory(serializer ...message.Serializer) PubsubFactory
• type PubsubFactoryBase
  • func (p *PubsubFactoryBase) MakeInmemPubsub(app app_context.Context, poolService *pool.PoolServiceBinding) (*pubsub_inmem.PubsubInmem, error)
  • func (p *PubsubFactoryBase) MakePublisher(app app_context.Context, config ...PubsubConfigI) (pubsub.Publisher, error)
  • func (p *PubsubFactoryBase) MakeSubscriber(app app_context.Context, config ...PubsubConfigI) (pubsub_subscriber.Subscriber, error)

Constants

const SingletonInmemProvider string = "singleton_inmem"

Functions

func MakeSingletonInmemPubsub

func MakeSingletonInmemPubsub(serializer message.Serializer, app app_context.Context, poolService *pool.PoolServiceBinding) (*pubsub_inmem.PubsubInmem, error)

func ResetSingletonInmemPubsub

func ResetSingletonInmemPubsub()

Types

type PubsubConfig

type PubsubConfig struct {
	PoolService   *pool.PoolServiceBinding
	ConfigKeyPath string
}

func (*PubsubConfig) GetConfigKeyPath

func (p *PubsubConfig) GetConfigKeyPath() string

func (*PubsubConfig) GetPoolService

func (p *PubsubConfig) GetPoolService() *pool.PoolServiceBinding

type PubsubConfigI

type PubsubConfigI interface {
	GetPoolService() *pool.PoolServiceBinding
	GetConfigKeyPath() string
}

type PubsubFactory

type PubsubFactory interface {
	MakePublisher(app app_context.Context, config ...PubsubConfigI) (pubsub.Publisher, error)
	MakeSubscriber(app app_context.Context, config ...PubsubConfigI) (pubsub_subscriber.Subscriber, error)
}

func DefaultPubsubFactory

func DefaultPubsubFactory(serializer ...message.Serializer) PubsubFactory

type PubsubFactoryBase

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

func (*PubsubFactoryBase) MakeInmemPubsub

func (p *PubsubFactoryBase) MakeInmemPubsub(app app_context.Context, poolService *pool.PoolServiceBinding) (*pubsub_inmem.PubsubInmem, error)

func (*PubsubFactoryBase) MakePublisher

func (p *PubsubFactoryBase) MakePublisher(app app_context.Context, config ...PubsubConfigI) (pubsub.Publisher, error)

func (*PubsubFactoryBase) MakeSubscriber

func (p *PubsubFactoryBase) MakeSubscriber(app app_context.Context, config ...PubsubConfigI) (pubsub_subscriber.Subscriber, error)