Struct krill::pubd::Repository

pub struct Repository { /* fields omitted */ }

An RFC8183 Repository server, capable of handling Publishers (both embedded, and remote RFC8183), and publishing to RRDP and disk, and signing responses.

Implementations

impl Repository

pub fn key_id(&self) -> &KeyIdentifier

impl Repository

Manage publishers

pub fn repo_info_for(&self, publisher: &PublisherHandle) -> RepoInfo

pub fn repository_response(
    &self,
    rfc8181_uri: Https,
    publisher_handle: &PublisherHandle
) -> Result<RepositoryResponse, Error>

pub fn get_publisher(
    &self,
    publisher_handle: &PublisherHandle
) -> Result<&Publisher, Error>

pub fn stats(&self) -> &RepoStats

pub fn publishers(&self) -> Vec<PublisherHandle>

impl Repository

Publish

pub fn write(&self) -> Result<(), Error>

Update the RRPD and Rsync files on disk.

impl Repository

Miscellaneous

pub fn regenerate_stats(&mut self)

Trait Implementations

impl Aggregate for Repository

Event Sourcing support

type Command = Cmd

type StorableCommandDetails = StorableRepositoryCommand

type Event = Evt

type InitEvent = Ini

type Error = Error

fn init(event: Self::InitEvent) -> Result<Self, Self::Error>

Creates a new instance. Expects an event with data needed to initialise the instance. Typically this means that a specific 'create' event is passed, with all the needed data, or just an empty marker if no data is needed. Implementations must return an error in case the instance cannot be created.

fn version(&self) -> u64

Returns the current version of the aggregate.

fn apply(&mut self, event: Self::Event)

Applies the event to this. This MUST not result in any errors, and this MUST be side-effect free. Applying the event just updates the internal data of the aggregate.

fn process_command(
    &self,
    command: Self::Command
) -> Result<Vec<Self::Event>, Self::Error>

Processes a command. I.e. validate the command, and return a list of events that will result in the desired new state, but do not apply these event here.

fn apply_all(&mut self, events: Vec<Self::Event>)

Applies all events. Assumes that the list ordered, starting with the oldest event, applicable, self.version matches the oldest event, and contiguous, i.e. there are no missing events.

impl Clone for Repository

fn clone(&self) -> Repository

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Repository

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Repository

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl Serialize for Repository

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
    __S: Serializer, 

Serialize this value into the given Serde serializer.