registrysyncer

Documentation

Index

• func New(lggr logger.Logger, peerWrapper p2ptypes.PeerWrapper, ...) (*registrySyncer, error)
• type Capability
• type DON
• type DonID
• type Launcher
• type LocalRegistry
  • func (l *LocalRegistry) ConfigForCapability(ctx context.Context, capabilityID string, donID uint32) (capabilities.CapabilityConfiguration, error)
  • func (l *LocalRegistry) LocalNode(ctx context.Context) (capabilities.Node, error)
• type Syncer

Functions

func New

func New(
	lggr logger.Logger,
	peerWrapper p2ptypes.PeerWrapper,
	relayer contractReaderFactory,
	registryAddress string,
) (*registrySyncer, error)

New instantiates a new RegistrySyncer

Types

type Capability

type Capability struct {
	ID             string
	CapabilityType capabilities.CapabilityType
}

type DON

type DON struct {
	capabilities.DON
	CapabilityConfigurations map[string]capabilities.CapabilityConfiguration
}

type DonID

type DonID uint32

type Launcher

type Launcher interface {
	Launch(ctx context.Context, registry *LocalRegistry) error
}

type LocalRegistry

type LocalRegistry struct {
	IDsToDONs         map[DonID]DON
	IDsToNodes        map[p2ptypes.PeerID]kcr.CapabilitiesRegistryNodeInfo
	IDsToCapabilities map[string]Capability
	// contains filtered or unexported fields
}

func (*LocalRegistry) ConfigForCapability

func (l *LocalRegistry) ConfigForCapability(ctx context.Context, capabilityID string, donID uint32) (capabilities.CapabilityConfiguration, error)

func (*LocalRegistry) LocalNode

func (l *LocalRegistry) LocalNode(ctx context.Context) (capabilities.Node, error)

type Syncer

type Syncer interface {
	services.Service
	AddLauncher(h ...Launcher)
}