middleware

Documentation

Index

• func LifecycleLogger() actor.ReceiverMiddleware
• func OptionalUsing(one actor.ReceiverMiddleware, ...) func(next actor.ReceiverFunc) actor.ReceiverFunc
• func PersistenceUsing(provider persistence.Provider) func(next actor.ReceiverFunc) actor.ReceiverFunc
• func SystemSync(wg *sync.WaitGroup) actor.ReceiverMiddleware
• type LogAware
• type LogAwareHolder
  • func (state *LogAwareHolder) Logger() *zerolog.Logger
  • func (state *LogAwareHolder) SetLog(logger zerolog.Logger)
• type LogInjectorPlugin
  • func (p *LogInjectorPlugin) OnOtherMessage(_ actor.ReceiverContext, _ *actor.MessageEnvelope)
  • func (p *LogInjectorPlugin) OnStart(ctx actor.ReceiverContext)
• type SpawnAwareMixin
  • func (state *SpawnAwareMixin) SpawnNamedOrDie(ctx actor.Context, props *actor.Props, name string) *actor.PID
• type SpawnInjectorPlugin
  • func (p *SpawnInjectorPlugin) OnOtherMessage(ctx actor.ReceiverContext, msg *actor.MessageEnvelope)
  • func (p *SpawnInjectorPlugin) OnStart(ctx actor.ReceiverContext)

Functions

func LifecycleLogger

func LifecycleLogger() actor.ReceiverMiddleware

LifecycleLogger is a middleware which logs lifecycle messages (started, stopped...).

func OptionalUsing

func OptionalUsing(
	one actor.ReceiverMiddleware,
	predicate func(ctx actor.ReceiverContext, env *actor.MessageEnvelope) bool,
) func(next actor.ReceiverFunc) actor.ReceiverFunc

func PersistenceUsing

func PersistenceUsing(provider persistence.Provider) func(next actor.ReceiverFunc) actor.ReceiverFunc

PersistenceUsing installs the persistence mixin only on Persistent actors. TODO: it would be preferable to have the peristence.Using function to be less strict regarding the nature of the actor.

func SystemSync

func SystemSync(wg *sync.WaitGroup) actor.ReceiverMiddleware

Types

type LogAware

type LogAware interface {
	Logger() *zerolog.Logger
	SetLog(logger zerolog.Logger)
}

type LogAwareHolder

type LogAwareHolder struct {
	Log zerolog.Logger
}

func (*LogAwareHolder) Logger

func (state *LogAwareHolder) Logger() *zerolog.Logger

func (*LogAwareHolder) SetLog

func (state *LogAwareHolder) SetLog(logger zerolog.Logger)

type LogInjectorPlugin

type LogInjectorPlugin struct{}

func (*LogInjectorPlugin) OnOtherMessage

func (p *LogInjectorPlugin) OnOtherMessage(_ actor.ReceiverContext, _ *actor.MessageEnvelope)

func (*LogInjectorPlugin) OnStart

func (p *LogInjectorPlugin) OnStart(ctx actor.ReceiverContext)

type SpawnAwareMixin

type SpawnAwareMixin struct {
	LogAwareHolder
}

func (*SpawnAwareMixin) SpawnNamedOrDie

func (state *SpawnAwareMixin) SpawnNamedOrDie(ctx actor.Context, props *actor.Props, name string) *actor.PID

type SpawnInjectorPlugin

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

func (*SpawnInjectorPlugin) OnOtherMessage

func (p *SpawnInjectorPlugin) OnOtherMessage(ctx actor.ReceiverContext, msg *actor.MessageEnvelope)

func (*SpawnInjectorPlugin) OnStart

func (p *SpawnInjectorPlugin) OnStart(ctx actor.ReceiverContext)