pool

type ClientRequest struct {
	Kind string `json:"kind"`
}

type ClientResponse struct {
	// Hosts that have whitelisted the client NodeID and are ready for the
	// client to connect.
	Hosts []store.Node `json:"hosts"`
	// PoolVersion is the version of vipnode-pool that is running.
	PoolVersion string `json:"pool_version"`
	// Message contains a prompt for the client from the pool, possibly
	// instructions for interfacing with this pool. For example, a link to the
	// DApp for adding a balance deposit.
	Message string `json:"message,omitempty"`
}

type HostRequest struct {
	// Kind is the type of node the host supports: geth, parity
	Kind string `json:"kind"`
	// Payout sets the wallet account to register the host credit towards.
	Payout string `json:"payout"`
	// Optional public node URI override, useful if the vipnode agent runs on a
	// separate IP from the actual node host. Otherwise, the pool will
	// automatically use the same IP and default port as the host connecting.
	NodeURI string `json:"node_uri,omitempty"`
}

type HostResponse struct {
	PoolVersion string `json:"pool_version"`
}

type NoHostNodesError struct {
	NumTried int
}

type Pool interface {
	// Host subscribes a host to receive vipnode_whitelist instructions.
	Host(ctx context.Context, req HostRequest) (*HostResponse, error)

	// Client requests for available hosts to connect to as a client.
	Client(ctx context.Context, req ClientRequest) (*ClientResponse, error)

	// Disconnect stops tracking the connection and billing, will prompt a
	// disconnect from both ends.
	Disconnect(ctx context.Context) error

	// Update is a keep-alive for sharing the node's peering info. It returns
	// a list of peers that are no longer corroborated by the pool, and current
	// balance for the node (if relevant).
	Update(ctx context.Context, req UpdateRequest) (*UpdateResponse, error)

	// Withdraw prompts a request to settle the node's balance.
	Withdraw(ctx context.Context) error
}

type RemoteHostErrors struct {
	Method string
	Errors []error
}

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

type StaticPool struct {
	Nodes []store.Node
}

type UpdateRequest struct {
	Peers       []string `json:"peers"`
	BlockNumber uint64   `json:"block_number"`
}

type UpdateResponse struct {
	Balance      *store.Balance `json:"balance,omitempty"`
	InvalidPeers []string       `json:"invalid_peers"`
}

type VerifyFailedError struct {
	Cause  error
	Method string
}

type VipnodePool struct {
	// Version is returned as the PoolVersion in the ClientResponse when a new client connects.
	Version string

	Store          store.Store
	BalanceManager balance.Manager
	ClientMessager func(nodeID string) string
	// contains filtered or unexported fields
}