Struct Cpo 

pub struct Cpo<DB, CH>
where
    DB: Store,
{ /* private fields */ }

Cpo implements the CPO role of the OCPI Protocol.

Every module supplies an implementation of it self on this type.

Implementations

impl<DB> Cpo<DB, NoCommandsHandler>

where DB: Store,

pub fn new(db: DB, client: Client) -> Self

Creates a new Cpo instance. the base_url must be the url to the base ocpi endpoint. NOT the versions module. This base url will be used to add on each module url. so versions will be appended and the versions module should be served from that path.

impl<DB> Cpo<DB, NoCommandsHandler>

where DB: Store,

pub fn with_mpsc_commands_handler( self, tx: Sender<CommandRequest<DB::PartyModel>>, ) -> Cpo<DB, MpscCommandsHandler<DB::PartyModel>>

Trait Implementations

impl<DB, CH: Clone> Clone for Cpo<DB, CH>

where DB: Store + Clone,

fn clone(&self) -> Cpo<DB, CH>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<DB> CommandsModule for Cpo<DB, MpscCommandsHandler<DB::PartyModel>>

where DB: Store,

fn handle_command<'life0, 'async_trait>( &'life0 self, context: Context, command: Command, ) -> Pin<Box<dyn Future<Output = Result<CommandResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn commands_post<'life0, 'async_trait>( &'life0 self, ctx: Context, command: CommandType, body: Value, ) -> Pin<Box<dyn Future<Output = Result<CommandResponse>> + Send + 'async_trait>>

where Self: Sync + 'async_trait, 'life0: 'async_trait,

impl<DB, CH, M, Rm> CredentialsModule for Cpo<DB, CH>

where M: Party + Send + 'static, Rm: Send + 'static, CH: CommandsHandler, DB: PartyStore<PartyModel = M, RegistrationModel = Rm> + VersionsStore + Sync,

fn credentials_post<'life0, 'async_trait>( &'life0 self, ctx: Context, param: Credential, ) -> Pin<Box<dyn Future<Output = Result<Credential>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Provides credentials for the Server to access the Clients system. This is done using the Temporary model. If this the authentication of the provided Credential is succesful

The provided Credentials will be used to create a new Model. The Credentials for this new Model is what is returned.

type PartyModel = M

type RegistrationModel = Rm

fn credentials_get<'life0, 'async_trait>( &'life0 self, ctx: Context, ) -> Pin<Box<dyn Future<Output = Result<Credential>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

7.2.1. GET Method

fn credentials_put<'life0, 'async_trait>( &'life0 self, ctx: Context, param: Credential, ) -> Pin<Box<dyn Future<Output = Result<Credential>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

7.2.3. PUT Method

fn credentials_delete<'life0, 'async_trait>( &'life0 self, ctx: Context, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

7.2.4. DELETE Method

impl<DB, CH> SessionsModule for Cpo<DB, CH>

where DB: SessionsStore, CH: CommandsHandler,

fn sessions_get<'life0, 'async_trait>( &'life0 self, ctx: Context, date_from: DateTime, date_to: Option<DateTime>, offset: Option<usize>, limit: Option<usize>, ) -> Pin<Box<dyn Future<Output = Result<Paginated<Session>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn sessions_put<'life0, 'async_trait>( &'life0 self, _ctx: Context, _session_id: CiString<36>, _charging_preferences: ChargingPreferences, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

impl<DB, CH> VersionsModule for Cpo<DB, CH>

where DB: Store + VersionsStore, CH: CommandsHandler,

fn versions_get<'life0, 'async_trait>( &'life0 self, ctx: Context, ) -> Pin<Box<dyn Future<Output = Result<Vec<Version>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

6.1. Version information endpoint

fn versions_get_details<'life0, 'async_trait>( &'life0 self, ctx: Context, version_number: VersionNumber, ) -> Pin<Box<dyn Future<Output = Result<Option<VersionDetails>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

6.2. Version details endpoint