consumers

package

v0.0.0-...-b0fceeb Latest Latest Go to latest Published: Dec 26, 2025 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

View Source

var DumpPinotMetricOnConsoleToDebug = false

DumpPinotMetricOnConsoleToDebug flag to be enabled to debug what is going into Pinot. In prod setup we will disable it

func NewMessagingFactoryLifecycle(lifecycle fx.Lifecycle, cf gox.CrossFunction, configuration *goxMessaging.Configuration, service MessagingFactory)

func NewMetricPublisher(configuration *messaging.Configuration, logger *zap.Logger) (metrics.Publisher, error)

type MessagingFactory goxMessaging.Factory

func NewMessagingFactory(cf gox.CrossFunction) (MessagingFactory, error)

type Publisher struct {
	MessagingFactory
}

func (n *Publisher) Publish(ctx context.Context, p metrics.Publishable) error

func (n *Publisher) SilentPublish(ctx context.Context, p metrics.Publishable)

func (p *Publisher) Start(ctx context.Context, mf MessagingFactory) error