fabric: github.com/hyperledger/fabric/core/ledger/kvledger/txmgmt/pvtstatepurgemgmt Index | Files

package pvtstatepurgemgmt

import "github.com/hyperledger/fabric/core/ledger/kvledger/txmgmt/pvtstatepurgemgmt"

Index

Package Files

expiry_keeper.go expiry_schedule_builder.go purge_mgr.go pvtdata_key.pb.go pvtdata_key_helper.go

type Collections Uses

type Collections struct {
    Map                  map[string]*KeysAndHashes `protobuf:"bytes,1,rep,name=map,proto3" json:"map,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
    XXX_unrecognized     []byte                    `json:"-"`
    XXX_sizecache        int32                     `json:"-"`
}

func (*Collections) Descriptor Uses

func (*Collections) Descriptor() ([]byte, []int)

func (*Collections) GetMap Uses

func (m *Collections) GetMap() map[string]*KeysAndHashes

func (*Collections) ProtoMessage Uses

func (*Collections) ProtoMessage()

func (*Collections) Reset Uses

func (m *Collections) Reset()

func (*Collections) String Uses

func (m *Collections) String() string

func (*Collections) XXX_DiscardUnknown Uses

func (m *Collections) XXX_DiscardUnknown()

func (*Collections) XXX_Marshal Uses

func (m *Collections) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Collections) XXX_Merge Uses

func (dst *Collections) XXX_Merge(src proto.Message)

func (*Collections) XXX_Size Uses

func (m *Collections) XXX_Size() int

func (*Collections) XXX_Unmarshal Uses

func (m *Collections) XXX_Unmarshal(b []byte) error

type KeyAndHash Uses

type KeyAndHash struct {
    Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
    Hash                 []byte   `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*KeyAndHash) Descriptor Uses

func (*KeyAndHash) Descriptor() ([]byte, []int)

func (*KeyAndHash) GetHash Uses

func (m *KeyAndHash) GetHash() []byte

func (*KeyAndHash) GetKey Uses

func (m *KeyAndHash) GetKey() string

func (*KeyAndHash) ProtoMessage Uses

func (*KeyAndHash) ProtoMessage()

func (*KeyAndHash) Reset Uses

func (m *KeyAndHash) Reset()

func (*KeyAndHash) String Uses

func (m *KeyAndHash) String() string

func (*KeyAndHash) XXX_DiscardUnknown Uses

func (m *KeyAndHash) XXX_DiscardUnknown()

func (*KeyAndHash) XXX_Marshal Uses

func (m *KeyAndHash) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KeyAndHash) XXX_Merge Uses

func (dst *KeyAndHash) XXX_Merge(src proto.Message)

func (*KeyAndHash) XXX_Size Uses

func (m *KeyAndHash) XXX_Size() int

func (*KeyAndHash) XXX_Unmarshal Uses

func (m *KeyAndHash) XXX_Unmarshal(b []byte) error

type KeysAndHashes Uses

type KeysAndHashes struct {
    List                 []*KeyAndHash `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"`
    XXX_NoUnkeyedLiteral struct{}      `json:"-"`
    XXX_unrecognized     []byte        `json:"-"`
    XXX_sizecache        int32         `json:"-"`
}

func (*KeysAndHashes) Descriptor Uses

func (*KeysAndHashes) Descriptor() ([]byte, []int)

func (*KeysAndHashes) GetList Uses

func (m *KeysAndHashes) GetList() []*KeyAndHash

func (*KeysAndHashes) ProtoMessage Uses

func (*KeysAndHashes) ProtoMessage()

func (*KeysAndHashes) Reset Uses

func (m *KeysAndHashes) Reset()

func (*KeysAndHashes) String Uses

func (m *KeysAndHashes) String() string

func (*KeysAndHashes) XXX_DiscardUnknown Uses

func (m *KeysAndHashes) XXX_DiscardUnknown()

func (*KeysAndHashes) XXX_Marshal Uses

func (m *KeysAndHashes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KeysAndHashes) XXX_Merge Uses

func (dst *KeysAndHashes) XXX_Merge(src proto.Message)

func (*KeysAndHashes) XXX_Size Uses

func (m *KeysAndHashes) XXX_Size() int

func (*KeysAndHashes) XXX_Unmarshal Uses

func (m *KeysAndHashes) XXX_Unmarshal(b []byte) error

type PurgeMgr Uses

type PurgeMgr interface {
    // PrepareForExpiringKeys gives a chance to the PurgeMgr to do background work in advance if any
    PrepareForExpiringKeys(expiringAtBlk uint64)
    // WaitForPrepareToFinish holds the caller till the background goroutine lauched by 'PrepareForExpiringKeys' is finished
    WaitForPrepareToFinish()
    // DeleteExpiredAndUpdateBookkeeping updates the bookkeeping and modifies the update batch by adding the deletes for the expired pvtdata
    DeleteExpiredAndUpdateBookkeeping(
        pvtUpdates *privacyenabledstate.PvtUpdateBatch,
        hashedUpdates *privacyenabledstate.HashedUpdateBatch) error
    // UpdateBookkeepingForPvtDataOfOldBlocks updates the existing expiry entries in the bookkeeper with the given pvtUpdates
    UpdateBookkeepingForPvtDataOfOldBlocks(pvtUpdates *privacyenabledstate.PvtUpdateBatch) error
    // BlockCommitDone is a callback to the PurgeMgr when the block is committed to the ledger
    BlockCommitDone() error
}

PurgeMgr manages purging of the expired pvtdata

func InstantiatePurgeMgr Uses

func InstantiatePurgeMgr(ledgerid string, db privacyenabledstate.DB, btlPolicy pvtdatapolicy.BTLPolicy, bookkeepingProvider bookkeeping.Provider) (PurgeMgr, error)

InstantiatePurgeMgr instantiates a PurgeMgr.

type PvtdataKeys Uses

type PvtdataKeys struct {
    Map                  map[string]*Collections `protobuf:"bytes,1,rep,name=map,proto3" json:"map,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    XXX_NoUnkeyedLiteral struct{}                `json:"-"`
    XXX_unrecognized     []byte                  `json:"-"`
    XXX_sizecache        int32                   `json:"-"`
}

func (*PvtdataKeys) Descriptor Uses

func (*PvtdataKeys) Descriptor() ([]byte, []int)

func (*PvtdataKeys) GetMap Uses

func (m *PvtdataKeys) GetMap() map[string]*Collections

func (*PvtdataKeys) ProtoMessage Uses

func (*PvtdataKeys) ProtoMessage()

func (*PvtdataKeys) Reset Uses

func (m *PvtdataKeys) Reset()

func (*PvtdataKeys) String Uses

func (m *PvtdataKeys) String() string

func (*PvtdataKeys) XXX_DiscardUnknown Uses

func (m *PvtdataKeys) XXX_DiscardUnknown()

func (*PvtdataKeys) XXX_Marshal Uses

func (m *PvtdataKeys) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PvtdataKeys) XXX_Merge Uses

func (dst *PvtdataKeys) XXX_Merge(src proto.Message)

func (*PvtdataKeys) XXX_Size Uses

func (m *PvtdataKeys) XXX_Size() int

func (*PvtdataKeys) XXX_Unmarshal Uses

func (m *PvtdataKeys) XXX_Unmarshal(b []byte) error

Package pvtstatepurgemgmt imports 13 packages (graph) and is imported by 1 packages. Updated 2019-06-15. Refresh now. Tools for package owners.