Documentation ¶
Index ¶
Constants ¶
View Source
const ( ErrCloseTimeout = Error("database close timeout") ErrDBClosed = Error("database already closed") )
View Source
const ( ErrNoEventsData = Error("no events data") EOS = Error("end of stream") )
View Source
const (
OurEpoch = 1455209242000 // OUR epoch starts from this millisecond since unix epoch
)
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Event ¶
type Event struct { ID uint64 `json:"id"` Stream string `json:"stream"` Type string `json:"type"` Body json.RawMessage `json:"body"` }
func (*Event) MarshalJSON ¶
func (*Event) MarshalJSONBuf ¶
func (mj *Event) MarshalJSONBuf(buf fflib.EncodingBuffer) error
func (*Event) UnmarshalJSON ¶
func (*Event) UnmarshalJSONFFLexer ¶
Source Files ¶
Click to show internal directories.
Click to hide internal directories.