Struct GeyserGrpcBuilder 

pub struct GeyserGrpcBuilder {
    pub endpoint: Endpoint,
    pub x_token: Option<AsciiMetadataValue>,
    pub x_request_snapshot: bool,
    pub send_compressed: Option<CompressionEncoding>,
    pub accept_compressed: Option<CompressionEncoding>,
    pub max_decoding_message_size: Option<usize>,
    pub max_encoding_message_size: Option<usize>,
}

Fields

endpoint: Endpoint

x_token: Option<AsciiMetadataValue>

x_request_snapshot: bool

send_compressed: Option<CompressionEncoding>

accept_compressed: Option<CompressionEncoding>

max_decoding_message_size: Option<usize>

max_encoding_message_size: Option<usize>

Implementations

impl GeyserGrpcBuilder

pub fn from_shared(endpoint: impl Into<Bytes>) -> GeyserGrpcBuilderResult<Self>

pub fn from_static(endpoint: &'static str) -> Self

pub async fn connect( self, ) -> GeyserGrpcBuilderResult<GeyserGrpcClient<impl Interceptor>>

pub fn connect_lazy( self, ) -> GeyserGrpcBuilderResult<GeyserGrpcClient<impl Interceptor>>

pub fn x_token<T>(self, x_token: Option<T>) -> GeyserGrpcBuilderResult<Self>

where T: TryInto<AsciiMetadataValue, Error = InvalidMetadataValue>,

pub fn set_x_request_snapshot(self, value: bool) -> Self

pub fn connect_timeout(self, dur: Duration) -> Self

pub fn buffer_size(self, sz: impl Into<Option<usize>>) -> Self

pub fn http2_adaptive_window(self, enabled: bool) -> Self

pub fn http2_keep_alive_interval(self, interval: Duration) -> Self

pub fn initial_connection_window_size(self, sz: impl Into<Option<u32>>) -> Self

pub fn initial_stream_window_size(self, sz: impl Into<Option<u32>>) -> Self

pub fn keep_alive_timeout(self, duration: Duration) -> Self

pub fn keep_alive_while_idle(self, enabled: bool) -> Self

pub fn tcp_keepalive(self, tcp_keepalive: Option<Duration>) -> Self

pub fn tcp_nodelay(self, enabled: bool) -> Self

pub fn timeout(self, dur: Duration) -> Self

pub fn tls_config( self, tls_config: ClientTlsConfig, ) -> GeyserGrpcBuilderResult<Self>

pub fn send_compressed(self, encoding: CompressionEncoding) -> Self

pub fn accept_compressed(self, encoding: CompressionEncoding) -> Self

pub fn max_decoding_message_size(self, limit: usize) -> Self

pub fn max_encoding_message_size(self, limit: usize) -> Self

Trait Implementations

impl Debug for GeyserGrpcBuilder

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.