Struct OCPP2_0_1Client 

pub struct OCPP2_0_1Client { /* private fields */ }

OCPP 2.0.1 client

Implementations

impl OCPP2_0_1Client

pub async fn disconnect(&self) -> Result<(), Box<dyn Error + Send + Sync>>

Disconnect from the server

pub async fn send_authorize( &self, request: AuthorizeRequest, ) -> Result<Result<AuthorizeResponse, OCPP2_0_1Error>, Box<dyn Error + Send + Sync>>

pub async fn send_boot_notification( &self, request: BootNotificationRequest, ) -> Result<Result<BootNotificationResponse, OCPP2_0_1Error>, Box<dyn Error + Send + Sync>>

pub async fn send_cleared_charging_limit_request( &self, request: ClearedChargingLimitRequest, ) -> Result<Result<ClearedChargingLimitResponse, OCPP2_0_1Error>, Box<dyn Error + Send + Sync>>

pub async fn send_data_transfer( &self, request: DataTransferRequest, ) -> Result<Result<DataTransferResponse, OCPP2_0_1Error>, Box<dyn Error + Send + Sync>>

pub async fn send_firmware_status_notification( &self, request: FirmwareStatusNotificationRequest, ) -> Result<Result<FirmwareStatusNotificationResponse, OCPP2_0_1Error>, Box<dyn Error + Send + Sync>>

pub async fn send_get_15118_ev_certificate( &self, request: Get15118EVCertificateRequest, ) -> Result<Result<Get15118EVCertificateResponse, OCPP2_0_1Error>, Box<dyn Error + Send + Sync>>

pub async fn send_get_certificate_status( &self, request: GetCertificateStatusRequest, ) -> Result<Result<GetCertificateStatusResponse, OCPP2_0_1Error>, Box<dyn Error + Send + Sync>>

pub async fn send_heartbeat( &self, request: HeartbeatRequest, ) -> Result<Result<HeartbeatResponse, OCPP2_0_1Error>, Box<dyn Error + Send + Sync>>

pub async fn send_log_status_notification( &self, request: LogStatusNotificationRequest, ) -> Result<Result<LogStatusNotificationResponse, OCPP2_0_1Error>, Box<dyn Error + Send + Sync>>

pub async fn send_meter_values( &self, request: MeterValuesRequest, ) -> Result<Result<MeterValuesResponse, OCPP2_0_1Error>, Box<dyn Error + Send + Sync>>

pub async fn send_notify_charging_limit( &self, request: NotifyChargingLimitRequest, ) -> Result<Result<NotifyChargingLimitResponse, OCPP2_0_1Error>, Box<dyn Error + Send + Sync>>

pub async fn send_notify_customer_information( &self, request: NotifyCustomerInformationRequest, ) -> Result<Result<NotifyCustomerInformationResponse, OCPP2_0_1Error>, Box<dyn Error + Send + Sync>>

pub async fn send_notify_display_messages( &self, request: NotifyDisplayMessagesRequest, ) -> Result<Result<NotifyDisplayMessagesResponse, OCPP2_0_1Error>, Box<dyn Error + Send + Sync>>

pub async fn send_notify_ev_charging_needs( &self, request: NotifyEVChargingNeedsRequest, ) -> Result<Result<NotifyEVChargingNeedsResponse, OCPP2_0_1Error>, Box<dyn Error + Send + Sync>>

pub async fn send_notify_ev_charging_schedule( &self, request: NotifyEVChargingScheduleRequest, ) -> Result<Result<NotifyEVChargingScheduleResponse, OCPP2_0_1Error>, Box<dyn Error + Send + Sync>>

pub async fn send_notify_event( &self, request: NotifyEventRequest, ) -> Result<Result<NotifyEventResponse, OCPP2_0_1Error>, Box<dyn Error + Send + Sync>>

pub async fn send_notify_monitoring_report( &self, request: NotifyMonitoringReportRequest, ) -> Result<Result<NotifyMonitoringReportResponse, OCPP2_0_1Error>, Box<dyn Error + Send + Sync>>

pub async fn send_notify_report( &self, request: NotifyReportRequest, ) -> Result<Result<NotifyReportResponse, OCPP2_0_1Error>, Box<dyn Error + Send + Sync>>

pub async fn send_publish_firmware_status_notification( &self, request: PublishFirmwareStatusNotificationRequest, ) -> Result<Result<PublishFirmwareStatusNotificationResponse, OCPP2_0_1Error>, Box<dyn Error + Send + Sync>>

pub async fn send_report_charging_profiles( &self, request: ReportChargingProfilesRequest, ) -> Result<Result<ReportChargingProfilesResponse, OCPP2_0_1Error>, Box<dyn Error + Send + Sync>>

pub async fn send_request_start_transaction( &self, request: RequestStartTransactionRequest, ) -> Result<Result<RequestStartTransactionResponse, OCPP2_0_1Error>, Box<dyn Error + Send + Sync>>

pub async fn send_request_stop_transaction( &self, request: RequestStopTransactionRequest, ) -> Result<Result<RequestStopTransactionResponse, OCPP2_0_1Error>, Box<dyn Error + Send + Sync>>

pub async fn send_reservation_status_update( &self, request: ReservationStatusUpdateRequest, ) -> Result<Result<ReservationStatusUpdateResponse, OCPP2_0_1Error>, Box<dyn Error + Send + Sync>>

pub async fn send_sign_certificate( &self, request: SignCertificateRequest, ) -> Result<Result<SignCertificateResponse, OCPP2_0_1Error>, Box<dyn Error + Send + Sync>>

pub async fn send_status_notification( &self, request: StatusNotificationRequest, ) -> Result<Result<StatusNotificationResponse, OCPP2_0_1Error>, Box<dyn Error + Send + Sync>>

pub async fn send_transaction_event( &self, request: TransactionEventRequest, ) -> Result<Result<TransactionEventResponse, OCPP2_0_1Error>, Box<dyn Error + Send + Sync>>

pub async fn send_ping(&self) -> Result<(), Box<dyn Error + Send + Sync>>

pub async fn on_cancel_reservation<F: FnMut(CancelReservationRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<CancelReservationResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_certificate_signed<F: FnMut(CertificateSignedRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<CertificateSignedResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_change_availability<F: FnMut(ChangeAvailabilityRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<ChangeAvailabilityResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_clear_cache<F: FnMut(ClearCacheRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<ClearCacheResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_clear_charging_profile<F: FnMut(ClearChargingProfileRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<ClearChargingProfileResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_clear_display_message<F: FnMut(ClearDisplayMessageRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<ClearDisplayMessageResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_clear_variable_monitoring<F: FnMut(ClearVariableMonitoringRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<ClearVariableMonitoringResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_cost_updated<F: FnMut(CostUpdatedRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<CostUpdatedResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_customer_information<F: FnMut(CustomerInformationRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<CustomerInformationResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_data_transfer<F: FnMut(DataTransferRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<DataTransferResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_delete_certificate<F: FnMut(DeleteCertificateRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<DeleteCertificateResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_get_base_report<F: FnMut(GetBaseReportRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<GetBaseReportResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_get_charging_profiles<F: FnMut(GetChargingProfilesRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<GetChargingProfilesResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_get_composite_schedule<F: FnMut(GetCompositeScheduleRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<GetCompositeScheduleResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_get_display_messages<F: FnMut(GetDisplayMessagesRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<GetDisplayMessagesResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_get_installed_certificate_ids<F: FnMut(GetInstalledCertificateIdsRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<GetInstalledCertificateIdsResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_get_local_list_version<F: FnMut(GetLocalListVersionRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<GetLocalListVersionResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_get_log<F: FnMut(GetLogRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<GetLogResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_get_monitoring_report<F: FnMut(GetMonitoringReportRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<GetMonitoringReportResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_get_report<F: FnMut(GetReportRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<GetReportResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_get_transaction_status<F: FnMut(GetTransactionStatusRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<GetTransactionStatusResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_get_variables<F: FnMut(GetVariablesRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<GetVariablesResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_install_certificate<F: FnMut(InstallCertificateRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<InstallCertificateResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_publish_firmware<F: FnMut(PublishFirmwareRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<PublishFirmwareResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_reserve_now<F: FnMut(ReserveNowRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<ReserveNowResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_reset<F: FnMut(ResetRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<ResetResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_send_local_list<F: FnMut(SendLocalListRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<SendLocalListResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_set_charging_profile<F: FnMut(SetChargingProfileRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<SetChargingProfileResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_set_display_message<F: FnMut(SetDisplayMessageRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<SetDisplayMessageResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_set_monitoring_base<F: FnMut(SetMonitoringBaseRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<SetMonitoringBaseResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_set_monitoring_level<F: FnMut(SetMonitoringLevelRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<SetMonitoringLevelResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_set_network_profile<F: FnMut(SetNetworkProfileRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<SetNetworkProfileResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_set_variable_monitoring<F: FnMut(SetVariableMonitoringRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<SetVariableMonitoringResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_set_variables<F: FnMut(SetVariablesRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<SetVariablesResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_trigger_message<F: FnMut(TriggerMessageRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<TriggerMessageResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_unlock_connector<F: FnMut(UnlockConnectorRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<UnlockConnectorResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_unpublish_firmware<F: FnMut(UnpublishFirmwareRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<UnpublishFirmwareResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_update_firmware<F: FnMut(UpdateFirmwareRequest, Self) -> FF + Send + Sync + 'static, FF: Future<Output = Result<UpdateFirmwareResponse, OCPP2_0_1Error>> + Send + Sync>( &self, callback: F, )

pub async fn on_ping<F: FnMut(Self) -> FF + Send + Sync + 'static, FF: Future<Output = ()> + Send + Sync>( &self, callback: F, )

Trait Implementations

impl Clone for OCPP2_0_1Client

fn clone(&self) -> OCPP2_0_1Client

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.