Synadia Connect

Timeplus

NAMERUNTIMETYPEVERSION
timepluswombatsinklatest

Sends message to a Timeplus Enterprise stream via ingest endpoint

This output can send message to Timeplus Enterprise Cloud, Timeplus Enterprise (self-hosted) or directly to timeplusd.

This output accepts structured message only. It also expects all message contains the same keys and matches the schema of the destination stream.


Configuration

NameTypeOptionalSecretDescription
targetstringyesnoThe destination type, either Timeplus Enterprise or timeplusd. The value should be one of timeplus or timeplusd. The value defaults to "timeplus".
urlstringyesnoThe url should always include schema and host. The value defaults to "https://us-west-2.timeplus.cloud".
workspacestringnonoID of the workspace. Required if target is timeplus.
streamstringnonoThe name of the stream. Make sure the schema of the stream matches the input
apikeystringnoyesThe API key. Required if you are sending message to Timeplus Enterprise Cloud
usernamestringnonoThe username. Required if you are sending message to Timeplus Enterprise (self-hosted) or timeplusd
passwordstringnoyesThe password. Required if you are sending message to Timeplus Enterprise (self-hosted) or timeplusd
max_in_flightintyesnoThe maximum number of messages to have in flight at a given time. Increase this to improve throughput. The value defaults to 64.
batchingbatchingnonoAllows you to configure a batching policy.

Batching

NameTypeOptionalSecretDescription
countintyesnoA number of messages at which the batch should be flushed. If 0 disables count based batching. The value defaults to 0.
byte_sizeintyesnoAn amount of bytes at which the batch should be flushed. If 0 disables size based batching. The value defaults to 0.
periodstringyesnoA period in which an incomplete batch should be flushed regardless of its size. The value defaults to "".
checkstringyesnoA Bloblang query that should return a boolean value indicating whether a message should end a batch. The value defaults to "".
Previous
SFTP