capabilities

Documentation

Index

• func NewAggregator(name string, config values.Map, lggr logger.Logger) (types.Aggregator, error)
• func NewMockMercuryDataProducer(trigger *triggers.MercuryTriggerService, lggr logger.Logger) *mockMercuryDataProducer
• func NewRegistrySyncer(peerWrapper p2ptypes.PeerWrapper, registry core.CapabilitiesRegistry, ...) *registrySyncer
• type HardcodedDonNetworkSetup
  • func NewHardcodedDonNetworkSetup() (HardcodedDonNetworkSetup, error)
  • func (h HardcodedDonNetworkSetup) IsTargetDon(id p2ptypes.PeerID) bool
  • func (h HardcodedDonNetworkSetup) IsTriggerDon(id p2ptypes.PeerID) bool
  • func (h HardcodedDonNetworkSetup) IsWorkflowDon(id p2ptypes.PeerID) bool
• type Registry
  • func NewRegistry(lggr logger.Logger) *Registry
  • func (r *Registry) Add(ctx context.Context, c capabilities.BaseCapability) error
  • func (r *Registry) Get(_ context.Context, id string) (capabilities.BaseCapability, error)
  • func (r *Registry) GetAction(ctx context.Context, id string) (capabilities.ActionCapability, error)
  • func (r *Registry) GetConsensus(ctx context.Context, id string) (capabilities.ConsensusCapability, error)
  • func (r *Registry) GetTarget(ctx context.Context, id string) (capabilities.TargetCapability, error)
  • func (r *Registry) GetTrigger(ctx context.Context, id string) (capabilities.TriggerCapability, error)
  • func (r *Registry) List(_ context.Context) ([]capabilities.BaseCapability, error)

Functions

func NewAggregator

func NewAggregator(name string, config values.Map, lggr logger.Logger) (types.Aggregator, error)

func NewMockMercuryDataProducer

func NewMockMercuryDataProducer(trigger *triggers.MercuryTriggerService, lggr logger.Logger) *mockMercuryDataProducer

func NewRegistrySyncer

func NewRegistrySyncer(peerWrapper p2ptypes.PeerWrapper, registry core.CapabilitiesRegistry, dispatcher remotetypes.Dispatcher, lggr logger.Logger,
	networkSetup HardcodedDonNetworkSetup) *registrySyncer

RegistrySyncer updates local Registry to match its onchain counterpart

Types

type HardcodedDonNetworkSetup

type HardcodedDonNetworkSetup struct {
	WorkflowsDonInfo         capabilities.DON
	TriggerCapabilityDonInfo capabilities.DON
	TargetCapabilityDonInfo  capabilities.DON
	// contains filtered or unexported fields
}

HardcodedDonNetworkSetup is a temporary setup for testing purposes

func NewHardcodedDonNetworkSetup

func NewHardcodedDonNetworkSetup() (HardcodedDonNetworkSetup, error)

func (HardcodedDonNetworkSetup) IsTargetDon

func (h HardcodedDonNetworkSetup) IsTargetDon(id p2ptypes.PeerID) bool

func (HardcodedDonNetworkSetup) IsTriggerDon

func (h HardcodedDonNetworkSetup) IsTriggerDon(id p2ptypes.PeerID) bool

func (HardcodedDonNetworkSetup) IsWorkflowDon

func (h HardcodedDonNetworkSetup) IsWorkflowDon(id p2ptypes.PeerID) bool

type Registry

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

Registry is a struct for the registry of capabilities. Registry is safe for concurrent use.

func NewRegistry

func NewRegistry(lggr logger.Logger) *Registry

NewRegistry returns a new Registry.

func (*Registry) Add

func (r *Registry) Add(ctx context.Context, c capabilities.BaseCapability) error

Add adds a capability to the registry.

func (*Registry) Get

func (r *Registry) Get(_ context.Context, id string) (capabilities.BaseCapability, error)

Get gets a capability from the registry.

func (*Registry) GetAction

func (r *Registry) GetAction(ctx context.Context, id string) (capabilities.ActionCapability, error)

GetAction gets a capability from the registry and tries to coerce it to the ActionCapability interface.

func (*Registry) GetConsensus

func (r *Registry) GetConsensus(ctx context.Context, id string) (capabilities.ConsensusCapability, error)

GetConsensus gets a capability from the registry and tries to coerce it to the ConsensusCapability interface.

func (*Registry) GetTarget

func (r *Registry) GetTarget(ctx context.Context, id string) (capabilities.TargetCapability, error)

GetTarget gets a capability from the registry and tries to coerce it to the TargetCapability interface.

func (*Registry) GetTrigger

func (r *Registry) GetTrigger(ctx context.Context, id string) (capabilities.TriggerCapability, error)

GetTrigger gets a capability from the registry and tries to coerce it to the TriggerCapability interface.

func (*Registry) List

func (r *Registry) List(_ context.Context) ([]capabilities.BaseCapability, error)

List lists all the capabilities in the registry.