Documentation ¶
Index ¶
Constants ¶
const (
CaravanDebug = "CARAVAN_DEBUG"
)
Environment variables
const (
MsgInstantiationTrace = "stack at time of instantiation"
)
Error messages
Variables ¶
var (
Debug = &debugger{}
)
Functions ¶
Types ¶
type Closer ¶
Closer is an internal implementation of a closer.Closer
type ErrorWrapper ¶
ErrorWrapper is a function that wraps an error. It is returned by WrapStackTrace to attach stack information to a standard error
func WrapStackTrace ¶
func WrapStackTrace(msg string) ErrorWrapper
WrapStackTrace returns an ErrorWrapper that attaches Stack information to an error based on the call stack when this function is invoked
type Log ¶
type Log[Msg any] struct { // contains filtered or unexported fields }
Log manages a set of segments that contain Log entries
type Topic ¶
Topic is the internal implementation of a Topic
func (*Topic[Msg]) Get ¶
Get consumes a message starting at the specified virtual Offset within the Topic. If the Offset is no longer being retained, the next available Offset will be consumed. The actual Offset read is returned
func (*Topic[Msg]) NewConsumer ¶
NewConsumer instantiates a new Topic Consumer
func (*Topic[Msg]) NewProducer ¶
NewProducer instantiates a new Topic Producer