client

Documentation

Index

• type NatsSubscription
• type NatsSubscriptionImpl
  • func NewNatsSubscription(pubSubClient *pubsub.PubSubClientServiceImpl, logger *zap.SugaredLogger, ...) (*NatsSubscriptionImpl, error)

Types

type NatsSubscription

type NatsSubscription interface {
}

type NatsSubscriptionImpl

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

func NewNatsSubscription

func NewNatsSubscription(pubSubClient *pubsub.PubSubClientServiceImpl,
	logger *zap.SugaredLogger,
	ingestionService pkg.IngestionService) (*NatsSubscriptionImpl, error)