plugin

package
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 25, 2020 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL