actorsystem

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

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

type ActorRef interface {
	Tell(proto.Message, ActorRef)
	TellAndNoSender(proto.Message)
	GetMethod() string
	GetHost() string
	GetPort() int
	// contains filtered or unexported methods
}

type ActorSystem struct {
	Name string
	Host string
	Prot int

	RecvDecoder func([]byte, interface{})
	// contains filtered or unexported fields
}

type CallbackActorExecutor struct {
	Task *timewheel.Task
	// contains filtered or unexported fields
}

type DeadLetterActorRef struct {
	DefaultActorRef
}

type DefaultActorRef struct {
	Host    string
	Port    int
	Method  string
	Session []byte
	Sender  *MsgSender
	// contains filtered or unexported fields
}

type ICallbackUntypedActor interface {
	IDefaultUntypedActor
	ITimeoutHandler
}

type ICreateInputHandler interface {
	CreateInputObj() proto.Message
}

type IDefaultUntypedActor interface {
	IReceiveHandler
	ISenderHandler
	ISelfHandler
	ICreateInputHandler
}

type IExecutor interface {
	Execute(req *rpc.RpcMessageRequest, msgSender *MsgSender)
}

type IReceiveHandler interface {
	OnReceive(msg proto.Message)
}

type ISelfHandler interface {
	SetSelf(self ActorRef)
}

type ISenderHandler interface {
	SetSender(sender ActorRef)
}

type ITimeoutHandler interface {
	OnTimeout()
}

type IUntypedActor interface{}

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

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

type NewInput func() proto.Message

type Processor func(ActorRef, proto.Message)

type RpcClient struct {
	Address string
	// contains filtered or unexported fields
}

type RpcServer struct {
	Host string
	Port int
	// contains filtered or unexported fields
}

type UntypedActor struct {
	Sender ActorRef
	Self   ActorRef
}