identity

package
v6.6.0+incompatible Latest Latest
Warning

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

Go to latest
Published: Feb 20, 2020 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause, + 4 more Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source
const (
	TWELVE_HOURS_S uint64 = 12 * 60 * 60
)

Variables

This section is empty.

Functions

func BubbleSortUint32

func BubbleSortUint32(arr []uint32) []uint32

func CheckTimestamp

func CheckTimestamp(time []byte, timeEntered int64) bool

Makes sure the timestamp is within the designated window to be valid : 12 hours TimeEntered is in seconds

Types

type AnchorSigningKey

type AnchorSigningKey struct {
	BlockChain string                 `json:"blockchain"`
	KeyLevel   byte                   `json:"level"`
	KeyType    byte                   `json:"keytype"`
	SigningKey primitives.ByteSlice20 `json:"key"` //if bytes, it is hex
}

func RandomAnchorSigningKey

func RandomAnchorSigningKey() *AnchorSigningKey

func (*AnchorSigningKey) IsSameAs

func (e *AnchorSigningKey) IsSameAs(b *AnchorSigningKey) bool

func (*AnchorSigningKey) MarshalBinary

func (e *AnchorSigningKey) MarshalBinary() (rval []byte, err error)

func (*AnchorSigningKey) UnmarshalBinary

func (e *AnchorSigningKey) UnmarshalBinary(p []byte) error

func (*AnchorSigningKey) UnmarshalBinaryData

func (e *AnchorSigningKey) UnmarshalBinaryData(p []byte) (newData []byte, err error)

type AnchorSigningKeySort

type AnchorSigningKeySort []AnchorSigningKey

sort.Sort interface implementation

func (AnchorSigningKeySort) Len

func (p AnchorSigningKeySort) Len() int

func (AnchorSigningKeySort) Less

func (p AnchorSigningKeySort) Less(i, j int) bool

func (AnchorSigningKeySort) Swap

func (p AnchorSigningKeySort) Swap(i, j int)

type Authority

type Authority struct {
	AuthorityChainID  interfaces.IHash     `json:"chainid"`
	ManagementChainID interfaces.IHash     `json:"manageid"`
	MatryoshkaHash    interfaces.IHash     `json:"matroyshka"`
	SigningKey        primitives.PublicKey `json:"signingkey"`
	Status            uint8                `json:"status"`
	AnchorKeys        []AnchorSigningKey   `json:"anchorkeys"`

	KeyHistory      []HistoricKey       `json:"-"`
	Efficiency      uint16              `json:"efficiency"`
	CoinbaseAddress interfaces.IAddress `json:"coinbaseaddress"`
}

func NewAuthority

func NewAuthority() *Authority

func RandomAuthority

func RandomAuthority() *Authority

func (*Authority) Clone

func (a *Authority) Clone() *Authority

func (*Authority) GetAuthorityChainID

func (e *Authority) GetAuthorityChainID() (rval interfaces.IHash)

func (*Authority) GetCoinbaseHumanReadable

func (a *Authority) GetCoinbaseHumanReadable() string

func (*Authority) GetSigningKey

func (auth *Authority) GetSigningKey() []byte

func (*Authority) Init

func (e *Authority) Init()

func (*Authority) IsSameAs

func (e *Authority) IsSameAs(b *Authority) bool

func (*Authority) MarshalBinary

func (e *Authority) MarshalBinary() (rval []byte, err error)

func (*Authority) MarshalJSON

func (auth *Authority) MarshalJSON() (rval []byte, err error)

func (*Authority) Type

func (auth *Authority) Type() int

1 if fed, 0 if audit, -1 if neither

func (*Authority) UnmarshalBinary

func (e *Authority) UnmarshalBinary(p []byte) error

func (*Authority) UnmarshalBinaryData

func (e *Authority) UnmarshalBinaryData(p []byte) (newData []byte, err error)

func (*Authority) VerifySignature

func (auth *Authority) VerifySignature(msg []byte, sig *[constants.SIGNATURE_LENGTH]byte) (bool, error)

type AuthoritySort

type AuthoritySort []interfaces.IAuthority

sort.Sort interface implementation

func (AuthoritySort) Len

func (p AuthoritySort) Len() int

func (AuthoritySort) Less

func (p AuthoritySort) Less(i, j int) bool

func (AuthoritySort) Swap

func (p AuthoritySort) Swap(i, j int)

type CoinbaseCancelManager

type CoinbaseCancelManager struct {
	// Heights of various descriptor cancel proposals. This list will be
	// sorted, and is used for garbage collecting proposals that have failed
	ProposalsList []uint32

	// Proposals is all cancel proposals for a given descriptor height
	//		[descriptorheight][cancel index][id chain]Cancel identity entry
	Proposals map[uint32]map[uint32]map[[32]byte]identityEntries.NewCoinbaseCancelStruct

	// Boolean indicator if it's been recorded to the admin block. We do not do this more than once
	//		[descriptorheight][cancel index]
	AdminBlockRecord map[uint32]map[uint32]bool
	// contains filtered or unexported fields
}

CoinbaseCancelManager handles keeping track of coinbase cancel signals in identity chains. Specifically keeps track of the tallies, then can determine if an admin block entry should be created.

func NewCoinbaseCancelManager

func NewCoinbaseCancelManager(im *IdentityManager) *CoinbaseCancelManager

func (*CoinbaseCancelManager) AddCancel

AddCancel will add a proposal to the list. It assumes the height check has already been done

func (*CoinbaseCancelManager) AddNewProposalHeight

func (cm *CoinbaseCancelManager) AddNewProposalHeight(descriptorHeight uint32)

AddNewProposalHeight does a insert into the sorted list. It does not use binary search as this list should be relatively small, and infrequently used. Only used when canceling a coinbase in the future.

func (*CoinbaseCancelManager) CanceledOutputs

func (cm *CoinbaseCancelManager) CanceledOutputs(descriptorHeight uint32) []uint32

CanceledOutputs will return the indices of all indices to be canceled for a given descriptor height

It will only return indicies not already marked as cancelled (in the admin block)

This function is used in unit tests, not in factomd

func (*CoinbaseCancelManager) GC

func (c *CoinbaseCancelManager) GC(dbheight uint32)

GC is garbage collecting old proposals

dbheight is the current height.

func (*CoinbaseCancelManager) IsAdminBlockRecorded

func (cm *CoinbaseCancelManager) IsAdminBlockRecorded(descriptorHeight uint32, index uint32) bool

IsAdminBlockRecorded returns boolean if marked already recorded. Garbage collected heights will return false, so the caller will have to check if the dbheight is valid.

func (*CoinbaseCancelManager) IsCoinbaseCancelled

func (cm *CoinbaseCancelManager) IsCoinbaseCancelled(descriptorHeight, index uint32) bool

IsCoinbaseCancelled returns true if the coinbase transaction is cancelled for a given descriptor height and (output) index.

func (*CoinbaseCancelManager) MarkAdminBlockRecorded

func (cm *CoinbaseCancelManager) MarkAdminBlockRecorded(descriptorHeight uint32, index uint32)

MarkAdminBlockRecorded will mark a given index for a descriptor already canceled. This is to prevent a given index from being recorded multiple times

type EntryBlockMarker

type EntryBlockMarker struct {
	KeyMr           interfaces.IHash
	Sequence        uint32
	DBHeight        uint32
	DblockTimestamp interfaces.Timestamp
}

func NewEntryBlockMarker

func NewEntryBlockMarker() *EntryBlockMarker

func RandomEntryBlockMarker

func RandomEntryBlockMarker() *EntryBlockMarker

func (*EntryBlockMarker) Clone

func (e *EntryBlockMarker) Clone() *EntryBlockMarker

func (*EntryBlockMarker) IsSameAs

func (a *EntryBlockMarker) IsSameAs(b *EntryBlockMarker) bool

func (*EntryBlockMarker) MarshalBinary

func (e *EntryBlockMarker) MarshalBinary() (rval []byte, err error)

func (*EntryBlockMarker) Size

func (e *EntryBlockMarker) Size() int

Returns the byte size when marshaled

func (*EntryBlockMarker) UnmarshalBinary

func (e *EntryBlockMarker) UnmarshalBinary(p []byte) error

func (*EntryBlockMarker) UnmarshalBinaryData

func (e *EntryBlockMarker) UnmarshalBinaryData(p []byte) (newData []byte, err error)

type EntryBlockMarkerList

type EntryBlockMarkerList []EntryBlockMarker

func (EntryBlockMarkerList) Len

func (p EntryBlockMarkerList) Len() int

func (EntryBlockMarkerList) Less

func (p EntryBlockMarkerList) Less(i, j int) bool

func (EntryBlockMarkerList) Swap

func (p EntryBlockMarkerList) Swap(i, j int)

type EntryBlockSync

type EntryBlockSync struct {
	Current          EntryBlockMarker
	Target           EntryBlockMarker
	BlocksToBeParsed []EntryBlockMarker
}

EntryBlockSync has the current eblock synced to, and the target Eblock

It also has the blocks in between in order. This makes it so traversing only needs to happen once

func NewEntryBlockSync

func NewEntryBlockSync() *EntryBlockSync

func RandomEntryBlockSync

func RandomEntryBlockSync() *EntryBlockSync

func (*EntryBlockSync) AddNewHead

func (a *EntryBlockSync) AddNewHead(keymr interfaces.IHash, seq uint32, ht uint32, dblockTimestamp interfaces.Timestamp)

func (*EntryBlockSync) AddNewHeadMarker

func (a *EntryBlockSync) AddNewHeadMarker(marker EntryBlockMarker)

AddNewHead will add a new eblock to be parsed to the head (tail of list)

Since the block needs to be parsed, it is the new target and added to the blocks to be parsed

func (*EntryBlockSync) BlockParsed

func (a *EntryBlockSync) BlockParsed(block EntryBlockMarker)

BlockParsed indicates a block has been parsed. We update our current

func (*EntryBlockSync) Clone

func (e *EntryBlockSync) Clone() *EntryBlockSync

func (*EntryBlockSync) IsSameAs

func (a *EntryBlockSync) IsSameAs(b *EntryBlockSync) bool

func (*EntryBlockSync) MarshalBinary

func (e *EntryBlockSync) MarshalBinary() (rval []byte, err error)

func (*EntryBlockSync) NextEBlock

func (a *EntryBlockSync) NextEBlock() *EntryBlockMarker

NextEBlock returns the next eblock that is needed to be parsed

func (*EntryBlockSync) Synced

func (a *EntryBlockSync) Synced() bool

Synced returns if fully synced (current == target)

func (*EntryBlockSync) UnmarshalBinary

func (e *EntryBlockSync) UnmarshalBinary(p []byte) error

func (*EntryBlockSync) UnmarshalBinaryData

func (e *EntryBlockSync) UnmarshalBinaryData(p []byte) (newData []byte, err error)

type HistoricKey

type HistoricKey struct {
	ActiveDBHeight uint32
	SigningKey     primitives.PublicKey
}

func RandomHistoricKey

func RandomHistoricKey() *HistoricKey

func (*HistoricKey) IsSameAs

func (e *HistoricKey) IsSameAs(b *HistoricKey) bool

func (*HistoricKey) MarshalBinary

func (e *HistoricKey) MarshalBinary() (rval []byte, err error)

func (*HistoricKey) UnmarshalBinary

func (e *HistoricKey) UnmarshalBinary(p []byte) error

func (*HistoricKey) UnmarshalBinaryData

func (e *HistoricKey) UnmarshalBinaryData(p []byte) (newData []byte, err error)

type Identity

type Identity struct {
	IdentityChainID    interfaces.IHash `json:"identity_chainid"`
	IdentityChainSync  EntryBlockSync   `json:"-"`
	IdentityRegistered uint32           `json:"identity_registered`
	IdentityCreated    uint32           `json:"identity_created`

	ManagementChainID    interfaces.IHash `json:"management_chaind`
	ManagementChainSync  EntryBlockSync   `json:"-"`
	ManagementRegistered uint32           `json:"management_registered`
	ManagementCreated    uint32           `json:"management_created`
	MatryoshkaHash       interfaces.IHash `json:"matryoshka_hash`

	// All 4 levels keys, 0 indexed.
	//		Keys[0] --> Key 1
	//		Keys[1] --> Key 2
	//		Keys[2] --> Key 3
	//		Keys[3] --> Key 4
	Keys            [4]interfaces.IHash `json:"identity_keys"`
	SigningKey      interfaces.IHash    `json:"signing_key"`
	Status          uint8               `json:"status"`
	AnchorKeys      []AnchorSigningKey  `json:"anchor_keys"`
	Efficiency      uint16              `json:"efficiency"`
	CoinbaseAddress interfaces.IHash    `json:"coinbase_address"`
}

https://github.com/FactomProject/FactomDocs/blob/master/Identity.md

func NewIdentity

func NewIdentity() *Identity

func RandomIdentity

func RandomIdentity() *Identity

func (*Identity) Clone

func (e *Identity) Clone() *Identity

func (*Identity) GetCoinbaseHumanReadable

func (id *Identity) GetCoinbaseHumanReadable() string

func (*Identity) Init

func (e *Identity) Init()

func (*Identity) IsComplete

func (id *Identity) IsComplete() (bool, error)

IsComplete returns if the identity is complete, meaning it has all of the required information for an authority server. If the identity is not valid, a list of missing things will be returned in the error

func (*Identity) IsFull

func (id *Identity) IsFull() bool

func (*Identity) IsPromteable

func (id *Identity) IsPromteable() (bool, error)

IsPromteable will return if the identity is able to be promoted.

Checks if the Identity is complete
Checks if the registration is valid

func (*Identity) IsRegistrationValid

func (id *Identity) IsRegistrationValid() (bool, error)

IsRegistrationValid will return if the registration of the identity is valid. It is determined by the block heights of registration to creation and is all time based (where time is measured in blocks)

func (*Identity) IsSameAs

func (e *Identity) IsSameAs(b *Identity) bool

func (*Identity) JSONByte

func (e *Identity) JSONByte() ([]byte, error)

func (*Identity) JSONString

func (e *Identity) JSONString() (string, error)

func (*Identity) MarshalBinary

func (e *Identity) MarshalBinary() (rval []byte, err error)

func (*Identity) String

func (e *Identity) String() string

func (*Identity) ToAuthority

func (id *Identity) ToAuthority() *Authority

ToAuthority should ONLY be used in TESTING

Helpful for unit tests, useless for anything else

func (*Identity) UnmarshalBinary

func (e *Identity) UnmarshalBinary(p []byte) error

func (*Identity) UnmarshalBinaryData

func (e *Identity) UnmarshalBinaryData(p []byte) (newData []byte, err error)

func (*Identity) VerifySignature

func (id *Identity) VerifySignature(msg []byte, sig *[constants.SIGNATURE_LENGTH]byte) (bool, error)

type IdentityManager

type IdentityManager struct {
	Mutex sync.RWMutex
	IdentityManagerWithoutMutex
}

func NewIdentityManager

func NewIdentityManager() *IdentityManager

func RandomIdentityManager

func RandomIdentityManager() *IdentityManager

func RandomIdentityManagerWithCounts

func RandomIdentityManagerWithCounts(fedCount, audCount int) *IdentityManager

func (*IdentityManager) ApplyAddAuditServer

func (im *IdentityManager) ApplyAddAuditServer(entry interfaces.IABEntry, st interfaces.IState) error

func (*IdentityManager) ApplyAddEfficiency

func (im *IdentityManager) ApplyAddEfficiency(entry interfaces.IABEntry) error

func (*IdentityManager) ApplyAddFactoidAddress

func (im *IdentityManager) ApplyAddFactoidAddress(entry interfaces.IABEntry) error

func (*IdentityManager) ApplyAddFederatedServer

func (im *IdentityManager) ApplyAddFederatedServer(entry interfaces.IABEntry, st interfaces.IState) error

func (*IdentityManager) ApplyAddFederatedServerBitcoinAnchorKey

func (im *IdentityManager) ApplyAddFederatedServerBitcoinAnchorKey(entry interfaces.IABEntry) error

func (*IdentityManager) ApplyAddFederatedServerSigningKey

func (im *IdentityManager) ApplyAddFederatedServerSigningKey(entry interfaces.IABEntry) error

func (*IdentityManager) ApplyAddReplaceMatryoshkaHash

func (im *IdentityManager) ApplyAddReplaceMatryoshkaHash(entry interfaces.IABEntry) error

func (*IdentityManager) ApplyCancelCoinbaseDescriptor

func (im *IdentityManager) ApplyCancelCoinbaseDescriptor(entry interfaces.IABEntry) error

func (*IdentityManager) ApplyIdentityChainStructure

func (im *IdentityManager) ApplyIdentityChainStructure(ic *IdentityChainStructure, chainID interfaces.IHash, dBlockHeight uint32) (bool, error)

func (*IdentityManager) ApplyIncreaseServerCount

func (im *IdentityManager) ApplyIncreaseServerCount(entry interfaces.IABEntry) error

func (*IdentityManager) ApplyNewBitcoinKeyStructure

func (im *IdentityManager) ApplyNewBitcoinKeyStructure(bnk *NewBitcoinKeyStructure, subChainID interfaces.IHash, BlockChain string, dBlockTimestamp interfaces.Timestamp, a interfaces.IAdminBlock) (bool, bool, error)

Returns

bool	change		If a key has been changed
bool	tryagain	If this is set to true, this entry can be reprocessed if it is *new*
error	err			Any errors

func (*IdentityManager) ApplyNewBlockSigningKeyStruct

func (im *IdentityManager) ApplyNewBlockSigningKeyStruct(nbsk *NewBlockSigningKeyStruct, subchainID interfaces.IHash, dBlockTimestamp interfaces.Timestamp, a interfaces.IAdminBlock) (bool, bool, error)

ApplyNewBlockSigningKeyStruct will parse a new block signing key and attempt to add the signing to the proper identity.

Returns
	bool	change		If a key has been changed
	bool	tryagain	If this is set to true, this entry can be reprocessed if it is *new*
	error	err			Any errors

func (*IdentityManager) ApplyNewCoinbaseAddressStruct

func (im *IdentityManager) ApplyNewCoinbaseAddressStruct(ncas *NewCoinbaseAddressStruct, rootchainID interfaces.IHash, dBlockTimestamp interfaces.Timestamp, a interfaces.IAdminBlock) (bool, bool, error)

ApplyNewCoinbaseAddressStruct will parse a new coinbase address and attempt to add the signing to the proper identity.

Returns
	bool	change		If a key has been changed
	bool	tryagain	If this is set to true, this entry can be reprocessed if it is *new*
	error	err			Any errors

func (*IdentityManager) ApplyNewCoinbaseCancelStruct

func (im *IdentityManager) ApplyNewCoinbaseCancelStruct(nccs *NewCoinbaseCancelStruct, managechain interfaces.IHash, dblockHeight uint32, a interfaces.IAdminBlock) (bool, bool, error)

ApplyNewCoinbaseCancelStruct will parse a new coinbase cancel

Validation Difference:
	Most entries check the timestamps to ensure entry is within 12 hours of dblock. That does not apply to coinbase, it can be replayed
	as long as it is between the block window.
Returns
	bool	change		If a key has been changed
	bool	tryagain	If this is set to true, this entry can be reprocessed if it is *new*
	error	err			Any errors

func (*IdentityManager) ApplyNewMatryoshkaHashStructure

func (im *IdentityManager) ApplyNewMatryoshkaHashStructure(nmh *NewMatryoshkaHashStructure, dBlockTimestamp interfaces.Timestamp, a interfaces.IAdminBlock) (bool, bool, error)

ApplyNewMatryoshkaHashStructure will parse a new matryoshka hash and attempt to add the signing to the proper identity.

Returns
	bool	change		If a key has been changed
	bool	tryagain	If this is set to true, this entry can be reprocessed if it is *new*
	error	err			Any errors

func (*IdentityManager) ApplyNewServerEfficiencyStruct

func (im *IdentityManager) ApplyNewServerEfficiencyStruct(nses *NewServerEfficiencyStruct, subchainID interfaces.IHash, dBlockTimestamp interfaces.Timestamp, a interfaces.IAdminBlock) (bool, bool, error)

ApplyNewServerEfficiencyStruct will parse a new server efficiency and attempt to add the signing to the proper identity.

Returns
	bool	change		If a key has been changed
	bool	tryagain	If this is set to true, this entry can be reprocessed if it is *new*
	error	err			Any errors

func (*IdentityManager) ApplyRegisterFactomIdentityStructure

func (im *IdentityManager) ApplyRegisterFactomIdentityStructure(rfi *RegisterFactomIdentityStructure, dBlockHeight uint32) (bool, error)

func (*IdentityManager) ApplyRegisterServerManagementStructure

func (im *IdentityManager) ApplyRegisterServerManagementStructure(rsm *RegisterServerManagementStructure, chainID interfaces.IHash, dBlockHeight uint32) (bool, error)

func (*IdentityManager) ApplyRemoveFederatedServer

func (im *IdentityManager) ApplyRemoveFederatedServer(entry interfaces.IABEntry) error

func (*IdentityManager) ApplyRevealMatryoshkaHash

func (im *IdentityManager) ApplyRevealMatryoshkaHash(entry interfaces.IABEntry) error

func (*IdentityManager) ApplyServerFault

func (im *IdentityManager) ApplyServerFault(entry interfaces.IABEntry) error

func (*IdentityManager) ApplyServerManagementStructure

func (im *IdentityManager) ApplyServerManagementStructure(sm *ServerManagementStructure, chainID interfaces.IHash, dBlockHeight uint32) (bool, error)

ApplyServerManagementStructure is the first entry in the management chain

DO NOT set the management chain in the identity, as it will be set on the register
	"Server Management"

func (*IdentityManager) AuditServerCount

func (im *IdentityManager) AuditServerCount() int

func (*IdentityManager) AuthorityServerCount

func (im *IdentityManager) AuthorityServerCount() int

AuthorityServerCount returns the total count of Federated + Audit Servers

func (*IdentityManager) CheckDBSignatureEntries

func (im *IdentityManager) CheckDBSignatureEntries(aBlock interfaces.IAdminBlock, dBlock interfaces.IDirectoryBlock, prevHeader []byte) error

func (*IdentityManager) Clone

func (im *IdentityManager) Clone() *IdentityManager

Used when cloning state into sim nodes

func (*IdentityManager) FedServerCount

func (im *IdentityManager) FedServerCount() int

func (*IdentityManager) GetAuthorities

func (im *IdentityManager) GetAuthorities() []interfaces.IAuthority

func (*IdentityManager) GetAuthority

func (im *IdentityManager) GetAuthority(chainID interfaces.IHash) *Authority

func (*IdentityManager) GetIdentities

func (im *IdentityManager) GetIdentities() []*Identity

func (*IdentityManager) GetIdentity

func (im *IdentityManager) GetIdentity(chainID interfaces.IHash) *Identity

func (*IdentityManager) GetRegistrations

func (*IdentityManager) GetSortedAuthorities

func (im *IdentityManager) GetSortedAuthorities() []interfaces.IAuthority

func (*IdentityManager) GetSortedIdentities

func (im *IdentityManager) GetSortedIdentities() []*Identity

func (*IdentityManager) GetSortedRegistrations

func (im *IdentityManager) GetSortedRegistrations() []*identityEntries.RegisterFactomIdentityStructure

func (*IdentityManager) GobDecode

func (im *IdentityManager) GobDecode(data []byte) error

func (*IdentityManager) GobEncode

func (im *IdentityManager) GobEncode() ([]byte, error)

func (*IdentityManager) Init

func (im *IdentityManager) Init()

func (*IdentityManager) IsSameAs

func (a *IdentityManager) IsSameAs(b *IdentityManager) bool

func (*IdentityManager) MarshalBinary

func (im *IdentityManager) MarshalBinary() ([]byte, error)

func (*IdentityManager) ProcessABlockEntry

func (im *IdentityManager) ProcessABlockEntry(entry interfaces.IABEntry, st interfaces.IState) error

func (*IdentityManager) ProcessIdentityEntry

func (im *IdentityManager) ProcessIdentityEntry(entry interfaces.IEBEntry, dBlockHeight uint32, dBlockTimestamp interfaces.Timestamp, newEntry bool) (bool, error)

func (*IdentityManager) ProcessIdentityEntryWithABlockUpdate

func (im *IdentityManager) ProcessIdentityEntryWithABlockUpdate(entry interfaces.IEBEntry, dBlockHeight uint32, dBlockTimestamp interfaces.Timestamp, a interfaces.IAdminBlock, newEntry bool) (bool, error)

ProcessIdentityEntryWithABlockUpdate will process an entry and update an entry. It will also update the admin block with any changes. There are some special parameters:

Params:
	entry
	dBlockHeight
	dBlockTimestamp
	d					DBState		If not nil, it means to update the admin block with changes
	newEntry			bool		Setting this to true means it can be put into the oldEntries queue to be reprocesses (helps for out of order entries)

Returns
	change				bool		If a key has been changed
	err					error

func (*IdentityManager) ProcessOldEntries

func (im *IdentityManager) ProcessOldEntries() (bool, error)

func (*IdentityManager) PushEntryForLater

func (im *IdentityManager) PushEntryForLater(entry interfaces.IEBEntry, dBlockHeight uint32, dBlockTimestamp interfaces.Timestamp) error

func (*IdentityManager) RemoveAuthority

func (im *IdentityManager) RemoveAuthority(chainID interfaces.IHash) bool

func (*IdentityManager) RemoveIdentity

func (im *IdentityManager) RemoveIdentity(chainID interfaces.IHash) bool

func (*IdentityManager) SetAuthority

func (im *IdentityManager) SetAuthority(chainID interfaces.IHash, auth *Authority)

func (*IdentityManager) SetBootstrapIdentity

func (im *IdentityManager) SetBootstrapIdentity(id interfaces.IHash, key interfaces.IHash) error

func (*IdentityManager) SetIdentity

func (im *IdentityManager) SetIdentity(chainID interfaces.IHash, id *Identity)

func (*IdentityManager) SetIdentityRegistration

func (im *IdentityManager) SetIdentityRegistration(chain interfaces.IHash) error

func (*IdentityManager) SetSkeletonIdentity

func (im *IdentityManager) SetSkeletonIdentity(chain interfaces.IHash) error

func (*IdentityManager) String

func (im *IdentityManager) String() string

Full print of Identity Manager

func (*IdentityManager) UnmarshalBinary

func (e *IdentityManager) UnmarshalBinary(p []byte) error

func (*IdentityManager) UnmarshalBinaryData

func (im *IdentityManager) UnmarshalBinaryData(p []byte) (newData []byte, err error)

type IdentityManagerWithoutMutex

type IdentityManagerWithoutMutex struct {
	Authorities map[[32]byte]*Authority
	Identities  map[[32]byte]*Identity
	// All Identity Registrations.
	IdentityRegistrations   map[[32]byte]*identityEntries.RegisterFactomIdentityStructure
	MaxAuthorityServerCount int

	// Not Marshalled
	// Tracks cancellation of coinbases
	CancelManager *CoinbaseCancelManager

	// Map of all coinbase outputs that are cancelled.
	//	The map key is the block height of the DESCRIPTOR
	//	The list of ints are the indices of the outputs to be
	//	removed. The keys from the map should be deleted when the
	//	descriptor+declaration height is hit.
	//		[descriptorheight]List of cancelled outputs
	CanceledCoinbaseOutputs map[uint32][]uint32
	OldEntries              []*OldEntry
}

type IdentitySort

type IdentitySort []*Identity

sort.Sort interface implementation

func (IdentitySort) Len

func (p IdentitySort) Len() int

func (IdentitySort) Less

func (p IdentitySort) Less(i, j int) bool

func (IdentitySort) Swap

func (p IdentitySort) Swap(i, j int)

type OldEntry

type OldEntry struct {
	EntryBinary     []byte
	DBlockHeight    uint32
	DBlockTimestamp uint64
}

Jump to

Keyboard shortcuts

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