Struct gapi_grpc::google::cloud::aiplatform::v1beta1::ModelDeploymentMonitoringJob [−][src]
Represents a job that runs periodically to monitor the deployed models in an endpoint. It will analyze the logged training & prediction data to detect any abnormal behaviors.
Fields
name: String
Output only. Resource name of a ModelDeploymentMonitoringJob.
display_name: String
Required. The user-defined name of the ModelDeploymentMonitoringJob. The name can be up to 128 characters long and can be consist of any UTF-8 characters. Display name of a ModelDeploymentMonitoringJob.
endpoint: String
Required. Endpoint resource name.
Format: projects/{project}/locations/{location}/endpoints/{endpoint}
state: i32
Output only. The detailed state of the monitoring job. When the job is still creating, the state will be ‘PENDING’. Once the job is successfully created, the state will be ‘RUNNING’. Pause the job, the state will be ‘PAUSED’. Resume the job, the state will return to ‘RUNNING’.
schedule_state: i32
Output only. Schedule state when the monitoring job is in Running state.
model_deployment_monitoring_objective_configs: Vec<ModelDeploymentMonitoringObjectiveConfig>
Required. The config for monitoring objectives. This is a per DeployedModel config. Each DeployedModel needs to be configed separately.
model_deployment_monitoring_schedule_config: Option<ModelDeploymentMonitoringScheduleConfig>
Required. Schedule config for running the monitoring job.
logging_sampling_strategy: Option<SamplingStrategy>
Required. Sample Strategy for logging.
model_monitoring_alert_config: Option<ModelMonitoringAlertConfig>
Alert config for model monitoring.
predict_instance_schema_uri: String
YAML schema file uri describing the format of a single instance, which are given to format this Endpoint’s prediction (and explanation). If not set, we will generate predict schema from collected predict requests.
sample_predict_instance: Option<Value>
Sample Predict instance, same format as [PredictRequest.instances][google.cloud.aiplatform.v1beta1.PredictRequest.instances], this can be set as a replacement of [ModelDeploymentMonitoringJob.predict_instance_schema_uri][google.cloud.aiplatform.v1beta1.ModelDeploymentMonitoringJob.predict_instance_schema_uri]. If not set, we will generate predict schema from collected predict requests.
analysis_instance_schema_uri: String
YAML schema file uri describing the format of a single instance that you want Tensorflow Data Validation (TFDV) to analyze.
If this field is empty, all the feature data types are inferred from [predict_instance_schema_uri][google.cloud.aiplatform.v1beta1.ModelDeploymentMonitoringJob.predict_instance_schema_uri], meaning that TFDV will use the data in the exact format(data type) as prediction request/response. If there are any data type differences between predict instance and TFDV instance, this field can be used to override the schema. For models trained with Vertex AI, this field must be set as all the fields in predict instance formatted as string.
bigquery_tables: Vec<ModelDeploymentMonitoringBigQueryTable>
Output only. The created bigquery tables for the job under customer project. Customer could do their own query & analysis. There could be 4 log tables in maximum:
- Training data logging predict request/response
- Serving data logging predict request/response
log_ttl: Option<Duration>
The TTL of BigQuery tables in user projects which stores logs. A day is the basic unit of the TTL and we take the ceil of TTL/86400(a day). e.g. { second: 3600} indicates ttl = 1 day.
labels: HashMap<String, String>
The labels with user-defined metadata to organize your ModelDeploymentMonitoringJob.
Label keys and values can be no longer than 64 characters (Unicode codepoints), can only contain lowercase letters, numeric characters, underscores and dashes. International characters are allowed.
See https://goo.gl/xmQnxf for more information and examples of labels.
create_time: Option<Timestamp>
Output only. Timestamp when this ModelDeploymentMonitoringJob was created.
update_time: Option<Timestamp>
Output only. Timestamp when this ModelDeploymentMonitoringJob was updated most recently.
next_schedule_time: Option<Timestamp>
Output only. Timestamp when this monitoring pipeline will be scheduled to run for the next round.
stats_anomalies_base_directory: Option<GcsDestination>
Stats anomalies base folder path.
Implementations
impl ModelDeploymentMonitoringJob
[src]
pub fn state(&self) -> JobState
[src]
Returns the enum value of state
, or the default if the field is set to an invalid enum value.
pub fn set_state(&mut self, value: JobState)
[src]
Sets state
to the provided enum value.
pub fn schedule_state(&self) -> MonitoringScheduleState
[src]
Returns the enum value of schedule_state
, or the default if the field is set to an invalid enum value.
pub fn set_schedule_state(&mut self, value: MonitoringScheduleState)
[src]
Sets schedule_state
to the provided enum value.
Trait Implementations
impl Clone for ModelDeploymentMonitoringJob
[src]
fn clone(&self) -> ModelDeploymentMonitoringJob
[src]
pub fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Debug for ModelDeploymentMonitoringJob
[src]
impl Default for ModelDeploymentMonitoringJob
[src]
impl Message for ModelDeploymentMonitoringJob
[src]
fn encode_raw<B>(&self, buf: &mut B) where
B: BufMut,
[src]
B: BufMut,
fn merge_field<B>(
&mut self,
tag: u32,
wire_type: WireType,
buf: &mut B,
ctx: DecodeContext
) -> Result<(), DecodeError> where
B: Buf,
[src]
&mut self,
tag: u32,
wire_type: WireType,
buf: &mut B,
ctx: DecodeContext
) -> Result<(), DecodeError> where
B: Buf,
fn encoded_len(&self) -> usize
[src]
fn clear(&mut self)
[src]
pub fn encode<B>(&self, buf: &mut B) -> Result<(), EncodeError> where
B: BufMut,
[src]
B: BufMut,
pub fn encode_length_delimited<B>(&self, buf: &mut B) -> Result<(), EncodeError> where
B: BufMut,
[src]
B: BufMut,
pub fn decode<B>(buf: B) -> Result<Self, DecodeError> where
Self: Default,
B: Buf,
[src]
Self: Default,
B: Buf,
pub fn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError> where
Self: Default,
B: Buf,
[src]
Self: Default,
B: Buf,
pub fn merge<B>(&mut self, buf: B) -> Result<(), DecodeError> where
B: Buf,
[src]
B: Buf,
pub fn merge_length_delimited<B>(&mut self, buf: B) -> Result<(), DecodeError> where
B: Buf,
[src]
B: Buf,
impl PartialEq<ModelDeploymentMonitoringJob> for ModelDeploymentMonitoringJob
[src]
fn eq(&self, other: &ModelDeploymentMonitoringJob) -> bool
[src]
fn ne(&self, other: &ModelDeploymentMonitoringJob) -> bool
[src]
impl StructuralPartialEq for ModelDeploymentMonitoringJob
[src]
Auto Trait Implementations
impl RefUnwindSafe for ModelDeploymentMonitoringJob
impl Send for ModelDeploymentMonitoringJob
impl Sync for ModelDeploymentMonitoringJob
impl Unpin for ModelDeploymentMonitoringJob
impl UnwindSafe for ModelDeploymentMonitoringJob
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T> Instrument for T
[src]
pub fn instrument(self, span: Span) -> Instrumented<Self>
[src]
pub fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T> Instrument for T
[src]
pub fn instrument(self, span: Span) -> Instrumented<Self>
[src]
pub fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> IntoRequest<T> for T
[src]
pub fn into_request(self) -> Request<T>
[src]
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
pub fn to_owned(&self) -> T
[src]
pub fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
[src]
V: MultiLane<T>,
impl<T> WithSubscriber for T
[src]
pub fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
[src]
S: Into<Dispatch>,