plugin

Documentation

Index

• func SetLogLevel(level log.Level)
• func Use(plugin plugin) func(next actor.ReceiverFunc) actor.ReceiverFunc
• 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.ReceiverContext, env *actor.MessageEnvelope)
  • func (pp *PassivationPlugin) OnStart(ctx actor.ReceiverContext)

Functions

func SetLogLevel

func SetLogLevel(level log.Level)

func Use

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

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.ReceiverContext, env *actor.MessageEnvelope)

func (*PassivationPlugin) OnStart

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