list.rs - source

Files

anyhow

backtrace.rs chain.rs context.rs error.rs fmt.rs kind.rs lib.rs macros.rs ptr.rs wrapper.rs

async_stream

async_stream.rs lib.rs next.rs yielder.rs

async_stream_impl

async_trait

args.rs expand.rs lib.rs lifetime.rs parse.rs receiver.rs

base64

write

encoder.rs mod.rs

chunked_encoder.rs decode.rs display.rs encode.rs lib.rs tables.rs

bytes

buf

buf_impl.rs buf_mut.rs chain.rs iter.rs limit.rs mod.rs reader.rs take.rs uninit_slice.rs vec_deque.rs writer.rs

fmt

debug.rs hex.rs mod.rs

bytes.rs bytes_mut.rs lib.rs loom.rs

cfg_if

either

fnv

futures_channel

mpsc

mod.rs queue.rs

lib.rs lock.rs oneshot.rs

futures_core

task

__internal

atomic_waker.rs mod.rs

future.rs lib.rs stream.rs

futures_sink

futures_task

arc_wake.rs future_obj.rs lib.rs noop_waker.rs spawn.rs waker.rs waker_ref.rs

futures_util

future

lock

stream

task

mod.rs spawn.rs

abortable.rs fns.rs lib.rs never.rs unfold_state.rs

gapi_grpc

getrandom

error.rs error_impls.rs lib.rs linux_android.rs use_file.rs util.rs util_libc.rs

h2

hashbrown

external_trait_impls

raw

bitmask.rs mod.rs sse2.rs

lib.rs macros.rs map.rs scopeguard.rs set.rs

http

header

map.rs mod.rs name.rs value.rs

uri

authority.rs builder.rs mod.rs path.rs port.rs scheme.rs

byte_str.rs convert.rs error.rs extensions.rs lib.rs method.rs request.rs response.rs status.rs version.rs

http_body

lib.rs next.rs size_hint.rs

httparse

simd

avx2.rs mod.rs sse42.rs

iter.rs lib.rs macros.rs

httpdate

httpdate.rs lib.rs

hyper

body

aggregate.rs body.rs mod.rs to_bytes.rs

client

connect

dns.rs http.rs mod.rs

conn.rs dispatch.rs mod.rs pool.rs service.rs

common

io

mod.rs rewind.rs

buf.rs drain.rs exec.rs lazy.rs mod.rs never.rs sync_wrapper.rs task.rs watch.rs

proto

h1

conn.rs date.rs decode.rs dispatch.rs encode.rs io.rs mod.rs role.rs

h2

client.rs mod.rs ping.rs server.rs

server

accept.rs conn.rs mod.rs shutdown.rs tcp.rs

service

http.rs make.rs mod.rs oneshot.rs util.rs

error.rs headers.rs lib.rs rt.rs upgrade.rs

indexmap

map

core

equivalent.rs lib.rs macros.rs map.rs mutable_keys.rs set.rs util.rs

iovec

sys

itertools

itoa

lazy_static

inline_lazy.rs lib.rs

libc

unix

linux_like

linux

arch

generic

gnu

b64

x86_64

align.rs mod.rs not_x32.rs

align.rs mod.rs

align.rs mod.rs

align.rs mod.rs

fixed_width_ints.rs lib.rs macros.rs

log

lib.rs macros.rs

memchr

memchr

x86

avx.rs mod.rs sse2.rs

fallback.rs iter.rs mod.rs naive.rs

memmem

prefilter

x86

avx.rs mod.rs sse.rs

fallback.rs genericsimd.rs mod.rs

x86

avx.rs mod.rs sse.rs

byte_frequencies.rs genericsimd.rs mod.rs rabinkarp.rs rarebytes.rs twoway.rs util.rs vector.rs

mio

net2

sys

unix

impls.rs mod.rs

ext.rs lib.rs socket.rs tcp.rs udp.rs unix.rs utils.rs

once_cell

imp_std.rs lib.rs race.rs

openssl_probe

percent_encoding

pin_project

pin_project_lite

pin_utils

lib.rs projection.rs stack_pin.rs

ppv_lite86

x86_64

lib.rs soft.rs types.rs

proc_macro2

detection.rs fallback.rs lib.rs marker.rs parse.rs wrapper.rs

prost

encoding.rs error.rs lib.rs message.rs types.rs

prost_derive

field

group.rs map.rs message.rs mod.rs oneof.rs scalar.rs

prost_types

compiler.rs lib.rs protobuf.rs

quote

ext.rs format.rs ident_fragment.rs lib.rs runtime.rs spanned.rs to_tokens.rs

rand

rand_chacha

chacha.rs guts.rs lib.rs

rand_core

block.rs error.rs impls.rs le.rs lib.rs os.rs

rand_pcg

lib.rs pcg128.rs pcg64.rs

ring

rustls

rustls_native_certs

sct

slab

socket2

sys

lib.rs sockaddr.rs socket.rs utils.rs

spin

lib.rs mutex.rs once.rs rw_lock.rs

syn

tokio

future

maybe_done.rs mod.rs poll_fn.rs ready.rs try_join.rs

io

loom

std

atomic_ptr.rs atomic_u16.rs atomic_u32.rs atomic_u64.rs atomic_u8.rs atomic_usize.rs mod.rs unsafe_cell.rs

macros

cfg.rs loom.rs mod.rs pin.rs ready.rs scoped_tls.rs support.rs thread_local.rs

net

tcp

incoming.rs listener.rs mod.rs split.rs split_owned.rs stream.rs

park

either.rs mod.rs thread.rs

runtime

stream

all.rs any.rs chain.rs collect.rs empty.rs filter.rs filter_map.rs fold.rs fuse.rs iter.rs map.rs merge.rs mod.rs next.rs once.rs pending.rs skip.rs skip_while.rs stream_map.rs take.rs take_while.rs timeout.rs try_next.rs

sync

task

blocking.rs mod.rs spawn.rs yield_now.rs

time

driver

atomic_stack.rs entry.rs handle.rs mod.rs registration.rs stack.rs

wheel

level.rs mod.rs stack.rs

clock.rs delay.rs delay_queue.rs error.rs instant.rs interval.rs mod.rs throttle.rs timeout.rs

util

slab

addr.rs entry.rs generation.rs mod.rs page.rs shard.rs slot.rs stack.rs

bit.rs intrusive_double_linked_list.rs linked_list.rs mod.rs rand.rs trace.rs wake.rs

coop.rs lib.rs prelude.rs

tokio_rustls

common

handshake.rs mod.rs

client.rs lib.rs server.rs

tokio_util

codec

bytes_codec.rs decoder.rs encoder.rs framed.rs framed_read.rs framed_write.rs length_delimited.rs lines_codec.rs mod.rs

tonic

client

grpc.rs mod.rs service.rs

codec

buffer.rs decode.rs encode.rs mod.rs prost.rs

metadata

encoding.rs key.rs map.rs mod.rs value.rs

server

grpc.rs mod.rs service.rs

transport

channel

endpoint.rs mod.rs tls.rs

server

conn.rs incoming.rs mod.rs tls.rs

service

add_origin.rs connection.rs connector.rs discover.rs io.rs layer.rs mod.rs reconnect.rs router.rs tls.rs

error.rs mod.rs tls.rs

body.rs codegen.rs interceptor.rs lib.rs macros.rs request.rs response.rs status.rs

tower

builder

tower_balance

p2c

layer.rs make.rs mod.rs service.rs

pool

error.rs lib.rs

tower_buffer

error.rs future.rs layer.rs lib.rs message.rs service.rs worker.rs

tower_discover

error.rs lib.rs list.rs stream.rs

tower_layer

identity.rs layer_fn.rs lib.rs stack.rs

tower_limit

concurrency

sync

cell.rs mod.rs semaphore.rs waker.rs

future.rs layer.rs mod.rs service.rs

rate

layer.rs mod.rs rate.rs service.rs

tower_load

constant.rs instrument.rs lib.rs peak_ewma.rs pending_requests.rs

tower_load_shed

error.rs future.rs layer.rs lib.rs

tower_make

lib.rs make_connection.rs make_service.rs

tower_ready_cache

cache.rs error.rs lib.rs

tower_retry

budget.rs future.rs layer.rs lib.rs policy.rs

tower_service

tower_timeout

error.rs future.rs layer.rs lib.rs

tower_util

boxed

mod.rs sync.rs unsync.rs

call_all

common.rs mod.rs ordered.rs unordered.rs

optional

error.rs future.rs mod.rs

either.rs lib.rs oneshot.rs ready.rs service_fn.rs

tracing

dispatcher.rs field.rs instrument.rs level_filters.rs lib.rs macros.rs span.rs stdlib.rs subscriber.rs

tracing_attributes

tracing_core

callsite.rs dispatcher.rs event.rs field.rs lib.rs metadata.rs parent.rs span.rs stdlib.rs subscriber.rs

tracing_futures

executor

lib.rs stdlib.rs

try_lock

unicode_xid

lib.rs tables.rs

untrusted

want

webpki

calendar.rs cert.rs der.rs error.rs name.rs signed_data.rs time.rs trust_anchor_util.rs verify_cert.rs webpki.rs

use crate::{error::Never, Change, Discover};
use pin_project::pin_project;
use std::iter::{Enumerate, IntoIterator};
use std::{
    pin::Pin,
    task::{Context, Poll},
};
use tower_service::Service;

/// Static service discovery based on a predetermined list of services.
///
/// `ServiceList` is created with an initial list of services. The discovery
/// process will yield this list once and do nothing after.
#[pin_project]
#[derive(Debug)]
pub struct ServiceList<T>
where
    T: IntoIterator,
{
    inner: Enumerate<T::IntoIter>,
}

impl<T, U> ServiceList<T>
where
    T: IntoIterator<Item = U>,
{
    #[allow(missing_docs)]
    pub fn new<Request>(services: T) -> ServiceList<T>
    where
        U: Service<Request>,
    {
        ServiceList {
            inner: services.into_iter().enumerate(),
        }
    }
}

impl<T, U> Discover for ServiceList<T>
where
    T: IntoIterator<Item = U>,
{
    type Key = usize;
    type Service = U;
    type Error = Never;

    fn poll_discover(
        self: Pin<&mut Self>,
        _: &mut Context<'_>,
    ) -> Poll<Result<Change<Self::Key, Self::Service>, Self::Error>> {
        match self.project().inner.next() {
            Some((i, service)) => Poll::Ready(Ok(Change::Insert(i, service))),
            None => Poll::Pending,
        }
    }
}

// check that List can be directly over collections
#[cfg(test)]
#[allow(dead_code)]
type ListVecTest<T> = ServiceList<Vec<T>>;

#[cfg(test)]
#[allow(dead_code)]
type ListVecIterTest<T> = ServiceList<::std::vec::IntoIter<T>>;