Struct RepositoryContent

pub struct RepositoryContent { /* private fields */ }

This type manages the content of the repository. Note that access to the repository is managed by an event sourced component which handles RFC8181 based access, and which can enforce restrictions, such as the base uri for publishers.

Implementations

impl RepositoryContent

Construct

pub fn new(rrdp: RrdpServer, rsync: RsyncdStore) -> Self

pub fn init( rrdp_base_uri: Https, rsync_jail: Rsync, session: RrdpSession, repo_base_dir: &Path, ) -> Self

impl RepositoryContent

Publisher Content

pub fn clear(&self)

pub fn list_reply(&self, publisher: &PublisherHandle) -> KrillResult<ListReply>

Gets a list reply containing all objects for this publisher.

pub fn reset_session(&self) -> KrillResult<Vec<RepositoryContentChange>>

pub fn write_repository(&self, config: RrdpUpdatesConfig) -> KrillResult<()>

pub fn stats(&self) -> RepoStats

Returns the content stats for the repo

pub fn publisher_stats(&self) -> HashMap<PublisherHandle, PublisherStats>

Returns the stats for all current publishers

Trait Implementations

impl Clone for RepositoryContent

fn clone(&self) -> RepositoryContent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RepositoryContent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RepositoryContent

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for RepositoryContent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl TryFrom<OldRepositoryContent> for RepositoryContent

type Error = Error

The type returned in the event of a conversion error.

fn try_from(old: OldRepositoryContent) -> Result<Self, Error>

Performs the conversion.

impl WalSupport for RepositoryContent

Write-ahead logging support

type Command = RepositoryContentCommand

type Change = RepositoryContentChange

type Error = Error

fn revision(&self) -> u64

Returns the current version.

fn apply(&mut self, set: WalSet<Self>)

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::Change>, 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 events here.