kvrows

type Iterator interface {
	Item(fn func(key, val []byte) error) error
	Close()
}

type KV interface {
	Iterate(minKey, maxKey []byte) (Iterator, error)
	Updater() (Updater, error)
}

type ProposalData struct {
	TXID    uint64            `protobuf:"varint,1,opt,name=TXID,proto3" json:"TXID,omitempty"`
	Updates []*ProposedUpdate `protobuf:"bytes,2,rep,name=Updates,proto3" json:"Updates,omitempty"`
	// contains filtered or unexported fields
}

type ProposedUpdate struct {
	SID   uint32 `protobuf:"varint,1,opt,name=SID,proto3" json:"SID,omitempty"` // Statement ID
	Value []byte `protobuf:"bytes,2,opt,name=Value,proto3" json:"Value,omitempty"`
	// contains filtered or unexported fields
}

type RowData struct {
	Proposal *ProposalData `protobuf:"bytes,1,opt,name=Proposal,proto3" json:"Proposal,omitempty"`
	Rows     []*RowValue   `protobuf:"bytes,2,rep,name=Rows,proto3" json:"Rows,omitempty"`
	// contains filtered or unexported fields
}

type RowValue struct {
	Version uint64 `protobuf:"varint,1,opt,name=Version,proto3" json:"Version,omitempty"`
	Value   []byte `protobuf:"bytes,2,opt,name=Value,proto3" json:"Value,omitempty"`
	// contains filtered or unexported fields
}

type TransactionData struct {
	Epoch       uint64           `protobuf:"varint,1,opt,name=Epoch,proto3" json:"Epoch,omitempty"`
	State       TransactionState `protobuf:"varint,2,opt,name=State,proto3,enum=TransactionState" json:"State,omitempty"`
	Version     uint64           `protobuf:"varint,3,opt,name=Version,proto3" json:"Version,omitempty"`
	UpdatedKeys [][]byte         `protobuf:"bytes,4,rep,name=UpdatedKeys,proto3" json:"UpdatedKeys,omitempty"`
	// contains filtered or unexported fields
}

type TransactionState int32

type Updater interface {
	// Update is atomic for an individual key.
	Update(key []byte, fn func(val []byte) ([]byte, error)) error
	Commit(sync bool) error
	Rollback()
}