client_option() = {timeout, non_neg_integer()} | {batch_count, non_neg_integer()} | {batch_size, non_neg_integer()} | {batch_duration, non_neg_integer()}
client_options() = [client_option()]
s2s_config() = #{scheme => scheme(), hostname => string(), port => non_neg_integer(), transport_protocol => transport_protocol(), local_network_interface => string(), port_id => binary() | string()}
scheme() = string()
The scheme, one of http or https.
transport_protocol() = raw | http
The type of client protocol.
close/1 | Closes a connection. |
create_client/1 | Creates site-to-site client. |
create_client/2 | Creates site-to-site client. |
receive_flowfiles/1 | Receives flow file from server. |
transfer_flowfiles/2 | Transfers flow file to server. |
transmit_payload/3 | Transfers raw data and attributes to server. |
close(Pid::pid()) -> ok
Closes a connection. Finishes all pending transaction and sends a shutdown to the peer.
create_client(S2SConfig::s2s_config()) -> {ok, pid()}
Creates site-to-site client.
See also: create_client/2.
create_client(S2SConfig::s2s_config(), Options::client_options()) -> {ok, pid()}
Creates site-to-site client. This function will do all the steps as described in site-to-site-protocol-sequence.
receive_flowfiles(Pid::pid()) -> {ok, nifi_flowfile:flowfiles()}
Receives flow file from server.
transfer_flowfiles(Pid::pid(), Flowfile::nifi_flowfile:flowfiles()) -> ok
Transfers flow file to server.
transmit_payload(Pid::pid(), Payload::binary(), Attributes::map()) -> boolean()
Transfers raw data and attributes to server.
Generated by EDoc