NewLogtailClient constructs LogtailClient.

NewLogtailServer initializes a server for logtail push model.

NewSession constructs a session for logtail client.

NewSessionManager constructs a session manager.

WithServerCollectInterval sets logtail collection interval.

WithServerEnableChecksum enables checksum.

WithServerMaxMessageSize sets max rpc message size.

WithServerSendTimeout sets timeout for response sending.

LogtailClient encapsulates morpc stream.

LogtailPhase is the logtail information of one phase of subscription request.

LogtailRequest wraps logtail.LogtailRequest.

LogtailResponse wraps logtail.LogtailResponse.

LogtailResponseSegment wrps logtail.MessageSegment.

LogtailServer handles logtail push logic.

Notifier provides incremental logtail.

Session manages subscription for logtail client.

SessionManager manages all client sessions.

Waterliner maintains waterline for all subscribed tables.

LogtailRequestPool acquires or releases LogtailRequest.

LogtailResponsePool acquires or releases LogtailResponse.

LogtailResponseSegmentPool acquires or releases LogtailResponseSegment.

LogtailServerSegmentPool describes segment pool for logtail server.

TableID comes from api.TableID.