eth

type Client interface {
	EstimateGas(context.Context, ethereum.CallMsg) (uint64, error)
	GetExpiry(context.Context, common.Address) (uint64, error)
	GetPublicKey(context.Context, common.Address) (PublicKey, error)
	NonceAt(context.Context, common.Address) (uint64, error)
	SendTransaction(context.Context, *types.Transaction) (SendTransactionResponse, error)
	SubscribeFilterLogs(context.Context, ethereum.FilterQuery, chan<- types.Log) (ethereum.Subscription, error)
	TransactionReceipt(ctx context.Context, txHash common.Hash) (*types.Receipt, error)
	BalanceAt(ctx context.Context, account common.Address, blockNumber *big.Int) (*big.Int, error)
	GetCode(ctx context.Context, addr common.Address) (string, error)
}

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

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

type LogSubscriber struct {
	FilterQuery ethereum.FilterQuery
	BlockNumber uint64
	Index       uint
	// contains filtered or unexported fields
}

type Pool interface {
	Conn(context.Context) (*Conn, error)
	Report(context.Context, *Conn) error
}

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

type PooledClientProps struct {
	Pool        Pool
	RetryConfig concurrent.RetryConfig
}

type PublicKey struct {
	Timestamp uint64 `json:"timestamp"`
	PublicKey string `json:"public_key"`
	Signature string `json:"signature"`
}

type SendTransactionResponse struct {
	Output string `json:"output"`
	Status uint64 `json:"status"`
	Hash   string `json:"transactionHash"`
}

type Subscriber interface {
	// Subscribe creates a subscription and forwards the received
	// events on the provided channel
	Subscribe(context.Context, Client, chan<- interface{}) (ethereum.Subscription, error)
}

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

type SubscriptionEndEvent struct {
	// Key uniquely identifies a subscription. It is provided by the
	// supervisor
	Key string

	// Error in case the subscription ended because of an error
	Error error
}

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

type SubscriptionManagerProps struct {
	// Context used by the manager and that can be used
	// to signal a cancellation
	Context context.Context

	// Logger used by the manager and its subscriptions
	Logger log.Logger

	// Client to make requests
	Client Client
}

type SubscriptionProps struct {
	// Logger used by the subscription
	Logger log.Logger

	// Client to make requests
	Client Client

	// URL to dial to for the subscription. Must be a ws URL since
	// other provides may not support creating subscriptions
	URL string

	// Key uniquely identifies a subscription and it can be used to
	// notify the subscription supervisor
	Key string

	// Subscriber used to create the subscription
	Subscriber Subscriber

	// C channel to receive the events for a subscription
	C chan<- interface{}
}

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

type UniDialerProps struct {
	URL         string
	RetryConfig concurrent.RetryConfig
}