rpc

Documentation

Index

• Constants
• type Node
  • func NewNode(client *http.HTTP, options ...NodeOption) *Node
  • func (n *Node) ChainID() string
  • func (n *Node) Endpoint() string
  • func (n *Node) IsRunning() bool
  • func (n *Node) IsSynced() bool
  • func (n *Node) OnEvent(eventType string, callback OnNodeEvent)
  • func (n *Node) OnStart(callback OnNodeStart)
  • func (n *Node) OnStatus(callback OnNodeStatus)
  • func (n *Node) Redacted() string
  • func (n *Node) Start(ctx context.Context) error
  • func (n *Node) Started() chan struct{}
  • func (n *Node) Status(ctx context.Context) (*ctypes.ResultStatus, error)
  • func (n *Node) Stop(ctx context.Context) error
  • func (n *Node) Subscribe(ctx context.Context, eventType string) (<-chan ctypes.ResultEvent, error)
• type NodeOption
  • func DisableWebsocket() NodeOption
• type OnNodeEvent
• type OnNodeStart
• type OnNodeStatus
• type Pool
  • func NewPool(chainID string, 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) Endpoint

func (n *Node) Endpoint() string

func (*Node) IsRunning

func (n *Node) IsRunning() bool

func (*Node) IsSynced

func (n *Node) IsSynced() bool

func (*Node) OnEvent

func (n *Node) OnEvent(eventType string, callback OnNodeEvent)

func (*Node) OnStart

func (n *Node) OnStart(callback OnNodeStart)

func (*Node) OnStatus

func (n *Node) OnStatus(callback OnNodeStatus)

func (*Node) Redacted

func (n *Node) Redacted() string

func (*Node) Start

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

func (*Node) Started

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

func (*Node) Status

func (n *Node) Status(ctx context.Context) (*ctypes.ResultStatus, error)

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 DisableWebsocket

func DisableWebsocket() NodeOption

type OnNodeEvent

type OnNodeEvent func(ctx context.Context, n *Node, event *ctypes.ResultEvent) error

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 {
	ChainID string
	Nodes   []*Node
	// contains filtered or unexported fields
}

func NewPool

func NewPool(chainID string, 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