Documentation
¶
Index ¶
- Variables
- func ExtractLimits(w *cresettings.Workflows) chain.Limits
- func RunRPCHealthCheck(clients map[uint64]chain.ChainClient, experimentalSelectors map[uint64]bool) error
- type LimitedStellarChain
- func (l *LimitedStellarChain) ChainSelector() uint64
- func (l *LimitedStellarChain) Close() error
- func (l *LimitedStellarChain) Description() string
- func (l *LimitedStellarChain) GetLatestLedger(ctx context.Context, m commonCap.RequestMetadata, ...) (*commonCap.ResponseAndMetadata[*stellarcap.GetLatestLedgerResponse], ...)
- func (l *LimitedStellarChain) HealthReport() map[string]error
- func (l *LimitedStellarChain) Initialise(ctx context.Context, deps core.StandardCapabilitiesDependencies) error
- func (l *LimitedStellarChain) Name() string
- func (l *LimitedStellarChain) ReadContract(ctx context.Context, m commonCap.RequestMetadata, ...) (*commonCap.ResponseAndMetadata[*stellarcap.ReadContractResponse], ...)
- func (l *LimitedStellarChain) Ready() error
- func (l *LimitedStellarChain) Start(ctx context.Context) error
- func (l *LimitedStellarChain) WriteReport(ctx context.Context, metadata commonCap.RequestMetadata, ...) (*commonCap.ResponseAndMetadata[*stellarcap.WriteReportReply], caperrors.Error)
- type StellarChainType
- func (ct *StellarChainType) CollectCLIInputs(*viper.Viper) map[string]string
- func (ct *StellarChainType) ExecuteTrigger(context.Context, uint64, string, interface{}) error
- func (ct *StellarChainType) Name() string
- func (ct *StellarChainType) ParseTriggerChainSelector(triggerID string) (uint64, bool)
- func (ct *StellarChainType) RegisterCapabilities(ctx context.Context, cfg chain.CapabilityConfig) (_ []services.Service, err error)
- func (ct *StellarChainType) ResolveClients(v *viper.Viper) (chain.ResolvedChains, error)
- func (ct *StellarChainType) ResolveKey(s *settings.Settings, broadcast bool) (interface{}, error)
- func (ct *StellarChainType) ResolveTriggerData(context.Context, uint64, chain.TriggerParams) (interface{}, error)
- func (ct *StellarChainType) RunHealthCheck(resolved chain.ResolvedChains) error
- func (ct *StellarChainType) SupportedChains() []chain.ChainConfig
- func (ct *StellarChainType) Supports(selector uint64) bool
Constants ¶
This section is empty.
Variables ¶
var SupportedChains = []chain.ChainConfig{ {Selector: chainselectors.STELLAR_TESTNET.Selector, Forwarder: testnetMockForwarder}, {Selector: chainselectors.STELLAR_MAINNET.Selector, Forwarder: mainnetMockForwarder}, }
SupportedChains lists Stellar networks cre-cli simulate can target.
Functions ¶
func ExtractLimits ¶
func ExtractLimits(w *cresettings.Workflows) chain.Limits
ExtractLimits maps workflow limits onto Stellar writes. cresettings has no Stellar-specific chain-write block, so the generic report size limit applies.
func RunRPCHealthCheck ¶
func RunRPCHealthCheck(clients map[uint64]chain.ChainClient, experimentalSelectors map[uint64]bool) error
RunRPCHealthCheck probes getHealth on every configured Stellar RPC client. experimentalSelectors identifies chains sourced from experimental-chains config.
Types ¶
type LimitedStellarChain ¶
type LimitedStellarChain struct {
// contains filtered or unexported fields
}
LimitedStellarChain enforces the chain-write report size limit.
func NewLimitedStellarChain ¶
func NewLimitedStellarChain(inner stellarserver.ClientCapability, limits chain.Limits) *LimitedStellarChain
func (*LimitedStellarChain) ChainSelector ¶
func (l *LimitedStellarChain) ChainSelector() uint64
func (*LimitedStellarChain) Close ¶
func (l *LimitedStellarChain) Close() error
func (*LimitedStellarChain) Description ¶
func (l *LimitedStellarChain) Description() string
func (*LimitedStellarChain) GetLatestLedger ¶
func (l *LimitedStellarChain) GetLatestLedger(ctx context.Context, m commonCap.RequestMetadata, i *stellarcap.GetLatestLedgerRequest) (*commonCap.ResponseAndMetadata[*stellarcap.GetLatestLedgerResponse], caperrors.Error)
func (*LimitedStellarChain) HealthReport ¶
func (l *LimitedStellarChain) HealthReport() map[string]error
func (*LimitedStellarChain) Initialise ¶
func (l *LimitedStellarChain) Initialise(ctx context.Context, deps core.StandardCapabilitiesDependencies) error
func (*LimitedStellarChain) Name ¶
func (l *LimitedStellarChain) Name() string
func (*LimitedStellarChain) ReadContract ¶
func (l *LimitedStellarChain) ReadContract(ctx context.Context, m commonCap.RequestMetadata, i *stellarcap.ReadContractRequest) (*commonCap.ResponseAndMetadata[*stellarcap.ReadContractResponse], caperrors.Error)
func (*LimitedStellarChain) Ready ¶
func (l *LimitedStellarChain) Ready() error
func (*LimitedStellarChain) WriteReport ¶
func (l *LimitedStellarChain) WriteReport(ctx context.Context, metadata commonCap.RequestMetadata, input *stellarcap.WriteReportRequest) (*commonCap.ResponseAndMetadata[*stellarcap.WriteReportReply], caperrors.Error)
type StellarChainType ¶
type StellarChainType struct {
// contains filtered or unexported fields
}
StellarChainType implements chain.ChainType for Stellar (Soroban) on top of chainlink-stellar's FakeStellarChain. Writes go through the mock forwarder: simulated by default, submitted with --broadcast.
func (*StellarChainType) CollectCLIInputs ¶
func (ct *StellarChainType) CollectCLIInputs(*viper.Viper) map[string]string
func (*StellarChainType) ExecuteTrigger ¶
func (*StellarChainType) Name ¶
func (ct *StellarChainType) Name() string
func (*StellarChainType) ParseTriggerChainSelector ¶
func (ct *StellarChainType) ParseTriggerChainSelector(triggerID string) (uint64, bool)
func (*StellarChainType) RegisterCapabilities ¶
func (ct *StellarChainType) RegisterCapabilities(ctx context.Context, cfg chain.CapabilityConfig) (_ []services.Service, err error)
func (*StellarChainType) ResolveClients ¶
func (ct *StellarChainType) ResolveClients(v *viper.Viper) (chain.ResolvedChains, error)
func (*StellarChainType) ResolveKey ¶
func (ct *StellarChainType) ResolveKey(s *settings.Settings, broadcast bool) (interface{}, error)
ResolveKey parses CRE_STELLAR_PRIVATE_KEY (an S… secret seed). It is required with --broadcast; dry-run simulation works without one.
func (*StellarChainType) ResolveTriggerData ¶
func (ct *StellarChainType) ResolveTriggerData(context.Context, uint64, chain.TriggerParams) (interface{}, error)
func (*StellarChainType) RunHealthCheck ¶
func (ct *StellarChainType) RunHealthCheck(resolved chain.ResolvedChains) error
func (*StellarChainType) SupportedChains ¶
func (ct *StellarChainType) SupportedChains() []chain.ChainConfig
func (*StellarChainType) Supports ¶
func (ct *StellarChainType) Supports(selector uint64) bool