API

ReactiveTransportConfiguration

Declaration

class ReactiveTransportConfiguration {
  final void Function(dynamic frame)? tracer;
  final Duration? gracefulTimeout;
  final TransportWorkerConfiguration workerConfiguration;
}

Parameters

Name	Type	Description	Defaults
tracer	void Function(dynamic)?	Function-tracer for each frame	null
gracefulTimeout	Duration?	Timeout for graceful shutdown	null
workerConfiguration	TransportWorkerConfiguration	IOUring parameters	TransportDefaults.worker()

ReactiveChannelConfiguration

Declaration

class ReactiveChannelConfiguration {
  final int initialRequestCount;
  final int frameMaxSize;
  final int chunksLimit;
  final int fragmentSize;
}

Parameters

Name	Type	Description	Defaults
initialRequestCount	int	How many items request after channel initialization	1
chunkLimit	int	How many frames to hold before sending	8
frameMaxSize	int	Max available frame size before fragmentation	5 * 1024 * 1024
fragmentSize	int	Frame fragment size during fragmentation	10 * 1024 * 1024

ReactiveBrokerConfiguration

Declaration

class ReactiveBrokerConfiguration {
  final Map<String, ReactiveCodec> codecs;
}

Parameters

codecs

Registry of the codecs for data mime type and metadata mime type.

Defaults:

Mime type	Codec
application/message-pack	ReactiveMessagePackCodec
application/octet-stream	ReactiveRawCodec
application/text	ReactiveUtf8Codec

ReactiveLeaseConfiguration

Declaration

class ReactiveLeaseConfiguration {
  final Duration timeToLiveRefresh;
  final Duration timeToLiveCheck;
  final int requests;
}

Parameters

Name	Type	Description
timeToLiveRefresh	Duration	How often to check lease
timeToLiveCheck	Duration	Lease period
requests	int	Lease request count

ReactiveSetupConfiguration

Declaration

class ReactiveSetupConfiguration {
  final String metadataMimeType;
  final String dataMimeType;
  final Duration keepAliveInterval;
  final Duration keepAliveMaxLifetime;
  final bool lease;
}

Parameters

Name	Type	Description	Defaults
metadataMimeType	String	Mime type for payloads meta data	application/message-pack
dataMimeType	String	Mime type for payloads data	application/message-pack
keepAliveInterval	Duration	Keep alive packets sending interval	Duration(seconds: 20)
keepAliveMaxLifetime	Duration	Keep alive max available time before next frame	Duration(seconds: 90)
lease	bool	Enable/Disable lease	false