jetcoordinator

Documentation

Overview

Package jetcoordinator is responsible for all jet manipulations.

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

Index

• Constants
• type JetCoordinator
  • func NewJetCoordinator() *JetCoordinator
  • func (jc *JetCoordinator) Heavy(ctx context.Context, pulse core.PulseNumber) (*core.RecordRef, error)
  • func (jc *JetCoordinator) IsAuthorized(ctx context.Context, role core.DynamicRole, obj core.RecordID, ...) (bool, error)
  • func (jc *JetCoordinator) LightExecutorForJet(ctx context.Context, jetID core.RecordID, pulse core.PulseNumber) (*core.RecordRef, error)
  • func (jc *JetCoordinator) LightExecutorForObject(ctx context.Context, objID core.RecordID, pulse core.PulseNumber) (*core.RecordRef, error)
  • func (jc *JetCoordinator) LightValidatorsForJet(ctx context.Context, jetID core.RecordID, pulse core.PulseNumber) ([]core.RecordRef, error)
  • func (jc *JetCoordinator) LightValidatorsForObject(ctx context.Context, objID core.RecordID, pulse core.PulseNumber) ([]core.RecordRef, error)
  • func (jc *JetCoordinator) Me() core.RecordRef
  • func (jc *JetCoordinator) QueryRole(ctx context.Context, role core.DynamicRole, objID core.RecordID, ...) ([]core.RecordRef, error)
  • func (jc *JetCoordinator) VirtualExecutorForObject(ctx context.Context, objID core.RecordID, pulse core.PulseNumber) (*core.RecordRef, error)
  • func (jc *JetCoordinator) VirtualValidatorsForObject(ctx context.Context, objID core.RecordID, pulse core.PulseNumber) ([]core.RecordRef, error)

Constants

const (
	VirtualValidatorCount  = 3
	MaterialValidatorCount = 3

	VirtualExecutorCount  = 1
	MaterialExecutorCount = 1
)

Hardcoded roles count for validation and execution

Types

type JetCoordinator

type JetCoordinator struct {
	NodeNet                    core.NodeNetwork                `inject:""`
	PlatformCryptographyScheme core.PlatformCryptographyScheme `inject:""`
	PulseStorage               core.PulseStorage               `inject:""`
	JetStorage                 storage.JetStorage              `inject:""`
	PulseTracker               storage.PulseTracker            `inject:""`
	storage.ActiveNodesStorage `inject:""`
}

JetCoordinator is responsible for all jet interactions

func NewJetCoordinator

func NewJetCoordinator() *JetCoordinator

NewJetCoordinator creates new coordinator instance.

func (*JetCoordinator) Heavy

func (jc *JetCoordinator) Heavy(ctx context.Context, pulse core.PulseNumber) (*core.RecordRef, error)

func (*JetCoordinator) IsAuthorized

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

IsAuthorized checks for role on concrete pulse for the address.

func (*JetCoordinator) LightExecutorForJet

func (jc *JetCoordinator) LightExecutorForJet(
	ctx context.Context, jetID core.RecordID, pulse core.PulseNumber,
) (*core.RecordRef, error)

func (*JetCoordinator) LightExecutorForObject

func (jc *JetCoordinator) LightExecutorForObject(
	ctx context.Context, objID core.RecordID, pulse core.PulseNumber,
) (*core.RecordRef, error)

func (*JetCoordinator) LightValidatorsForJet

func (jc *JetCoordinator) LightValidatorsForJet(
	ctx context.Context, jetID core.RecordID, pulse core.PulseNumber,
) ([]core.RecordRef, error)

func (*JetCoordinator) LightValidatorsForObject

func (jc *JetCoordinator) LightValidatorsForObject(
	ctx context.Context, objID core.RecordID, pulse core.PulseNumber,
) ([]core.RecordRef, error)

func (*JetCoordinator) Me

func (jc *JetCoordinator) Me() core.RecordRef

Me returns current node.

func (*JetCoordinator) QueryRole

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

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

func (*JetCoordinator) VirtualExecutorForObject

func (jc *JetCoordinator) VirtualExecutorForObject(
	ctx context.Context, objID core.RecordID, pulse core.PulseNumber,
) (*core.RecordRef, error)

func (*JetCoordinator) VirtualValidatorsForObject

func (jc *JetCoordinator) VirtualValidatorsForObject(
	ctx context.Context, objID core.RecordID, pulse core.PulseNumber,
) ([]core.RecordRef, error)