pub struct GitHubSource { /* private fields */ }Implementations§
Source§impl GitHubSource
impl GitHubSource
pub fn new(config: GitHubSourceConfig) -> Result<Self, SourceError>
Trait Implementations§
Source§impl Source for GitHubSource
impl Source for GitHubSource
Source§fn poll<'life0, 'life1, 'async_trait>(
&'life0 self,
state: &'life1 dyn StateStore,
) -> Pin<Box<dyn Future<Output = Result<Vec<Event>, SourceError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn poll<'life0, 'life1, 'async_trait>(
&'life0 self,
state: &'life1 dyn StateStore,
) -> Pin<Box<dyn Future<Output = Result<Vec<Event>, SourceError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Poll the provider and return newly-derived events (unordered).
Source§fn commit<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
_state: &'life1 dyn StateStore,
_event: &'life2 Event,
) -> Pin<Box<dyn Future<Output = Result<(), SourceError>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
Self: 'async_trait,
fn commit<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
_state: &'life1 dyn StateStore,
_event: &'life2 Event,
) -> Pin<Box<dyn Future<Output = Result<(), SourceError>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
Self: 'async_trait,
Optional hook invoked once an event has been delivered successfully, letting
the source advance provider-side state (e.g. mark a notification thread read).
Default: no-op.
Auto Trait Implementations§
impl !Freeze for GitHubSource
impl !RefUnwindSafe for GitHubSource
impl !UnwindSafe for GitHubSource
impl Send for GitHubSource
impl Sync for GitHubSource
impl Unpin for GitHubSource
impl UnsafeUnpin for GitHubSource
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more