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.