timelock

type HealthStatus ¶ added in v0.0.3

type HealthStatus int

HealthStatus represents the health status enum.

const (
	HealthStatusOK HealthStatus = iota
	HealthStatusError
)

func GetLiveStatus() HealthStatus

func GetReadyStatus() HealthStatus

type MockScheduler ¶ added in v0.1.0

type MockScheduler struct {
	mock.Mock
}

MockScheduler is an autogenerated mock type for the Scheduler type

func NewMockScheduler(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockScheduler

func (_m *MockScheduler) EXPECT() *MockScheduler_Expecter

type MockScheduler_Expecter ¶ added in v0.1.0

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

type MockScheduler_addToScheduler_Call ¶ added in v0.1.0

type MockScheduler_addToScheduler_Call struct {
	*mock.Call
}

MockScheduler_addToScheduler_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'addToScheduler'

func (_c *MockScheduler_addToScheduler_Call) Return() *MockScheduler_addToScheduler_Call

func (_c *MockScheduler_addToScheduler_Call) Run(run func(op TimelockCallScheduled)) *MockScheduler_addToScheduler_Call

func (_c *MockScheduler_addToScheduler_Call) RunAndReturn(run func(op TimelockCallScheduled)) *MockScheduler_addToScheduler_Call

type MockScheduler_delFromScheduler_Call ¶ added in v0.1.0

type MockScheduler_delFromScheduler_Call struct {
	*mock.Call
}

MockScheduler_delFromScheduler_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'delFromScheduler'

func (_c *MockScheduler_delFromScheduler_Call) Return() *MockScheduler_delFromScheduler_Call

func (_c *MockScheduler_delFromScheduler_Call) Run(run func(op operationKey)) *MockScheduler_delFromScheduler_Call

func (_c *MockScheduler_delFromScheduler_Call) RunAndReturn(run func(op operationKey)) *MockScheduler_delFromScheduler_Call

type MockScheduler_dumpOperationStore_Call ¶ added in v0.1.0

type MockScheduler_dumpOperationStore_Call struct {
	*mock.Call
}

MockScheduler_dumpOperationStore_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'dumpOperationStore'

func (_c *MockScheduler_dumpOperationStore_Call) Return() *MockScheduler_dumpOperationStore_Call

func (_c *MockScheduler_dumpOperationStore_Call) Run(run func(now func() time.Time)) *MockScheduler_dumpOperationStore_Call

func (_c *MockScheduler_dumpOperationStore_Call) RunAndReturn(run func(now func() time.Time)) *MockScheduler_dumpOperationStore_Call

type MockScheduler_runScheduler_Call ¶ added in v0.1.0

type MockScheduler_runScheduler_Call struct {
	*mock.Call
}

MockScheduler_runScheduler_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'runScheduler'

func (_c *MockScheduler_runScheduler_Call) Return(valCh <-chan struct{}) *MockScheduler_runScheduler_Call

func (_c *MockScheduler_runScheduler_Call) Run(run func(ctx context.Context)) *MockScheduler_runScheduler_Call

func (_c *MockScheduler_runScheduler_Call) RunAndReturn(run func(ctx context.Context) <-chan struct{}) *MockScheduler_runScheduler_Call

type Scheduler ¶ added in v0.0.7

type Scheduler interface {
	// contains filtered or unexported methods
}

type SolanaTimelockCallCancelledEvent ¶ added in v0.1.0

type SolanaTimelockCallCancelledEvent struct {
	ID operationKey
}

SolanaTimelockCallCancelledEvent corresponds to #[event] Cancelled { id }.

type SolanaTimelockCallExecutedEvent ¶ added in v0.1.0

type SolanaTimelockCallExecutedEvent struct {
	ID     operationKey
	Index  uint64
	Target solana.PublicKey
	Data   []byte
}

SolanaTimelockCallExecutedEvent corresponds to #[event] CallExecuted { id, index, target, data }.

type SolanaTimelockCallScheduledEvent ¶ added in v0.1.0

type SolanaTimelockCallScheduledEvent struct {
	ID          operationKey
	Index       uint64
	Target      solana.PublicKey
	Predecessor eth.Hash
	Salt        eth.Hash
	Delay       uint64
	Data        []byte
	BlockNumber *big.Int `borsh_skip:"true"`
	TxHash      string   `borsh_skip:"true"`
}

SolanaTimelockCallScheduledEvent corresponds to #[event] CallScheduled { id, index, target, predecessor, salt, delay, data }.

type SolanaTimelockEvents ¶ added in v0.1.0

type SolanaTimelockEvents struct {
	Scheduled []SolanaTimelockCallScheduledEvent
	Executed  []SolanaTimelockCallExecutedEvent
	Cancelled []SolanaTimelockCallCancelledEvent
}

TxTimelockEvents groups all decoded events from one transaction.

func ParseTimelockEvents(tx *rpc.TransactionWithMeta) (*SolanaTimelockEvents, error)

type TimelockCallScheduled ¶ added in v0.1.0

type TimelockCallScheduled interface {
	Id() operationKey
	Index() int
	BlockNumber() *big.Int
	TxHash() string
	Predecessor() eth.Hash
	Salt() eth.Hash
	String() string
}

func NewEVMTimelockCallScheduled(callScheduled *bindings.RBACTimelockCallScheduled) TimelockCallScheduled

func NewSolanaTimelockCallScheduled(callScheduledEvent SolanaTimelockCallScheduledEvent) TimelockCallScheduled

type Worker ¶

type Worker interface {
	Listen(ctx context.Context) error
}

type WorkerEVM ¶ added in v0.1.0

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

WorkerEVM represents an EVM worker instance. addresses is an array of addresses as expected by ethereum.FilterQuery, but it's enforced only to one addresses in the logic.

func NewTimelockWorkerEVM(
	nodeURL, timelockAddress, callProxyAddress, privateKey string, fromBlock *big.Int,
	maxGasLimit uint64, pollPeriod int64, listenerPollPeriod int64, pollSize uint64, dryRun bool,
	logger *zap.SugaredLogger,
) (*WorkerEVM, error)

func (tw *WorkerEVM) Listen(ctx context.Context) error

type WorkerSolana ¶ added in v0.1.0

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

WorkerSolana represents a solana worker instance. It fetches periodically the latest signatures and transactions from the Solana RPC node and dispatches them to the scheduler.

func NewTimelockWorkerSolana(
	nodeURL,
	timelockAddress,
	privateKey string,
	pollPeriod int64,
	listenerPollPeriod int64,
	pollSize int,
	dryRun bool,
	commitmentType rpc.CommitmentType,
	logger *zap.SugaredLogger,
) (*WorkerSolana, error)

func (w *WorkerSolana) Listen(ctx context.Context) error