pool_pubsub

Documentation

Index

• type AppConfig
• type AppConfigI
• type AppWithPubsub
• type AppWithPubsubBase
  • func NewApp(buildConfig *app_context.BuildConfig, appConfig ...AppConfigI) *AppWithPubsubBase
  • func (a *AppWithPubsubBase) Close()
  • func (a *AppWithPubsubBase) Init(configFile string, configType ...string) (op_context.Context, error)
  • func (a *AppWithPubsubBase) InitWithArgs(configFile string, args []string, configType ...string) (op_context.Context, error)
  • func (a *AppWithPubsubBase) Pubsub() PoolPubsub
• type PoolPubsub
• type PoolPubsubBase
  • func NewPubsub(factory ...pubsub_factory.PubsubFactory) *PoolPubsubBase
  • func (p *PoolPubsubBase) Init(app app_context.Context, pools pool.PoolStore) error
  • func (p *PoolPubsubBase) PublishPools(topicName string, msg interface{}, poolIds ...string) error
  • func (p *PoolPubsubBase) PublishSelfPool(topicName string, msg interface{}) error
  • func (p *PoolPubsubBase) Shutdown(ctx context.Context) error
  • func (p *PoolPubsubBase) SubscribePools(ctx op_context.Context, topic pubsub_subscriber.Topic, poolIds ...string) (map[string]string, error)
  • func (p *PoolPubsubBase) SubscribeSelfPool(ctx op_context.Context, topic pubsub_subscriber.Topic) (string, error)
  • func (p *PoolPubsubBase) UnsubscribePools(topicName string, poolIds ...string)
  • func (p *PoolPubsubBase) UnsubscribeSelfPool(topicName string)
• type PoolPubsubConfig
  • func (p *PoolPubsubConfig) GetPubsubFactory() pubsub_factory.PubsubFactory
• type PoolPubsubConfigI

Types

type AppConfig

type AppConfig struct {
	app_with_pools.AppConfig
	PoolPubsubConfig
}

type AppConfigI

type AppConfigI interface {
	app_with_pools.AppConfigI
	PoolPubsubConfigI
}

type AppWithPubsub

type AppWithPubsub interface {
	app_with_pools.AppWithPools
	Pubsub() PoolPubsub
}

type AppWithPubsubBase

type AppWithPubsubBase struct {
	*app_with_pools.AppWithPoolsBase
	// contains filtered or unexported fields
}

func NewApp

func NewApp(buildConfig *app_context.BuildConfig, appConfig ...AppConfigI) *AppWithPubsubBase

func (*AppWithPubsubBase) Close

func (a *AppWithPubsubBase) Close()

func (*AppWithPubsubBase) Init

func (a *AppWithPubsubBase) Init(configFile string, configType ...string) (op_context.Context, error)

func (*AppWithPubsubBase) InitWithArgs

func (a *AppWithPubsubBase) InitWithArgs(configFile string, args []string, configType ...string) (op_context.Context, error)

func (*AppWithPubsubBase) Pubsub

func (a *AppWithPubsubBase) Pubsub() PoolPubsub

type PoolPubsub

type PoolPubsub interface {
	Shutdown(ctx context.Context) error

	PublishSelfPool(topicName string, msg interface{}) error
	PublishPools(topicName string, msg interface{}, poolIds ...string) error

	SubscribeSelfPool(ctx op_context.Context, topic pubsub_subscriber.Topic) (string, error)
	UnsubscribeSelfPool(topicName string)

	SubscribePools(ctx op_context.Context, topic pubsub_subscriber.Topic, poolIds ...string) (map[string]string, error)
	UnsubscribePools(topicName string, poolIds ...string)
}

type PoolPubsubBase

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

func NewPubsub

func NewPubsub(factory ...pubsub_factory.PubsubFactory) *PoolPubsubBase

func (*PoolPubsubBase) Init

func (p *PoolPubsubBase) Init(app app_context.Context, pools pool.PoolStore) error

func (*PoolPubsubBase) PublishPools

func (p *PoolPubsubBase) PublishPools(topicName string, msg interface{}, poolIds ...string) error

func (*PoolPubsubBase) PublishSelfPool

func (p *PoolPubsubBase) PublishSelfPool(topicName string, msg interface{}) error

func (*PoolPubsubBase) Shutdown

func (p *PoolPubsubBase) Shutdown(ctx context.Context) error

func (*PoolPubsubBase) SubscribePools

func (p *PoolPubsubBase) SubscribePools(ctx op_context.Context, topic pubsub_subscriber.Topic, poolIds ...string) (map[string]string, error)

func (*PoolPubsubBase) SubscribeSelfPool

func (p *PoolPubsubBase) SubscribeSelfPool(ctx op_context.Context, topic pubsub_subscriber.Topic) (string, error)

func (*PoolPubsubBase) UnsubscribePools

func (p *PoolPubsubBase) UnsubscribePools(topicName string, poolIds ...string)

func (*PoolPubsubBase) UnsubscribeSelfPool

func (p *PoolPubsubBase) UnsubscribeSelfPool(topicName string)

type PoolPubsubConfig

type PoolPubsubConfig struct {
	PubsubFactory pubsub_factory.PubsubFactory
}

func (*PoolPubsubConfig) GetPubsubFactory

func (p *PoolPubsubConfig) GetPubsubFactory() pubsub_factory.PubsubFactory

type PoolPubsubConfigI

type PoolPubsubConfigI interface {
	GetPubsubFactory() pubsub_factory.PubsubFactory
}