\adminmatrix\swoole\ipc\driverUnixSocket

Summary

Methods
Properties
Constants
__construct()
listenMessage()
sendMessage()
getType()
prepare()
subscribe()
publish()
No public properties found
HEADER_SIZE
HEADER_STRUCT
HEADER_PACK
getSocket()
$config
$manager
$workerId
$packets
N/A
No private methods found
No private properties found
N/A

Constants

HEADER_SIZE

HEADER_SIZE = 8

HEADER_STRUCT

HEADER_STRUCT = 'Nworker/Nlength'

HEADER_PACK

HEADER_PACK = 'NN'

Properties

$config

$config : array

Type

array

$manager

$manager : \adminmatrix\swoole\Manager

Type

Manager

$workerId

$workerId

$packets

$packets : \adminmatrix\swoole\packet\Buffer[]

Type

Buffer[]

Methods

__construct()

__construct(\adminmatrix\swoole\Manager  $manager, array  $config) : mixed

Parameters

\adminmatrix\swoole\Manager $manager
array $config

Returns

mixed —

listenMessage()

listenMessage(mixed  $workerId) : mixed

Parameters

mixed $workerId

Returns

mixed —

sendMessage()

sendMessage(mixed  $workerId, mixed  $message) : mixed

Parameters

mixed $workerId
mixed $message

Returns

mixed —

getType()

getType() : mixed

Returns

mixed —

prepare()

prepare(\Swoole\Process\Pool  $pool) : mixed

Parameters

\Swoole\Process\Pool $pool

Returns

mixed —

subscribe()

subscribe() : mixed

Returns

mixed —

publish()

publish(mixed  $workerId, mixed  $message) : mixed

Parameters

mixed $workerId
mixed $message

Returns

mixed —

getSocket()

getSocket( $workerId) : \Swoole\Coroutine\Socket

Parameters

$workerId

Returns

\Swoole\Coroutine\Socket —