chainservice

package

Go to main page

Versions in this module

v0

v0.1.2

Oct 9, 2023

Changes in this version

+ const MAX_BACKOFF_TIME

+ const MAX_EPOCHS

+ const MIN_BACKOFF_TIME

+ type ChainOpts struct

+ CaAddress common.Address

+ ChainAuthToken string

+ ChainPk string

+ ChainStartBlock uint64

+ ChainUrl string

+ NaAddress common.Address

+ VpaAddress common.Address

v0.1.1

Sep 14, 2023

Changes in this version

+ func NewEventTracker(startBlock uint64) *eventTracker

type AllocationUpdatedEvent

+ func (ce AllocationUpdatedEvent) TxIndex() uint

type ChainService

+ GetLastConfirmedBlockNum func() uint64

type ChallengeRegisteredEvent

+ func (ce ChallengeRegisteredEvent) TxIndex() uint

type ConcludedEvent

+ func (ce ConcludedEvent) TxIndex() uint

type DepositedEvent

+ func (ce DepositedEvent) TxIndex() uint

type EthChainService

+ func (ecs *EthChainService) GetLastConfirmedBlockNum() uint64

type Event

+ TxIndex func() uint

type MockChain

+ BlockNum uint64

type MockChainService

+ func (mc *MockChainService) GetLastConfirmedBlockNum() uint64

v0.1.0

Sep 1, 2023

Changes in this version

+ const MAX_QUERY_BLOCK_RANGE

+ const REQUIRED_BLOCK_CONFIRMATIONS

+ const RESUB_INTERVAL

+ const TEST_CHAIN_ID

+ var ErrUnableToAssignBigInt = errors.New("simulated_backend_chainservice: unable to assign BigInt")

+ func SetupSimulatedBackend(numAccounts uint64) (SimulatedChain, Bindings, []*bind.TransactOpts, error)

+ type AllocationUpdatedEvent struct

+ func NewAllocationUpdatedEvent(channelId types.Destination, blockNum uint64, assetAddress common.Address, ...) AllocationUpdatedEvent

+ func (aue AllocationUpdatedEvent) String() string

+ func (ce AllocationUpdatedEvent) BlockNum() uint64

+ func (ce AllocationUpdatedEvent) ChannelID() types.Destination

+ type BackendWrapper struct

+ func (b *BackendWrapper) ChainID(ctx context.Context) (*big.Int, error)

+ type Bindings struct

+ Adjudicator binding[NitroAdjudicator.NitroAdjudicator]

+ ConsensusApp binding[ConsensusApp.ConsensusApp]

+ Token binding[Token.Token]

+ VirtualPaymentApp binding[VirtualPaymentApp.VirtualPaymentApp]

+ type ChainEventHandler interface

+ UpdateWithChainEvent func(event Event) (protocols.Objective, error)

+ type ChainService interface

+ Close func() error

+ EventFeed func() <-chan Event

+ GetChainId func() (*big.Int, error)

+ GetConsensusAppAddress func() types.Address

+ GetVirtualPaymentAppAddress func() types.Address

+ SendTransaction func(protocols.ChainTransaction) error

+ func NewSimulatedBackendChainService(sim SimulatedChain, bindings Bindings, txSigner *bind.TransactOpts) (ChainService, error)

+ type ChallengeRegisteredEvent struct

+ func NewChallengeRegisteredEvent(channelId types.Destination, blockNum uint64, variablePart state.VariablePart, ...) ChallengeRegisteredEvent

+ func (ce ChallengeRegisteredEvent) BlockNum() uint64

+ func (ce ChallengeRegisteredEvent) ChannelID() types.Destination

+ func (cr ChallengeRegisteredEvent) Outcome() outcome.Exit

+ func (cr ChallengeRegisteredEvent) SignedState(fp state.FixedPart) (state.SignedState, error)

+ func (cr ChallengeRegisteredEvent) StateHash(fp state.FixedPart) (common.Hash, error)

+ func (cr ChallengeRegisteredEvent) String() string

+ type ConcludedEvent struct

+ func (ce ConcludedEvent) BlockNum() uint64

+ func (ce ConcludedEvent) ChannelID() types.Destination

+ func (ce ConcludedEvent) String() string

+ type DepositedEvent struct

+ Asset types.Address

+ NowHeld *big.Int

+ func NewDepositedEvent(channelId types.Destination, blockNum uint64, assetAddress common.Address, ...) DepositedEvent

+ func (ce DepositedEvent) BlockNum() uint64

+ func (ce DepositedEvent) ChannelID() types.Destination

+ func (de DepositedEvent) String() string

+ type EthChainService struct

+ func NewEthChainService(chainUrl, chainAuthToken, chainPk string, ...) (*EthChainService, error)

+ func (ecs *EthChainService) Close() error

+ func (ecs *EthChainService) EventFeed() <-chan Event

+ func (ecs *EthChainService) GetChainId() (*big.Int, error)

+ func (ecs *EthChainService) GetConsensusAppAddress() types.Address

+ func (ecs *EthChainService) GetVirtualPaymentAppAddress() types.Address

+ func (ecs *EthChainService) SendTransaction(tx protocols.ChainTransaction) error

+ type Event interface

+ BlockNum func() uint64

+ ChannelID func() types.Destination

+ type EventQueue []types.Log

+ func (q *EventQueue) Pop() interface{}

+ func (q *EventQueue) Push(x interface{})

+ func (q EventQueue) Len() int

+ func (q EventQueue) Less(i, j int) bool

+ func (q EventQueue) Swap(i, j int)

+ type MockChain struct

+ func NewMockChain() *MockChain

+ func (mc *MockChain) Close() error

+ func (mc *MockChain) SubmitTransaction(tx protocols.ChainTransaction) error

+ func (mc *MockChain) SubscribeToEvents(a types.Address) <-chan Event

+ type MockChainService struct

+ func NewMockChainService(chain *MockChain, address common.Address) *MockChainService

+ func (mc *MockChainService) Close() error

+ func (mc *MockChainService) EventFeed() <-chan Event

+ func (mc *MockChainService) GetChainId() (*big.Int, error)

+ func (mc *MockChainService) GetConsensusAppAddress() types.Address

+ func (mc *MockChainService) GetVirtualPaymentAppAddress() types.Address

+ func (mc *MockChainService) SendTransaction(tx protocols.ChainTransaction) error

+ type SimulatedBackendChainService struct

+ func (sbcs *SimulatedBackendChainService) GetConsensusAppAddress() types.Address

+ func (sbcs *SimulatedBackendChainService) GetVirtualPaymentAppAddress() types.Address

+ func (sbcs *SimulatedBackendChainService) SendTransaction(tx protocols.ChainTransaction) error

+ type SimulatedChain interface

+ Close func() error

+ Commit func() common.Hash

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL