plugin

Documentation

Index

• func Use(plugin plugin) func(next actor.ActorFunc) actor.ActorFunc
• type PassivationAware
• type PassivationHolder
  • func (state *PassivationHolder) Cancel()
  • func (state *PassivationHolder) Init(pid *actor.PID, duration time.Duration)
  • func (state *PassivationHolder) Reset(duration time.Duration)
• type PassivationPlugin
  • func (pp *PassivationPlugin) OnOtherMessage(ctx actor.Context, msg interface{})
  • func (pp *PassivationPlugin) OnStart(ctx actor.Context)

Functions

func Use

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

Types

type PassivationAware

type PassivationAware interface {
	Init(*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(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.Context, msg interface{})

func (*PassivationPlugin) OnStart

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