sea-streamer-0.5.0
- sea-streamer 0.5.0
- Permalink
- Docs.rs crate page
- MIT OR Apache-2.0
- Links
- Documentation
- Repository
- Crates.io
- Source
- Owners
- tyt2y3
- Dependencies
- sea-streamer-file ^0.5 normal optional
  
  sea-streamer-kafka ^0.5 normal optional
  
  sea-streamer-redis ^0.5 normal optional
  
  sea-streamer-runtime ^0.5 normal optional
  
  sea-streamer-socket ^0.5 normal optional
  
  sea-streamer-stdio ^0.5 normal optional
  
  sea-streamer-types ^0.5 normal
- Versions
- 100% of the crate is documented
Platform
- i686-unknown-linux-gnu
- x86_64-unknown-linux-gnu
Feature flags

Rust

sea_streamer0.5.0

Macros
Structs
Enums
Constants
Traits
Functions
Type Aliases

List of all items

Structs

ConsumerGroup
ConsumerId
MessageHeader
OwnedMessage
Payload
SeaConnectOptions
SeaConsumer
SeaConsumerOptions
SeaProducer
SeaProducerOptions
SeaStreamer
ShardId
SharedMessage
StreamKey
StreamUrl
StreamerUri
Timestamp
export::futures::channel::mpsc::Receiver
export::futures::channel::mpsc::SendError
export::futures::channel::mpsc::Sender
export::futures::channel::mpsc::TryRecvError
export::futures::channel::mpsc::TrySendError
export::futures::channel::mpsc::UnboundedReceiver
export::futures::channel::mpsc::UnboundedSender
export::futures::channel::oneshot::Canceled
export::futures::channel::oneshot::Cancellation
export::futures::channel::oneshot::Receiver
export::futures::channel::oneshot::Sender
export::futures::io::AllowStdIo
export::futures::io::BufReader
export::futures::io::BufWriter
export::futures::io::Chain
export::futures::io::Close
export::futures::io::Copy
export::futures::io::CopyBuf
export::futures::io::CopyBufAbortable
export::futures::io::Cursor
export::futures::io::Empty
export::futures::io::Error
export::futures::io::FillBuf
export::futures::io::Flush
export::futures::io::IntoSink
export::futures::io::IoSlice
export::futures::io::IoSliceMut
export::futures::io::LineWriter
export::futures::io::Lines
export::futures::io::Read
export::futures::io::ReadExact
export::futures::io::ReadHalf
export::futures::io::ReadLine
export::futures::io::ReadToEnd
export::futures::io::ReadToString
export::futures::io::ReadUntil
export::futures::io::ReadVectored
export::futures::io::Repeat
export::futures::io::ReuniteError
export::futures::io::SeeKRelative
export::futures::io::Seek
export::futures::io::Sink
export::futures::io::Take
export::futures::io::Window
export::futures::io::Write
export::futures::io::WriteAll
export::futures::io::WriteHalf
export::futures::io::WriteVectored
export::futures::lock::MappedMutexGuard
export::futures::lock::Mutex
export::futures::lock::MutexGuard
export::futures::lock::MutexLockFuture
export::futures::lock::OwnedMutexGuard
export::futures::lock::OwnedMutexLockFuture
export::futures::prelude::future::AbortHandle
export::futures::prelude::future::AbortRegistration
export::futures::prelude::future::Abortable
export::futures::prelude::future::Aborted
export::futures::prelude::future::AndThen
export::futures::prelude::future::CatchUnwind
export::futures::prelude::future::ErrInto
export::futures::prelude::future::Flatten
export::futures::prelude::future::FlattenSink
export::futures::prelude::future::FlattenStream
export::futures::prelude::future::Fuse
export::futures::prelude::future::FutureObj
export::futures::prelude::future::Inspect
export::futures::prelude::future::InspectErr
export::futures::prelude::future::InspectOk
export::futures::prelude::future::IntoFuture
export::futures::prelude::future::IntoStream
export::futures::prelude::future::Join
export::futures::prelude::future::Join3
export::futures::prelude::future::Join4
export::futures::prelude::future::Join5
export::futures::prelude::future::JoinAll
export::futures::prelude::future::Lazy
export::futures::prelude::future::LocalFutureObj
export::futures::prelude::future::Map
export::futures::prelude::future::MapErr
export::futures::prelude::future::MapInto
export::futures::prelude::future::MapOk
export::futures::prelude::future::MapOkOrElse
export::futures::prelude::future::NeverError
export::futures::prelude::future::OkInto
export::futures::prelude::future::OptionFuture
export::futures::prelude::future::OrElse
export::futures::prelude::future::Pending
export::futures::prelude::future::PollFn
export::futures::prelude::future::PollImmediate
export::futures::prelude::future::Ready
export::futures::prelude::future::Remote
export::futures::prelude::future::RemoteHandle
export::futures::prelude::future::Select
export::futures::prelude::future::SelectAll
export::futures::prelude::future::SelectOk
export::futures::prelude::future::Shared
export::futures::prelude::future::Then
export::futures::prelude::future::TryFlatten
export::futures::prelude::future::TryFlattenStream
export::futures::prelude::future::TryJoin
export::futures::prelude::future::TryJoin3
export::futures::prelude::future::TryJoin4
export::futures::prelude::future::TryJoin5
export::futures::prelude::future::TryJoinAll
export::futures::prelude::future::TrySelect
export::futures::prelude::future::UnitError
export::futures::prelude::future::UnwrapOrElse
export::futures::prelude::future::WeakShared
export::futures::prelude::sink::Buffer
export::futures::prelude::sink::Close
export::futures::prelude::sink::Drain
export::futures::prelude::sink::Fanout
export::futures::prelude::sink::Feed
export::futures::prelude::sink::Flush
export::futures::prelude::sink::Send
export::futures::prelude::sink::SendAll
export::futures::prelude::sink::SinkErrInto
export::futures::prelude::sink::SinkMapErr
export::futures::prelude::sink::Unfold
export::futures::prelude::sink::With
export::futures::prelude::sink::WithFlatMap
export::futures::prelude::stream::AbortHandle
export::futures::prelude::stream::AbortRegistration
export::futures::prelude::stream::Abortable
export::futures::prelude::stream::Aborted
export::futures::prelude::stream::All
export::futures::prelude::stream::AndThen
export::futures::prelude::stream::Any
export::futures::prelude::stream::BufferUnordered
export::futures::prelude::stream::Buffered
export::futures::prelude::stream::CatchUnwind
export::futures::prelude::stream::Chain
export::futures::prelude::stream::Chunks
export::futures::prelude::stream::Collect
export::futures::prelude::stream::Concat
export::futures::prelude::stream::Count
export::futures::prelude::stream::Cycle
export::futures::prelude::stream::Empty
export::futures::prelude::stream::Enumerate
export::futures::prelude::stream::ErrInto
export::futures::prelude::stream::Filter
export::futures::prelude::stream::FilterMap
export::futures::prelude::stream::FlatMap
export::futures::prelude::stream::FlatMapUnordered
export::futures::prelude::stream::Flatten
export::futures::prelude::stream::Fold
export::futures::prelude::stream::ForEach
export::futures::prelude::stream::ForEachConcurrent
export::futures::prelude::stream::Forward
export::futures::prelude::stream::Fuse
export::futures::prelude::stream::FuturesOrdered
export::futures::prelude::stream::FuturesUnordered
export::futures::prelude::stream::Inspect
export::futures::prelude::stream::InspectErr
export::futures::prelude::stream::InspectOk
export::futures::prelude::stream::IntoAsyncRead
export::futures::prelude::stream::IntoStream
export::futures::prelude::stream::Iter
export::futures::prelude::stream::Map
export::futures::prelude::stream::MapErr
export::futures::prelude::stream::MapOk
export::futures::prelude::stream::Next
export::futures::prelude::stream::NextIf
export::futures::prelude::stream::NextIfEq
export::futures::prelude::stream::Once
export::futures::prelude::stream::OrElse
export::futures::prelude::stream::Peek
export::futures::prelude::stream::PeekMut
export::futures::prelude::stream::Peekable
export::futures::prelude::stream::Pending
export::futures::prelude::stream::PollFn
export::futures::prelude::stream::PollImmediate
export::futures::prelude::stream::ReadyChunks
export::futures::prelude::stream::Repeat
export::futures::prelude::stream::RepeatWith
export::futures::prelude::stream::ReuniteError
export::futures::prelude::stream::Scan
export::futures::prelude::stream::Select
export::futures::prelude::stream::SelectAll
export::futures::prelude::stream::SelectNextSome
export::futures::prelude::stream::SelectWithStrategy
export::futures::prelude::stream::Skip
export::futures::prelude::stream::SkipWhile
export::futures::prelude::stream::SplitSink
export::futures::prelude::stream::SplitStream
export::futures::prelude::stream::StreamFuture
export::futures::prelude::stream::Take
export::futures::prelude::stream::TakeUntil
export::futures::prelude::stream::TakeWhile
export::futures::prelude::stream::Then
export::futures::prelude::stream::TryAll
export::futures::prelude::stream::TryAny
export::futures::prelude::stream::TryBufferUnordered
export::futures::prelude::stream::TryBuffered
export::futures::prelude::stream::TryChunks
export::futures::prelude::stream::TryChunksError
export::futures::prelude::stream::TryCollect
export::futures::prelude::stream::TryConcat
export::futures::prelude::stream::TryFilter
export::futures::prelude::stream::TryFilterMap
export::futures::prelude::stream::TryFlatten
export::futures::prelude::stream::TryFlattenUnordered
export::futures::prelude::stream::TryFold
export::futures::prelude::stream::TryForEach
export::futures::prelude::stream::TryForEachConcurrent
export::futures::prelude::stream::TryNext
export::futures::prelude::stream::TryReadyChunks
export::futures::prelude::stream::TryReadyChunksError
export::futures::prelude::stream::TrySkipWhile
export::futures::prelude::stream::TryTakeWhile
export::futures::prelude::stream::TryUnfold
export::futures::prelude::stream::Unfold
export::futures::prelude::stream::Unzip
export::futures::prelude::stream::Zip
export::futures::prelude::stream::futures_unordered::FuturesUnordered
export::futures::prelude::stream::futures_unordered::IntoIter
export::futures::prelude::stream::futures_unordered::Iter
export::futures::prelude::stream::futures_unordered::IterMut
export::futures::prelude::stream::futures_unordered::IterPinMut
export::futures::prelude::stream::futures_unordered::IterPinRef
export::futures::prelude::stream::select_all::IntoIter
export::futures::prelude::stream::select_all::Iter
export::futures::prelude::stream::select_all::IterMut
export::futures::prelude::stream::select_all::SelectAll
export::futures::task::AtomicWaker
export::futures::task::Context
export::futures::task::FutureObj
export::futures::task::LocalFutureObj
export::futures::task::RawWaker
export::futures::task::RawWakerVTable
export::futures::task::SpawnError
export::futures::task::Waker
export::futures::task::WakerRef
export::time::Date
export::time::Duration
export::time::Instant
export::time::OffsetDateTime
export::time::PrimitiveDateTime
export::time::Time
export::time::UtcOffset
export::time::convert::Day
export::time::convert::Hour
export::time::convert::Microsecond
export::time::convert::Millisecond
export::time::convert::Minute
export::time::convert::Nanosecond
export::time::convert::Second
export::time::convert::Week
export::time::error::ComponentRange
export::time::error::ConversionRange
export::time::error::DifferentVariant
export::time::error::InvalidVariant
export::time::format_description::modifier::Day
export::time::format_description::modifier::End
export::time::format_description::modifier::Hour
export::time::format_description::modifier::Ignore
export::time::format_description::modifier::Minute
export::time::format_description::modifier::Month
export::time::format_description::modifier::OffsetHour
export::time::format_description::modifier::OffsetMinute
export::time::format_description::modifier::OffsetSecond
export::time::format_description::modifier::Ordinal
export::time::format_description::modifier::Period
export::time::format_description::modifier::Second
export::time::format_description::modifier::Subsecond
export::time::format_description::modifier::UnixTimestamp
export::time::format_description::modifier::WeekNumber
export::time::format_description::modifier::Weekday
export::time::format_description::modifier::Year
export::time::format_description::well_known::Iso8601
export::time::format_description::well_known::Rfc2822
export::time::format_description::well_known::Rfc3339
export::time::format_description::well_known::iso8601::Config
export::time::format_description::well_known::iso8601::Iso8601
export::time::parsing::Parsed
export::url::OpaqueOrigin
export::url::ParseOptions
export::url::PathSegmentsMut
export::url::Url
export::url::UrlQuery
export::url::form_urlencoded::ByteSerialize
export::url::form_urlencoded::Parse
export::url::form_urlencoded::ParseIntoOwned
export::url::form_urlencoded::Serializer

Enums

Backend
BackendErr
BytesOrStr
ConsumerMode
JsonErr
NextFuture
SeaMessage
SeaMessageStream
SeaStreamReset
SendFuture
SeqPos
StreamErr
StreamKeyErr
StreamUrlErr
export::futures::io::ErrorKind
export::futures::io::SeekFrom
export::futures::prelude::future::Either
export::futures::prelude::future::MaybeDone
export::futures::prelude::future::TryMaybeDone
export::futures::prelude::stream::PollNext
export::futures::task::Poll
export::time::Error
export::time::Month
export::time::Weekday
export::time::error::Error
export::time::error::Format
export::time::error::InvalidFormatDescription
export::time::error::Parse
export::time::error::ParseFromDescription
export::time::error::TryFromParsed
export::time::format_description::BorrowedFormatItem
export::time::format_description::Component
export::time::format_description::FormatItem
export::time::format_description::OwnedFormatItem
export::time::format_description::modifier::MonthRepr
export::time::format_description::modifier::Padding
export::time::format_description::modifier::SubsecondDigits
export::time::format_description::modifier::UnixTimestampPrecision
export::time::format_description::modifier::WeekNumberRepr
export::time::format_description::modifier::WeekdayRepr
export::time::format_description::modifier::YearRepr
export::time::format_description::well_known::iso8601::DateKind
export::time::format_description::well_known::iso8601::FormattedComponents
export::time::format_description::well_known::iso8601::OffsetPrecision
export::time::format_description::well_known::iso8601::TimePrecision
export::url::Host
export::url::Origin
export::url::ParseError
export::url::Position
export::url::SyntaxViolation

Traits

Buffer
ConnectOptions
Consumer
ConsumerOptions
IntoBytesOrStr
Message
Producer
ProducerOptions
SeaStreamerBackend
Streamer
export::futures::AsyncBufRead
export::futures::AsyncBufReadExt
export::futures::AsyncRead
export::futures::AsyncReadExt
export::futures::AsyncSeek
export::futures::AsyncSeekExt
export::futures::AsyncWrite
export::futures::AsyncWriteExt
export::futures::Future
export::futures::FutureExt
export::futures::Sink
export::futures::SinkExt
export::futures::Stream
export::futures::StreamExt
export::futures::TryFuture
export::futures::TryFutureExt
export::futures::TryStream
export::futures::TryStreamExt
export::futures::io::AsyncBufRead
export::futures::io::AsyncBufReadExt
export::futures::io::AsyncRead
export::futures::io::AsyncReadExt
export::futures::io::AsyncSeek
export::futures::io::AsyncSeekExt
export::futures::io::AsyncWrite
export::futures::io::AsyncWriteExt
export::futures::prelude::AsyncBufRead
export::futures::prelude::AsyncRead
export::futures::prelude::AsyncSeek
export::futures::prelude::AsyncWrite
export::futures::prelude::Future
export::futures::prelude::Sink
export::futures::prelude::Stream
export::futures::prelude::TryFuture
export::futures::prelude::TryStream
export::futures::prelude::_
export::futures::prelude::future::FusedFuture
export::futures::prelude::future::Future
export::futures::prelude::future::FutureExt
export::futures::prelude::future::TryFuture
export::futures::prelude::future::TryFutureExt
export::futures::prelude::future::UnsafeFutureObj
export::futures::prelude::sink::Sink
export::futures::prelude::sink::SinkExt
export::futures::prelude::stream::FusedStream
export::futures::prelude::stream::Stream
export::futures::prelude::stream::StreamExt
export::futures::prelude::stream::TryStream
export::futures::prelude::stream::TryStreamExt
export::futures::task::ArcWake
export::futures::task::LocalSpawn
export::futures::task::LocalSpawnExt
export::futures::task::Spawn
export::futures::task::SpawnExt
export::futures::task::UnsafeFutureObj
export::time::ext::InstantExt
export::time::ext::NumericalDuration
export::time::ext::NumericalStdDuration
export::time::formatting::Formattable
export::time::parsing::Parsable
export::url::form_urlencoded::Target

Macros

export::futures::join
export::futures::pending
export::futures::pin_mut
export::futures::poll
export::futures::ready
export::futures::select
export::futures::select_biased
export::futures::stream_select
export::futures::try_join
export::time::macros::date
export::time::macros::datetime
export::time::macros::format_description
export::time::macros::offset
export::time::macros::time

Functions

export::futures::channel::mpsc::channel
export::futures::channel::mpsc::unbounded
export::futures::channel::oneshot::channel
export::futures::io::copy
export::futures::io::copy_buf
export::futures::io::copy_buf_abortable
export::futures::io::empty
export::futures::io::repeat
export::futures::io::sink
export::futures::prelude::future::abortable
export::futures::prelude::future::err
export::futures::prelude::future::join
export::futures::prelude::future::join3
export::futures::prelude::future::join4
export::futures::prelude::future::join5
export::futures::prelude::future::join_all
export::futures::prelude::future::lazy
export::futures::prelude::future::maybe_done
export::futures::prelude::future::ok
export::futures::prelude::future::pending
export::futures::prelude::future::poll_fn
export::futures::prelude::future::poll_immediate
export::futures::prelude::future::ready
export::futures::prelude::future::select
export::futures::prelude::future::select_all
export::futures::prelude::future::select_ok
export::futures::prelude::future::try_join
export::futures::prelude::future::try_join3
export::futures::prelude::future::try_join4
export::futures::prelude::future::try_join5
export::futures::prelude::future::try_join_all
export::futures::prelude::future::try_maybe_done
export::futures::prelude::future::try_select
export::futures::prelude::sink::drain
export::futures::prelude::sink::unfold
export::futures::prelude::stream::abortable
export::futures::prelude::stream::empty
export::futures::prelude::stream::iter
export::futures::prelude::stream::once
export::futures::prelude::stream::pending
export::futures::prelude::stream::poll_fn
export::futures::prelude::stream::poll_immediate
export::futures::prelude::stream::repeat
export::futures::prelude::stream::repeat_with
export::futures::prelude::stream::select
export::futures::prelude::stream::select_all
export::futures::prelude::stream::select_all::select_all
export::futures::prelude::stream::select_with_strategy
export::futures::prelude::stream::try_unfold
export::futures::prelude::stream::unfold
export::futures::task::noop_waker
export::futures::task::noop_waker_ref
export::futures::task::waker
export::futures::task::waker_ref
export::time::format_description::parse
export::time::format_description::parse_borrowed
export::time::format_description::parse_owned
export::time::util::days_in_year
export::time::util::days_in_year_month
export::time::util::is_leap_year
export::time::util::weeks_in_year
export::url::form_urlencoded::byte_serialize
export::url::form_urlencoded::parse
is_valid_stream_key
is_valid_stream_key_char
runtime_error

Type Aliases

Error
Receipt
SeqNo
StreamResult
export::futures::io::Result
export::futures::never::Never
export::futures::prelude::future::BoxFuture
export::futures::prelude::future::LocalBoxFuture
export::futures::prelude::stream::BoxStream
export::futures::prelude::stream::FlattenUnordered
export::futures::prelude::stream::LocalBoxStream
export::time::Result
export::time::format_description::well_known::iso8601::EncodedConfig
export::url::EncodingOverride
export::url::form_urlencoded::EncodingOverride

Constants

MAX_STREAM_KEY_LEN
SEA_STREAMER_INTERNAL
TIMESTAMP_FORMAT