Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventstoreTransaction ¶
type EventstoreTransaction struct { BoltTx *bolt.Tx Bolt *bolt.DB NewChunks []*wtypes.ChunkSpec ShipFiles []*wtypes.LongTermShippableFile FilesToDisengageWalFor []string NeedsWALCompaction []string FilesToOpen []string FilesToClose []string WriteOps []*Write AffectedStreams map[string]string // streamName => cursorSerialized SubscriberNotifications []*wtypes.SubscriberNotification NonMetaLinesAdded int // only for metrics }
func NewEventstoreTransaction ¶
func NewEventstoreTransaction(bolt *bolt.DB) *EventstoreTransaction
func (*EventstoreTransaction) QueueWrite ¶
func (e *EventstoreTransaction) QueueWrite(filename string, buffer []byte, position int64)
Click to show internal directories.
Click to hide internal directories.