providers

Documentation

Index

• func ProvideEventSource(lc fx.Lifecycle, bus glocbus.EventBusInterface, ...) *sources.HeartbeatEventSource
• func ProvideHeartbeatSubscribers(lc fx.Lifecycle, bus glocbus.EventBusInterface, ...) []subscribers.HeartbeatSubscriber
• func ProvideTraceProvider(lc fx.Lifecycle) (trace.TracerProvider, error)
• type GlocbusSingletonProvider
  • func (provider *GlocbusSingletonProvider) ProvideGlocbusInstance(tracerProvider trace.TracerProvider) glocbus.EventBusInterface

Functions

func ProvideEventSource

func ProvideEventSource(
	lc fx.Lifecycle,
	bus glocbus.EventBusInterface,
	tracerProvider trace.TracerProvider,
	logger *log.Logger,
) *sources.HeartbeatEventSource

func ProvideHeartbeatSubscribers

func ProvideHeartbeatSubscribers(
	lc fx.Lifecycle,
	bus glocbus.EventBusInterface,
	tracerProvider trace.TracerProvider,
	logger *log.Logger,
) []subscribers.HeartbeatSubscriber

func ProvideTraceProvider

func ProvideTraceProvider(lc fx.Lifecycle) (trace.TracerProvider, error)

Types

type GlocbusSingletonProvider

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

Type for a provider that manages a glocbus instance as a singleton

func (*GlocbusSingletonProvider) ProvideGlocbusInstance

func (provider *GlocbusSingletonProvider) ProvideGlocbusInstance(tracerProvider trace.TracerProvider) glocbus.EventBusInterface

Provide the managed Glocbus instance