Module doris_starrocks_connector

Structs

HeaderBuilder

InserterInner

InserterInnerBuilder

MetaRequestSender

StarrocksTxnRequestBuilder

Enums

StreamLoadResponse 🔒

Constants

BUFFER_SIZE 🔒

DORIS_DELETE_SIGN 🔒

DORIS_SUCCESS_STATUS 🔒

LOCALHOST 🔒

LOCALHOST_IP 🔒

MIN_CHUNK_SIZE 🔒

POOL_IDLE_TIMEOUT 🔒

STARROCKS_DELETE_SIGN 🔒

STARROCKS_SUCCESS_STATUS 🔒

WAIT_HANDDLE_TIMEOUT 🔒

Functions

send_stream_load_request 🔒

Send the request and handle redirection if any. The reason we handle the redirection manually is that if we let reqwest handle the redirection automatically, it will remove sensitive headers (such as Authorization) during the redirection, and there’s no way to prevent this behavior. Please note, the FE address that user specified might be a FE follower not the leader, in this case, the follower FE will redirect request to leader FE and then to BE.

try_get_be_url 🔒

Try getting BE url from a redirected response, returning Ok(None) indicates this request does not redirect.

Type Aliases

Sender 🔒