struct LavinMQ::SegmentPosition

Included Modules

Defined in:

lavinmq/segment_position.cr

Constant Summary

BYTESIZE = 30

Constructors

Class Method Summary

Instance Method Summary

Constructor Detail

def self.new(segment : UInt32, position : UInt32, bytesize : UInt32 = 0_u32, timestamp : Int64 = 0_i64, ttl : Int64 = 0_u32, priority : UInt8 = 0_u8, flags : LavinMQ::SegmentPosition::SPFlags = SPFlags::None) #

[View source]

Class Method Detail

def self.from_i64(i : Int64) #

[View source]
def self.from_io(io : IO, format = IO::ByteFormat::SystemEndian) #

[View source]
def self.make(segment, position, msg) #

[View source]
def self.parse(s) #

[View source]
def self.zero #

[View source]

Instance Method Detail

def <=>(other : self) #

[View source]
def ==(other : self) #

def bytesize : UInt32 #

[View source]
def end_position #

[View source]
def expiration_ts : Int64 #

[View source]
def flags : SPFlags #

[View source]
def hash(hasher) #
Description copied from struct Struct

See Object#hash(hasher)


def position : UInt32 #

[View source]
def priority : UInt8 #

[View source]
def segment : UInt32 #

NOTE order is important here


[View source]
def timestamp : Int64 #

[View source]
def to_i64 #

[View source]
def to_io(io : IO, format) #

[View source]
def to_s(io : IO) #
Description copied from struct Struct

Same as #inspect(io).


[View source]
def ttl : Int64 #

[View source]
def ttl? : UInt32 | Nil #

[View source]
def zero? #

[View source]