transaction

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 31, 2017 License: Apache-2.0 Imports: 2 Imported by: 3

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)

type Write

type Write struct {
	Filename string
	Buffer   []byte
	Position int64
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL