yue

type ActorConfig struct {
	SpawnConfig SpawnConfig //object which describe how to create
	Size        int         //how many process can join this actor? if == 1, means only 1 process can serve as this actor.
	//if <= 0, means unlimited processes can serve.
	Throttle int //only enable when Size != 1.

}

type ActorError struct {
	Type uint8
	Args []interface{}
}

type CodecFactory interface {
	NewDecoder(c net.Conn) Decoder
	NewEncoder(c net.Conn) Encoder
}

type Config struct {
	Listeners                []net.Listener
	MeshServerPort           int
	MeshServerNetwork        string
	MeshServerCodec          string
	MeshServerConnTimeoutSec int
	MeshServerPingInterval   int
	DatabaseAddress          string
	CertPath                 string
	DockerCertPath           string
	HostAddress              string
	DefaultApiVersion        string
	Codecs                   map[string]CodecFactory
}

type ContainerExecuterFactory struct {
	Config     container.Config     `json:"config"`
	HostConfig container.HostConfig `json:"host_config"`
}

type Decoder interface {
	Decode(pl interface{}) error
}

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

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

type Encoder interface {
	Encode(pl interface{}) error
	Flush() error
}

type Executer interface {
	Call(string, ...interface{}) (interface{}, error)
}

type ExecuterFactory interface {
	Create(uint64, ...interface{}) (Executer, error)
	Destroy(Executer)
}

type InmemoryExecuterFactory struct {
	Constructor interface{}
	// contains filtered or unexported fields
}

type InmemoryFactory struct {
	Constructor func(args ...interface{}) (interface{}, error)
}

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

type JsonDecoder struct {
	json.Decoder
	// contains filtered or unexported fields
}

type JsonEncoder struct {
	json.Encoder
	// contains filtered or unexported fields
}

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

type MsgpackDecoder struct {
	msgpack.Decoder
	// contains filtered or unexported fields
}

type MsgpackEncoder struct {
	msgpack.Encoder
	// contains filtered or unexported fields
}

type Node struct {
	proto.Node
	// contains filtered or unexported fields
}

type Process struct {
	Id proto.ProcessId

	Executer Executer //all executer methods called concurrenctly from multiple goroutine.
	// contains filtered or unexported fields
}

type ProcessId proto.ProcessId

type SpawnConfig struct {
	Factory ExecuterFactory
	// contains filtered or unexported fields
}

type UUID proto.UUID