pubsub

Documentation

Index

• type NatSubscription
• type NatSubscriptionImpl
  • func NewNatSubscription(pubSubClient *pubsub1.PubSubClientServiceImpl, logger *zap.SugaredLogger, ...) (*NatSubscriptionImpl, error)
  • func (impl *NatSubscriptionImpl) Subscribe() error
• type NatsSubscriptionModeConfig
  • func NewNatsSubscriptionModeConfig() NatsSubscriptionModeConfig
• type TestPublish
• type TestPublishImpl
  • func NewTestPublishImpl(pubSubClient *pubsub.PubSubClientServiceImpl, logger *zap.SugaredLogger) *TestPublishImpl
  • func (impl *TestPublishImpl) PublishForScan(channel string, payload interface{}) error

Types

type NatSubscription

type NatSubscription interface {
	Subscribe() error
}

type NatSubscriptionImpl

type NatSubscriptionImpl struct {
	PubSubClient *pubsub1.PubSubClientServiceImpl
	Logger       *zap.SugaredLogger
	ClairService clairService.ClairService
}

func NewNatSubscription

func NewNatSubscription(pubSubClient *pubsub1.PubSubClientServiceImpl,
	logger *zap.SugaredLogger,
	clairService clairService.ClairService, natsSubscriptionConfig NatsSubscriptionModeConfig) (*NatSubscriptionImpl, error)

func (*NatSubscriptionImpl) Subscribe

func (impl *NatSubscriptionImpl) Subscribe() error

type NatsSubscriptionModeConfig

type NatsSubscriptionModeConfig struct {
	ToBeSubscribed bool
}

func NewNatsSubscriptionModeConfig

func NewNatsSubscriptionModeConfig() NatsSubscriptionModeConfig

type TestPublish

type TestPublish interface {
	PublishForScan(channel string, payload interface{}) error
}

type TestPublishImpl

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

func NewTestPublishImpl

func NewTestPublishImpl(pubSubClient *pubsub.PubSubClientServiceImpl,
	logger *zap.SugaredLogger) *TestPublishImpl

func (*TestPublishImpl) PublishForScan

func (impl *TestPublishImpl) PublishForScan(channel string, payload interface{}) error