plugin

Documentation

Index

• func Use(plugin plugin) func(next actor.ReceiverFunc) actor.ReceiverFunc
• type PassivationAware
• type PassivationHolder
  • func (state *PassivationHolder) Cancel()
  • func (state *PassivationHolder) Init(actorSystem *actor.ActorSystem, pid *actor.PID, duration time.Duration)
  • func (state *PassivationHolder) Reset(duration time.Duration)
• type PassivationPlugin
  • func (pp *PassivationPlugin) OnOtherMessage(ctx actor.ReceiverContext, env *actor.MessageEnvelope)
  • func (pp *PassivationPlugin) OnStart(ctx actor.ReceiverContext)

Functions

func Use

func Use(plugin plugin) func(next actor.ReceiverFunc) actor.ReceiverFunc

Types

type PassivationAware

type PassivationAware interface {
	Init(*actor.ActorSystem, *actor.PID, time.Duration)
	Reset(time.Duration)
	Cancel()
}

type PassivationHolder

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

func (*PassivationHolder) Cancel

func (state *PassivationHolder) Cancel()

func (*PassivationHolder) Init

func (state *PassivationHolder) Init(actorSystem *actor.ActorSystem, pid *actor.PID, duration time.Duration)

func (*PassivationHolder) Reset

func (state *PassivationHolder) Reset(duration time.Duration)

type PassivationPlugin

type PassivationPlugin struct {
	Duration time.Duration
}

func (*PassivationPlugin) OnOtherMessage

func (pp *PassivationPlugin) OnOtherMessage(ctx actor.ReceiverContext, env *actor.MessageEnvelope)

func (*PassivationPlugin) OnStart

func (pp *PassivationPlugin) OnStart(ctx actor.ReceiverContext)