Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

coordinator

package

Go to main page

Versions in this module

v1

v1.2.8

Aug 11, 2023

v1.2.7

Aug 10, 2023

v1.2.6

Aug 9, 2023

v1.2.5

Aug 4, 2023

v1.2.4

Feb 14, 2023

v1.2.3

Feb 13, 2023

v1.2.2

Jan 9, 2023

Changes in this version

+ const NodeAPIRouteDebugComputeWhiteFlag

+ var ErrQuorumGroupNoAnswer = errors.New("coordinator quorum group did not answer in time")

+ var ErrQuorumMerkleTreeHashMismatch = errors.New("coordinator quorum merkle tree hash mismatch")

+ func QuorumFinishedCaller(handler interface{}, params ...interface{})

type Coordinator

+ func (coo *Coordinator) Interval() time.Duration

+ func (coo *Coordinator) QuorumStats() []QuorumClientStatistic

+ type DebugNodeAPIClient struct

+ func NewDebugNodeAPIClient(baseURL string, opts ...iotago.NodeHTTPAPIClientOption) *DebugNodeAPIClient

+ func (api *DebugNodeAPIClient) Whiteflag(index milestone.Index, parents hornet.MessageIDs) (*MerkleTreeHash, error)

+ type Events struct

+ IssuedCheckpointMessage *events.Event

+ IssuedMilestone *events.Event

+ QuorumFinished *events.Event

+ SoftError *events.Event

+ type InMemoryEd25519MilestoneIndexSigner struct

+ func (s *InMemoryEd25519MilestoneIndexSigner) PublicKeys() []iotago.MilestonePublicKey

+ func (s *InMemoryEd25519MilestoneIndexSigner) PublicKeysSet() iotago.MilestonePublicKeySet

+ func (s *InMemoryEd25519MilestoneIndexSigner) SigningFunc() iotago.MilestoneSigningFunc

+ type InMemoryEd25519MilestoneSignerProvider struct

+ func NewInMemoryEd25519MilestoneSignerProvider(privateKeys []ed25519.PrivateKey, keyManager *keymanager.KeyManager, ...) *InMemoryEd25519MilestoneSignerProvider

+ func (p *InMemoryEd25519MilestoneSignerProvider) MilestoneIndexSigner(index milestone.Index) MilestoneIndexSigner

+ func (p *InMemoryEd25519MilestoneSignerProvider) PublicKeysCount() int

+ type InsecureRemoteEd25519MilestoneIndexSigner struct

+ func (s *InsecureRemoteEd25519MilestoneIndexSigner) PublicKeys() []iotago.MilestonePublicKey

+ func (s *InsecureRemoteEd25519MilestoneIndexSigner) PublicKeysSet() iotago.MilestonePublicKeySet

+ func (s *InsecureRemoteEd25519MilestoneIndexSigner) SigningFunc() iotago.MilestoneSigningFunc

+ type InsecureRemoteEd25519MilestoneSignerProvider struct

+ func NewInsecureRemoteEd25519MilestoneSignerProvider(remoteEndpoint string, keyManager *keymanager.KeyManager, publicKeysCount int) *InsecureRemoteEd25519MilestoneSignerProvider

+ func (p *InsecureRemoteEd25519MilestoneSignerProvider) MilestoneIndexSigner(index milestone.Index) MilestoneIndexSigner

+ func (p *InsecureRemoteEd25519MilestoneSignerProvider) PublicKeysCount() int

+ type MerkleTreeHash [iotago.MilestoneInclusionMerkleProofLength]byte

+ type MilestoneIndexSigner interface

+ PublicKeys func() []iotago.MilestonePublicKey

+ PublicKeysSet func() iotago.MilestonePublicKeySet

+ SigningFunc func() iotago.MilestoneSigningFunc

+ type MilestoneSignerProvider interface

+ MilestoneIndexSigner func(milestone.Index) MilestoneIndexSigner

+ PublicKeysCount func() int

+ type Option func(opts *Options)

+ func WithLogger(logger *logger.Logger) Option

+ func WithMilestoneInterval(milestoneInterval time.Duration) Option

+ func WithPoWWorkerCount(powWorkerCount int) Option

+ func WithQuorum(quorumEnabled bool, quorumGroups map[string][]*QuorumClientConfig, ...) Option

+ func WithSigningRetryAmount(amount int) Option

+ func WithSigningRetryTimeout(timeout time.Duration) Option

+ func WithStateFilePath(stateFilePath string) Option

+ type Options struct

+ type PublicKeyRange struct

+ EndIndex milestone.Index

+ Key string

+ StartIndex milestone.Index

+ type PublicKeyRanges []*PublicKeyRange

+ type QuorumClientConfig struct

+ Alias string

+ BaseURL string

+ Password string

+ UserName string

+ type QuorumClientStatistic struct

+ Alias string

+ BaseURL string

+ Error error

+ Group string

+ ResponseTimeSeconds float64

+ type QuorumFinishedResult struct

+ Duration time.Duration

+ Err error

+ type SendMessageFunc = func(msg *storage.Message, msIndex ...milestone.Index) error

type State

+ LatestMilestoneMessageID hornet.MessageID

+ func (cs *State) MarshalJSON() ([]byte, error)

+ func (cs *State) UnmarshalJSON(data []byte) error

v0

v0.5.10

Aug 9, 2023

v0.5.9

Aug 4, 2023

Changes in this version

+ var ErrInvalidSiblingsTrytesLength = errors.New("siblings trytes too long")

+ var ErrNetworkBootstrapped = errors.New("network already bootstrapped")

+ var ErrNoTipsGiven = errors.New("no tips given")

+ func CheckpointCaller(handler interface{}, params ...interface{})

+ func MilestoneCaller(handler interface{}, params ...interface{})

+ func MilestoneMerkleTreeHashFuncWithName(name string) crypto.Hash

+ type BackPressureFunc func() bool

+ type Coordinator struct

+ Events *CoordinatorEvents

+ func New(seed trinary.Hash, securityLvl consts.SecurityLevel, merkleTreeDepth int, ...) *Coordinator

+ func (coo *Coordinator) AddBackPressureFunc(bpFunc BackPressureFunc)

+ func (coo *Coordinator) Bootstrap() (hornet.Hash, error)

+ func (coo *Coordinator) GetInterval() time.Duration

+ func (coo *Coordinator) InitMerkleTree(filePath string, cooAddress trinary.Hash) error

+ func (coo *Coordinator) InitState(bootstrap bool, startIndex milestone.Index, forceAttachOnGenesis bool) error

+ func (coo *Coordinator) IssueCheckpoint(checkpointIndex int, lastCheckpointHash hornet.Hash, tips hornet.Hashes) (hornet.Hash, error)

+ func (coo *Coordinator) IssueMilestone(trunkHash hornet.Hash, branchHash hornet.Hash) (hornet.Hash, error, error)

+ func (coo *Coordinator) State() *State

+ type CoordinatorEvents struct

+ IssuedCheckpointTransaction *events.Event

+ IssuedMilestone *events.Event

+ type SendBundleFunc = func(b bundle.Bundle, isMilestone bool) error

+ type State struct

+ LatestMilestoneHash hornet.Hash

+ LatestMilestoneIndex milestone.Index

+ LatestMilestoneTime int64

+ LatestMilestoneTransactions hornet.Hashes

+ func (cs *State) MarshalBinary() (data []byte, err error)

+ func (cs *State) UnmarshalBinary(data []byte) error