pub struct JobEvent {
pub message: String,
pub job_id: String,
pub start_time: Option<Timestamp>,
pub end_time: Option<Timestamp>,
pub state: i32,
pub retries: i32,
pub type: i32,
pub service: i32,
pub service_job: String,
pub execution_trigger: i32,
}
Expand description
The payload associated with Job logs that contains events describing jobs that have run within a Lake.
Fields§
§message: String
The log message.
job_id: String
The unique id identifying the job.
start_time: Option<Timestamp>
The time when the job started running.
end_time: Option<Timestamp>
The time when the job ended running.
state: i32
The job state on completion.
retries: i32
The number of retries.
type: i32
The type of the job.
service: i32
The service used to execute the job.
service_job: String
The reference to the job within the service.
execution_trigger: i32
Job execution trigger.
Implementations§
source§impl JobEvent
impl JobEvent
sourcepub fn state(&self) -> State
pub fn state(&self) -> State
Returns the enum value of state
, or the default if the field is set to an invalid enum value.
sourcepub fn type(&self) -> Type
pub fn type(&self) -> Type
Returns the enum value of type
, or the default if the field is set to an invalid enum value.
sourcepub fn service(&self) -> Service
pub fn service(&self) -> Service
Returns the enum value of service
, or the default if the field is set to an invalid enum value.
sourcepub fn set_service(&mut self, value: Service)
pub fn set_service(&mut self, value: Service)
Sets service
to the provided enum value.
sourcepub fn execution_trigger(&self) -> ExecutionTrigger
pub fn execution_trigger(&self) -> ExecutionTrigger
Returns the enum value of execution_trigger
, or the default if the field is set to an invalid enum value.
sourcepub fn set_execution_trigger(&mut self, value: ExecutionTrigger)
pub fn set_execution_trigger(&mut self, value: ExecutionTrigger)
Sets execution_trigger
to the provided enum value.
Trait Implementations§
source§impl Message for JobEvent
impl Message for JobEvent
source§fn encoded_len(&self) -> usize
fn encoded_len(&self) -> usize
source§fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>where
Self: Sized,
fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>where
Self: Sized,
source§fn encode_to_vec(&self) -> Vec<u8>where
Self: Sized,
fn encode_to_vec(&self) -> Vec<u8>where
Self: Sized,
source§fn encode_length_delimited(
&self,
buf: &mut impl BufMut,
) -> Result<(), EncodeError>where
Self: Sized,
fn encode_length_delimited(
&self,
buf: &mut impl BufMut,
) -> Result<(), EncodeError>where
Self: Sized,
source§fn encode_length_delimited_to_vec(&self) -> Vec<u8>where
Self: Sized,
fn encode_length_delimited_to_vec(&self) -> Vec<u8>where
Self: Sized,
source§fn decode(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
fn decode(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
source§fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
source§fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
self
. Read moresource§fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
self
.source§impl PartialEq for JobEvent
impl PartialEq for JobEvent
impl StructuralPartialEq for JobEvent
Auto Trait Implementations§
impl Freeze for JobEvent
impl RefUnwindSafe for JobEvent
impl Send for JobEvent
impl Sync for JobEvent
impl Unpin for JobEvent
impl UnwindSafe for JobEvent
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
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T
in a tonic::Request