rpc

Documentation

Index

• Constants
• type Node
  • func NewNode(client *http.HTTP, options ...NodeOption) *Node
  • func (n *Node) ChainID() string
  • func (n *Node) IsRunning() bool
  • func (n *Node) IsSynced() bool
  • func (n *Node) Start(ctx context.Context)
  • func (n *Node) Started() chan struct{}
  • func (n *Node) Stop(ctx context.Context) error
  • func (n *Node) Subscribe(ctx context.Context, eventType string) (<-chan ctypes.ResultEvent, error)
• type NodeOption
  • func WithOnStart(onStart OnNodeStart) NodeOption
  • func WithOnStatus(onStatus OnNodeStatus) NodeOption
• type OnNodeStart
• type OnNodeStatus
• type Pool
  • func NewPool(nodes []*Node) *Pool
  • func (p *Pool) GetSyncedNode() *Node
  • func (p *Pool) Start(ctx context.Context) error
  • func (p *Pool) Started() chan struct{}
  • func (p *Pool) Stop(ctx context.Context) error

Constants

const (
	EventCompleteProposal    = "CompleteProposal"
	EventNewBlock            = "NewBlock"
	EventNewRound            = "NewRound"
	EventRoundState          = "RoundState"
	EventValidatorSetUpdates = "ValidatorSetUpdates"
	EventVote                = "Vote"
)

Types

type Node

type Node struct {
	Client *http.HTTP
	// contains filtered or unexported fields
}

func NewNode

func NewNode(client *http.HTTP, options ...NodeOption) *Node

func (*Node) ChainID

func (n *Node) ChainID() string

func (*Node) IsRunning

func (n *Node) IsRunning() bool

func (*Node) IsSynced

func (n *Node) IsSynced() bool

func (*Node) Start

func (n *Node) Start(ctx context.Context)

func (*Node) Started

func (n *Node) Started() chan struct{}

func (*Node) Stop

func (n *Node) Stop(ctx context.Context) error

func (*Node) Subscribe

func (n *Node) Subscribe(ctx context.Context, eventType string) (<-chan ctypes.ResultEvent, error)

type NodeOption

type NodeOption func(*Node)

func WithOnStart

func WithOnStart(onStart OnNodeStart) NodeOption

func WithOnStatus

func WithOnStatus(onStatus OnNodeStatus) NodeOption

type OnNodeStart

type OnNodeStart func(ctx context.Context, n *Node) error

type OnNodeStatus

type OnNodeStatus func(ctx context.Context, n *Node, status *ctypes.ResultStatus) error

type Pool

type Pool struct {
	Nodes []*Node
	// contains filtered or unexported fields
}

func NewPool

func NewPool(nodes []*Node) *Pool

func (*Pool) GetSyncedNode

func (p *Pool) GetSyncedNode() *Node

func (*Pool) Start

func (p *Pool) Start(ctx context.Context) error

func (*Pool) Started

func (p *Pool) Started() chan struct{}

func (*Pool) Stop

func (p *Pool) Stop(ctx context.Context) error