node

package

v0.0.0-...-822dead Latest Latest Go to latest Published: Jun 11, 2021 License: GPL-3.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

gitlab.com/bertrandbenj/politikojj

Links

Open Source Insights

Documentation ¶

Index ¶

func IsNewDay(oldTime int64, nowT int64) bool
type BlockDataProcessor
type BlockSmith
- func NewBlockSmith(ch *chain.BlockChainService, pair crypto.Keypair, powCores int) *BlockSmith
- func (smith BlockSmith) CalculatePow(block model.Block) model.Block
- func (smith BlockSmith) CheckForkOrChain(block model.Block) error
- func (smith BlockSmith) GenerateBlock(oldBlock model.Block) (model.Block, error)
- func (smith BlockSmith) RunBlockSmith()
type CratosProcessingService
- func (proc CratosProcessingService) ApplyAmendment(countAmendmentVote map[string]uint64, newCratos *model.Cratos, ...)
- func (proc CratosProcessingService) ApplyDelta(t int64, oldBlock model.Block, updatedCratosCid chan string, ...)
- func (proc CratosProcessingService) ApplyVariableValueChange(newCratos *model.Cratos, demos model.Demos, evidences chan model.Evidence)
- func (proc CratosProcessingService) DeserializeFromCratos(block model.Cratos)
- func (proc CratosProcessingService) IsAuthorized(role string, perm string) bool
- func (proc CratosProcessingService) SerializeForCratos() model.Roles
type CurrencyProcessorService
- func (ccy CurrencyProcessorService) ApplyDelta(t int64, oldBlock model.Block, updatedCid chan string, ...)
type DemosProcessingService
- func (proc DemosProcessingService) ApplyDelta(t int64, oldBlock model.Block, updatedCid chan string, ...)
- func (proc DemosProcessingService) FindNewCitizens(demos *model.Demos, evidences chan model.Evidence)
type NotaryProcessorService
- func (proc NotaryProcessorService) ApplyDelta(t int64, oldBlock model.Block, updatedCid chan string, ...)
type PolitikojjError
- func (e PolitikojjError) Error() string
type PowProcessorService
- func (proc PowProcessorService) ApplyDelta(t int64, oldBlock model.Block, updatedCid chan string, ...)
type TemporaryPool
- func NewPool() *TemporaryPool
- func (pool *TemporaryPool) Add(cid string, data interface{})
- func (pool *TemporaryPool) Attach(docsChan chan model.Wrapper)
- func (pool *TemporaryPool) CountVotes() map[string]map[string]uint64
- func (pool *TemporaryPool) Exists(cid string) bool
- func (pool *TemporaryPool) GetTxs() map[string]model.Transaction
- func (pool *TemporaryPool) GetVotes() map[string]model.OpenBallot
- func (pool *TemporaryPool) Remove(cid string)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func IsNewDay ¶

func IsNewDay(oldTime int64, nowT int64) bool

Types ¶

type BlockDataProcessor ¶

type BlockDataProcessor interface {
	ApplyDelta(t int64, oldBlock model.Block, updatedCid chan string, evidences chan model.Evidence, waitG *sync.WaitGroup)
}

type BlockSmith ¶

type BlockSmith struct {
	Key crypto.Keypair

	CratosP CratosProcessingService

	Pools *TemporaryPool
	Chain *chain.BlockChainService
	// contains filtered or unexported fields
}

func NewBlockSmith ¶

func NewBlockSmith(ch *chain.BlockChainService, pair crypto.Keypair, powCores int) *BlockSmith

func (BlockSmith) CalculatePow ¶

func (smith BlockSmith) CalculatePow(block model.Block) model.Block

func (BlockSmith) CheckForkOrChain ¶

func (smith BlockSmith) CheckForkOrChain(block model.Block) error

func (BlockSmith) GenerateBlock ¶

func (smith BlockSmith) GenerateBlock(oldBlock model.Block) (model.Block, error)

func (BlockSmith) RunBlockSmith ¶

func (smith BlockSmith) RunBlockSmith()

type CratosProcessingService ¶

type CratosProcessingService struct {
	Pools *TemporaryPool
	// contains filtered or unexported fields
}

func (CratosProcessingService) ApplyAmendment ¶

func (proc CratosProcessingService) ApplyAmendment(countAmendmentVote map[string]uint64, newCratos *model.Cratos, evidences chan model.Evidence)

func (CratosProcessingService) ApplyDelta ¶

func (proc CratosProcessingService) ApplyDelta(t int64, oldBlock model.Block, updatedCratosCid chan string, evidences chan model.Evidence, waitG *sync.WaitGroup)

func (CratosProcessingService) ApplyVariableValueChange ¶

func (proc CratosProcessingService) ApplyVariableValueChange(newCratos *model.Cratos, demos model.Demos, evidences chan model.Evidence)

func (CratosProcessingService) DeserializeFromCratos ¶

func (proc CratosProcessingService) DeserializeFromCratos(block model.Cratos)

func (CratosProcessingService) IsAuthorized ¶

func (proc CratosProcessingService) IsAuthorized(role string, perm string) bool

func (CratosProcessingService) SerializeForCratos ¶

func (proc CratosProcessingService) SerializeForCratos() model.Roles

type CurrencyProcessorService ¶

type CurrencyProcessorService struct {
	Pools *TemporaryPool
	// contains filtered or unexported fields
}

func (CurrencyProcessorService) ApplyDelta ¶

func (ccy CurrencyProcessorService) ApplyDelta(t int64, oldBlock model.Block, updatedCid chan string, evidences chan model.Evidence, waitG *sync.WaitGroup)

type DemosProcessingService ¶

type DemosProcessingService struct {
	Pools *TemporaryPool
	// contains filtered or unexported fields
}

func (DemosProcessingService) ApplyDelta ¶

func (proc DemosProcessingService) ApplyDelta(t int64, oldBlock model.Block, updatedCid chan string, evidences chan model.Evidence, waitG *sync.WaitGroup)

func (DemosProcessingService) FindNewCitizens ¶

func (proc DemosProcessingService) FindNewCitizens(demos *model.Demos, evidences chan model.Evidence)

type NotaryProcessorService ¶

type NotaryProcessorService struct {
	Pools *TemporaryPool
	// contains filtered or unexported fields
}

func (NotaryProcessorService) ApplyDelta ¶

func (proc NotaryProcessorService) ApplyDelta(t int64, oldBlock model.Block, updatedCid chan string, evidences chan model.Evidence, waitG *sync.WaitGroup)

type PolitikojjError ¶

type PolitikojjError string

func (PolitikojjError) Error ¶

func (e PolitikojjError) Error() string

type PowProcessorService ¶

type PowProcessorService struct {
	// contains filtered or unexported fields
}

func (PowProcessorService) ApplyDelta ¶

func (proc PowProcessorService) ApplyDelta(t int64, oldBlock model.Block, updatedCid chan string, evidences chan model.Evidence, waitG *sync.WaitGroup)

type TemporaryPool ¶

type TemporaryPool struct {
	Claims         map[string]model.Claim
	ApprovedClaims map[string]model.ApprovedClaim
	Votes          map[string]model.OpenBallot
	Transactions   map[string]model.Transaction
	Amendments     map[string]model.Amendment
	sync.RWMutex
	// contains filtered or unexported fields
}

==================== Pools ====================

func NewPool ¶

func NewPool() *TemporaryPool

func (*TemporaryPool) Add ¶

func (pool *TemporaryPool) Add(cid string, data interface{})

func (*TemporaryPool) Attach ¶

func (pool *TemporaryPool) Attach(docsChan chan model.Wrapper)

func (*TemporaryPool) CountVotes ¶

func (pool *TemporaryPool) CountVotes() map[string]map[string]uint64

func (*TemporaryPool) Exists ¶

func (pool *TemporaryPool) Exists(cid string) bool

func (*TemporaryPool) GetTxs ¶

func (pool *TemporaryPool) GetTxs() map[string]model.Transaction

func (*TemporaryPool) GetVotes ¶

func (pool *TemporaryPool) GetVotes() map[string]model.OpenBallot

func (*TemporaryPool) Remove ¶

func (pool *TemporaryPool) Remove(cid string)

Source Files ¶

View all Source files

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