List of all items

Structs

• accumulator::AccumulatorRequest
• accumulator::Message
• accumulator::Server
• batchmap::BatchResponse
• batchmap::Datum
• batchmap::Message
• batchmap::Server
• map::MapRequest
• map::Message
• map::Server
• map::SystemMetadata
• map::UserMetadata
• mapstream::MapStreamRequest
• mapstream::Message
• mapstream::Server
• proto::accumulator::AccumulatorRequest
• proto::accumulator::AccumulatorResponse
• proto::accumulator::KeyedWindow
• proto::accumulator::Payload
• proto::accumulator::ReadyResponse
• proto::accumulator::accumulator_client::AccumulatorClient
• proto::accumulator::accumulator_request::WindowOperation
• proto::accumulator::accumulator_server::AccumulatorServer
• proto::map::Handshake
• proto::map::MapRequest
• proto::map::MapResponse
• proto::map::ReadyResponse
• proto::map::TransmissionStatus
• proto::map::map_client::MapClient
• proto::map::map_request::Request
• proto::map::map_response::Result
• proto::map::map_server::MapServer
• proto::metadata::KeyValueGroup
• proto::metadata::Metadata
• proto::reduce::ReadyResponse
• proto::reduce::ReduceRequest
• proto::reduce::ReduceResponse
• proto::reduce::Window
• proto::reduce::reduce_client::ReduceClient
• proto::reduce::reduce_request::Payload
• proto::reduce::reduce_request::WindowOperation
• proto::reduce::reduce_response::Result
• proto::reduce::reduce_server::ReduceServer
• proto::serving_store::GetRequest
• proto::serving_store::GetResponse
• proto::serving_store::Payload
• proto::serving_store::PutRequest
• proto::serving_store::PutResponse
• proto::serving_store::ReadyResponse
• proto::serving_store::serving_store_client::ServingStoreClient
• proto::serving_store::serving_store_server::ServingStoreServer
• proto::session_reduce::KeyedWindow
• proto::session_reduce::ReadyResponse
• proto::session_reduce::SessionReduceRequest
• proto::session_reduce::SessionReduceResponse
• proto::session_reduce::session_reduce_client::SessionReduceClient
• proto::session_reduce::session_reduce_request::Payload
• proto::session_reduce::session_reduce_request::WindowOperation
• proto::session_reduce::session_reduce_response::Result
• proto::session_reduce::session_reduce_server::SessionReduceServer
• proto::side_input::ReadyResponse
• proto::side_input::SideInputResponse
• proto::side_input::side_input_client::SideInputClient
• proto::side_input::side_input_server::SideInputServer
• proto::sink::Handshake
• proto::sink::ReadyResponse
• proto::sink::SinkRequest
• proto::sink::SinkResponse
• proto::sink::TransmissionStatus
• proto::sink::sink_client::SinkClient
• proto::sink::sink_request::Request
• proto::sink::sink_response::Result
• proto::sink::sink_response::result::Message
• proto::sink::sink_server::SinkServer
• proto::source::AckRequest
• proto::source::AckResponse
• proto::source::Handshake
• proto::source::NackRequest
• proto::source::NackResponse
• proto::source::Offset
• proto::source::PartitionsResponse
• proto::source::PendingResponse
• proto::source::ReadRequest
• proto::source::ReadResponse
• proto::source::ReadyResponse
• proto::source::ack_request::Request
• proto::source::ack_response::Result
• proto::source::nack_request::Request
• proto::source::nack_response::Result
• proto::source::partitions_response::Result
• proto::source::pending_response::Result
• proto::source::read_request::Request
• proto::source::read_response::Result
• proto::source::read_response::Status
• proto::source::source_client::SourceClient
• proto::source::source_server::SourceServer
• proto::source_transformer::Handshake
• proto::source_transformer::ReadyResponse
• proto::source_transformer::SourceTransformRequest
• proto::source_transformer::SourceTransformResponse
• proto::source_transformer::source_transform_client::SourceTransformClient
• proto::source_transformer::source_transform_request::Request
• proto::source_transformer::source_transform_response::Result
• proto::source_transformer::source_transform_server::SourceTransformServer
• reduce::IntervalWindow
• reduce::Message
• reduce::Metadata
• reduce::ReduceRequest
• reduce::Server
• reducestream::Server
• serving_store::Data
• serving_store::Payload
• serving_store::Server
• session_reduce::Message
• session_reduce::Server
• session_reduce::SessionReduceRequest
• shared::ServerConfig
• shared::grpc_server::Server
• sideinput::Server
• sink::KeyValueGroup
• sink::Message
• sink::Response
• sink::Server
• sink::SinkRequest
• sink::SystemMetadata
• sink::UserMetadata
• source::Message
• source::Offset
• source::Server
• source::SourceReadRequest
• source::UserMetadata
• sourcetransform::Message
• sourcetransform::Server
• sourcetransform::SourceTransformRequest
• sourcetransform::SystemMetadata
• sourcetransform::UserMetadata

Enums

• error::Error
• error::ErrorKind
• proto::accumulator::accumulator_request::window_operation::Event
• proto::reduce::reduce_request::window_operation::Event
• proto::session_reduce::session_reduce_request::window_operation::Event
• proto::sink::Status
• proto::source::read_response::status::Code
• proto::source::read_response::status::Error
• sink::ResponseType

Traits

• accumulator::Accumulator
• accumulator::AccumulatorCreator
• batchmap::BatchMapper
• map::Mapper
• mapstream::MapStreamer
• proto::accumulator::accumulator_server::Accumulator
• proto::map::map_server::Map
• proto::reduce::reduce_server::Reduce
• proto::serving_store::serving_store_server::ServingStore
• proto::session_reduce::session_reduce_server::SessionReduce
• proto::side_input::side_input_server::SideInput
• proto::sink::sink_server::Sink
• proto::source::source_server::Source
• proto::source_transformer::source_transform_server::SourceTransform
• reduce::Reducer
• reduce::ReducerCreator
• reducestream::ReduceStreamer
• reducestream::ReduceStreamerCreator
• serving_store::ServingStore
• session_reduce::SessionReducer
• session_reduce::SessionReducerCreator
• shared::grpc_server::ServerExtras
• sideinput::SideInputer
• sink::Sinker
• source::Sourcer
• sourcetransform::SourceTransformer

Type Aliases

• error::Result
• reducestream::ReduceStreamRequest

Constants

• accumulator::SERVER_INFO_FILE
• accumulator::SOCK_ADDR
• batchmap::SERVER_INFO_FILE
• batchmap::SOCK_ADDR
• map::SERVER_INFO_FILE
• map::SOCK_ADDR
• mapstream::SERVER_INFO_FILE
• mapstream::SOCK_ADDR
• proto::accumulator::accumulator_server::SERVICE_NAME
• proto::map::map_server::SERVICE_NAME
• proto::reduce::reduce_server::SERVICE_NAME
• proto::serving_store::serving_store_server::SERVICE_NAME
• proto::session_reduce::session_reduce_server::SERVICE_NAME
• proto::side_input::side_input_server::SERVICE_NAME
• proto::sink::sink_server::SERVICE_NAME
• proto::source::source_server::SERVICE_NAME
• proto::source_transformer::source_transform_server::SERVICE_NAME
• reduce::SERVER_INFO_FILE
• reduce::SOCK_ADDR
• reducestream::SERVER_INFO_FILE
• reducestream::SOCK_ADDR
• serving_store::SERVER_INFO_FILE
• serving_store::SOCK_ADDR
• session_reduce::SERVER_INFO_FILE
• session_reduce::SOCK_ADDR
• shared::DROP
• sideinput::DIR_PATH
• sideinput::SERVER_INFO_FILE
• sideinput::SOCK_ADDR
• sink::FB_SERVER_INFO_FILE
• sink::FB_SOCK_ADDR
• sink::ONS_SERVER_INFO_FILE
• sink::ONS_SOCK_ADDR
• sink::SERVER_INFO_FILE
• sink::SOCK_ADDR
• source::SERVER_INFO_FILE
• source::SOCK_ADDR
• sourcetransform::SERVER_INFO_FILE
• sourcetransform::SOCK_ADDR