jetcoordinator

Documentation

Overview

Package jetcoordinator is responsible for all jet manipulations.

Package responsible for jet drops, split/merge jets, choose of validators.

Index

• type JetCoordinator
  • func NewJetCoordinator(db *storage.DB, conf configuration.JetCoordinator) *JetCoordinator
  • func (jc *JetCoordinator) GetActiveNodes(pulse core.PulseNumber) ([]core.Node, error)
  • func (jc *JetCoordinator) IsAuthorized(ctx context.Context, role core.DynamicRole, obj *core.RecordRef, ...) (bool, error)
  • func (jc *JetCoordinator) QueryRole(ctx context.Context, role core.DynamicRole, obj *core.RecordRef, ...) ([]core.RecordRef, error)
• type JetNode
  • func (jn *JetNode) GetContaining(objRef *core.RecordRef) *core.RecordRef

Types

type JetCoordinator

type JetCoordinator struct {
	NodeNet                    core.NodeNetwork                `inject:""`
	PlatformCryptographyScheme core.PlatformCryptographyScheme `inject:""`
	// contains filtered or unexported fields
}

JetCoordinator is responsible for all jet interactions

func NewJetCoordinator

func NewJetCoordinator(db *storage.DB, conf configuration.JetCoordinator) *JetCoordinator

NewJetCoordinator creates new coordinator instance.

func (*JetCoordinator) GetActiveNodes

func (jc *JetCoordinator) GetActiveNodes(pulse core.PulseNumber) ([]core.Node, error)

GetActiveNodes return active nodes for specified pulse.

func (*JetCoordinator) IsAuthorized

func (jc *JetCoordinator) IsAuthorized(
	ctx context.Context,
	role core.DynamicRole,
	obj *core.RecordRef,
	pulse core.PulseNumber,
	node core.RecordRef,
) (bool, error)

IsAuthorized checks for role on concrete pulse for the address.

func (*JetCoordinator) QueryRole

func (jc *JetCoordinator) QueryRole(
	ctx context.Context,
	role core.DynamicRole,
	obj *core.RecordRef,
	pulse core.PulseNumber,
) ([]core.RecordRef, error)

QueryRole returns node refs responsible for role bound operations for given object and pulse.

type JetNode

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

JetNode represents node in Jet tree.

func (*JetNode) GetContaining

func (jn *JetNode) GetContaining(objRef *core.RecordRef) *core.RecordRef

GetContaining returns leaf node reference. Leaf node is a jet host for provided objRef.