actor

package
v1.2.22 Latest Latest
Warning

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

 Go to latest Published: Nov 26, 2022 License: GPL-3.0 Imports: 18 Imported by: 5

Documentation

Index

Constants

View Source 
const (
	DefaultSysAddr = ":8888"
)
View Source 
const DefaultTimeout = time.Second * 10

Variables

This section is empty.

Functions

func LDebug 

func LDebug(l *lua.LState) int

func LError 

func LError(l *lua.LState) int

func LGoVersion 

func LGoVersion(l *lua.LState) int

func LWarn 

func LWarn(l *lua.LState) int

func New 

func New(id Id, handler spawnActor, opt ...Option) *actor

New build a new actor id is invalid if contain '@' or '$'

func ParseRequestId 

func ParseRequestId(requestId string) (sourceId string, targetId string, sourceAddr string, ok bool)

Types

type Actor added in v1.0.4 

type Actor interface {
	ID() string
	System() *System
	Exit()
	Drain(afterDrained ...func())

	Timer
	Sender

	CallLua(name string, ret int, args ...lua.LValue) []lua.LValue
}

type Base 

type Base struct {
	Actor
}

func (*Base) OnHandleEvent 

func (s *Base) OnHandleEvent(event interface{})

func (*Base) OnHandleMessage 

func (s *Base) OnHandleMessage(sourceId, targetId Id, msg interface{})

func (*Base) OnHandleRequest 

func (s *Base) OnHandleRequest(sourceId, targetId Id, requestId string, msg interface{}) (respErr error)

func (*Base) OnInit 

func (s *Base) OnInit()

func (*Base) OnStop 

func (s *Base) OnStop() bool

type EvClusterUpdate added in v1.0.7 

type EvClusterUpdate struct {
	ActorId Id
	Host    string
	Add     bool
}

type EvDelActor added in v1.2.16 

type EvDelActor struct {
	ActorId     Id
	Publish     bool
	FromCluster bool
}

type EvNewActor added in v1.2.16 

type EvNewActor struct {
	ActorId     Id
	Publish     bool
	FromCluster bool
}

type EvSessionClosed added in v1.2.16 

type EvSessionClosed struct {
	PeerHost string
}

type EvSessionOpened added in v1.2.16 

type EvSessionOpened struct {
	PeerHost string
}

type Handler added in v1.2.21 

type Handler interface{}

type Id added in v1.2.21 

type Id = string

type Option added in v1.1.10 

type Option func(*actor)

func SetLocalized 

func SetLocalized() Option

func SetLua 

func SetLua(path string) Option

func SetMailBoxSize 

func SetMailBoxSize(boxSize int) Option

type ReqMsgDrain added in v1.2.21 

type ReqMsgDrain struct{}

type RespMsgDrain added in v1.2.21 

type RespMsgDrain struct{ Err error }

type Sender added in v1.1.1 

type Sender interface {
	Send(targetId Id, msg interface{}) error
	Request(targetId Id, msg interface{}, timeout ...time.Duration) (req *request)
	RequestWait(targetId Id, msg interface{}, timeout ...time.Duration) (result interface{}, err error)
	Response(requestId string, msg interface{}) error
}

type System 

type System struct {
	Stopped chan struct{}
	// contains filtered or unexported fields
}

func NewSystem 

func NewSystem(op ...SystemOption) (*System, error)

func (*System) Add added in v1.1.13 

func (s *System) Add(actor *actor) error

Add startup a new actor

func (*System) Address 

func (s *System) Address() string

func (*System) CancelAll 

func (ed *System) CancelAll(actorId Id)

func (*System) CancelEvent 

func (ed *System) CancelEvent(actorId Id, events ...interface{})

func (*System) Cluster added in v1.2.18 

func (s *System) Cluster() *actor

func (*System) DispatchEvent 

func (ed *System) DispatchEvent(sourceId Id, event interface{})

func (*System) LocalActor added in v1.2.19 

func (s *System) LocalActor(actorId string) *actor

func (*System) OnEvent added in v1.2.21 

func (ed *System) OnEvent(actorId Id, callback Handler)

func (*System) ProtoIndex added in v1.2.2 

func (s *System) ProtoIndex() *tools.ProtoIndex

func (*System) RequestWait added in v1.2.18 

func (s *System) RequestWait(targetId string, msg interface{}, timeout ...time.Duration) (resp interface{}, err error)

RequestWait sync request

func (*System) Send 

func (s *System) Send(sourceId, targetId Id, requestId string, msg interface{}) (err error)

Send try to send the message to target

func (*System) SetCluster 

func (s *System) SetCluster(act *actor)

func (*System) Stop 

func (s *System) Stop()

func (*System) WaiterId added in v1.2.21 

func (s *System) WaiterId() string

type SystemOption 

type SystemOption func(*System) error

func Addr 

func Addr(addr string) SystemOption

func ProtoIndex added in v1.2.0 

func ProtoIndex(pi *tools.ProtoIndex) SystemOption

ProtoIndex index proto struct

type Timer added in v1.1.1 

type Timer interface {
	AddTimer(timeId string, endAt time.Time, callback func(dt time.Duration), triggerCount ...int) string
	CancelTimer(timerId string)
}

type TmpActor added in v1.2.18 

type TmpActor struct {
	Base
	Init          func()
	Stop          func() bool
	HandleMessage func(sourceId, targetId Id, msg interface{})
	HandleRequest func(sourceId, targetId Id, requestId string, msg interface{}) error
	HandleEvent   func(event interface{})
}

func (*TmpActor) OnHandleEvent added in v1.2.18 

func (s *TmpActor) OnHandleEvent(event interface{})

func (*TmpActor) OnHandleMessage added in v1.2.18 

func (s *TmpActor) OnHandleMessage(sourceId, targetId Id, msg interface{})

func (*TmpActor) OnHandleRequest added in v1.2.18 

func (s *TmpActor) OnHandleRequest(sourceId, targetId Id, requestId string, msg interface{}) (respErr error)

func (*TmpActor) OnInit added in v1.2.18 

func (s *TmpActor) OnInit()

func (*TmpActor) OnStop added in v1.2.21 

func (s *TmpActor) OnStop() bool

Source Files

View all Source files

Directories

Path Synopsis
cluster
fullmesh
fullmesh/remote_provider
fullmesh/remote_provider/remote_grpc
fullmesh/remote_provider/remote_grpc/internal
fullmesh/remote_provider/remote_tcp
fullmesh/servmesh_provider
fullmesh/servmesh_provider/consul
fullmesh/servmesh_provider/etcd
mq
mq/nats
internal
actor_msg
script

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.