[−][src]Module kekbit::core
Structs
Header | Defines and validates the metadata associated with a channel. |
ShmReader | An implementation of the Reader which access a persistent channel through
memory mapping. A |
ShmWriter | An implementation of the Writer which access a persistent channel through
memory mapping. A |
Enums
ChannelError | Channel Access errors |
InvalidPosition | Errors caused by failed move_to operation. |
ReadError | Read operation errors |
TickUnit | A TickUnit represents a specific time duration but does not maintain time information, it only helps define the time granularity required to used in various contexts by all kekbit components which share a given channel. For each channel it's TickUnit will be spcified at creation and will never be changed |
WriteError | Write operation errors |
Traits
Reader | The |
Writer | The |
Functions
shm_reader | Creates a kekbit reader associated to a memory mapped channel. |
shm_writer | Creates a file backed memory mapped kekbit channel and a writer associate with it. |
storage_path | Returns the path to the file associated with a channel inside a kekbit root folder. |
try_shm_reader | Tries multiple times to create a kekbit reader associated to a memory mapped channel.
This function will basically call shm_reader up to tries time unless
it succeeds. Between two tries the function will spin/sleep for a about |