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, error)
  • func (jc *JetCoordinator) IsAuthorized(ctx context.Context, role core.JetRole, obj core.RecordRef, ...) (bool, error)
  • func (jc *JetCoordinator) Link(components core.Components) error
  • func (jc *JetCoordinator) QueryRole(ctx context.Context, role core.JetRole, obj core.RecordRef, ...) ([]core.RecordRef, error)
• type JetNode
  • func (jn *JetNode) GetContaining(objRef *core.RecordRef) *core.RecordRef

Types

type JetCoordinator

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

JetCoordinator is responsible for all jet interactions

func NewJetCoordinator

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

NewJetCoordinator creates new coordinator instance.

func (*JetCoordinator) IsAuthorized

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

IsAuthorized checks for role on concrete pulse for the address.

func (*JetCoordinator) Link

func (jc *JetCoordinator) Link(components core.Components) error

func (*JetCoordinator) QueryRole

func (jc *JetCoordinator) QueryRole(
	ctx context.Context,
	role core.JetRole,
	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.