Documentation
¶
Index ¶
- func Marshal(v uint64) []byte
- func Unmarshal(raw []byte) uint64
- type CounterBasedVersionBuilder
- func (c *CounterBasedVersionBuilder) VersionedMetaValues(rws *vault.ReadWriteSet, ns driver.Namespace, writes vault.KeyedMetaWrites, ...) (map[driver.PKey]driver.VaultMetadataValue, error)
- func (*CounterBasedVersionBuilder) VersionedValues(rws *vault.ReadWriteSet, ns driver.Namespace, writes vault.NamespaceWrites, ...) (map[driver.PKey]driver.VaultValue, error)
- type CounterBasedVersionComparator
- type Interceptor
- type Marshaller
- type Vault
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type CounterBasedVersionBuilder ¶
type CounterBasedVersionBuilder struct{}
func (*CounterBasedVersionBuilder) VersionedMetaValues ¶
func (c *CounterBasedVersionBuilder) VersionedMetaValues(rws *vault.ReadWriteSet, ns driver.Namespace, writes vault.KeyedMetaWrites, block driver.BlockNum, indexInBloc driver.TxNum) (map[driver.PKey]driver.VaultMetadataValue, error)
func (*CounterBasedVersionBuilder) VersionedValues ¶
func (*CounterBasedVersionBuilder) VersionedValues(rws *vault.ReadWriteSet, ns driver.Namespace, writes vault.NamespaceWrites, block driver.BlockNum, indexInBloc driver.TxNum) (map[driver.PKey]driver.VaultValue, error)
type CounterBasedVersionComparator ¶
type CounterBasedVersionComparator struct{}
func (*CounterBasedVersionComparator) Equal ¶
func (*CounterBasedVersionComparator) Equal(v1, v2 driver.RawVersion) bool
type Interceptor ¶
type Interceptor[V driver.ValidationCode] struct { *vault.Interceptor[V] // contains filtered or unexported fields }
func (*Interceptor[V]) AppendRWSet ¶
func (i *Interceptor[V]) AppendRWSet(raw []byte, nss ...string) error
func (*Interceptor[V]) Bytes ¶
func (i *Interceptor[V]) Bytes() ([]byte, error)
type Marshaller ¶
type Marshaller struct {
NsInfo map[driver.Namespace]driver.RawVersion
}
Marshaller is the custom marshaller for fabricx.
func NewMarshaller ¶
func NewMarshaller() *Marshaller
func (*Marshaller) Append ¶
func (m *Marshaller) Append(destination *vault.ReadWriteSet, raw []byte, namespaces ...string) error
func (*Marshaller) Marshal ¶
func (m *Marshaller) Marshal(txID string, rws *vault.ReadWriteSet) ([]byte, error)
func (*Marshaller) RWSetFromBytes ¶
func (m *Marshaller) RWSetFromBytes(raw []byte, namespaces ...string) (*vault.ReadWriteSet, error)
type Vault ¶
type Vault = vault.Vault[fdriver.ValidationCode]
func New ¶
func New( configService fdriver.ConfigService, vaultStore driver.VaultStore, channel string, _ queryservice.Provider, metricsProvider metrics.Provider, tracerProvider trace.TracerProvider, ) (*Vault, error)
func NewVault ¶
func NewVault(vaultStore vault2.CachedVaultStore, metricsProvider metrics.Provider, tracerProvider trace.TracerProvider) *Vault
NewVault returns a new instance of Vault.
Click to show internal directories.
Click to hide internal directories.