tendermint

package

v0.0.0-...-3cf9108 Latest Latest Go to latest Published: Jul 4, 2023 License: Apache-2.0 Imports: 6 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/axelarnetwork/tm-events

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func StartClient(address string, endpoint string) (client.Client, error)
type RobustClient
- func NewRobustClient(factory func() (client.Client, error)) *RobustClient

Constants ¶

View Source

const (
	DefaultWSEndpoint = "/websocket"
	DefaultAddress    = "http://localhost:26657"
)

default client parameters

Variables ¶

This section is empty.

Functions ¶

func StartClient ¶

func StartClient(address string, endpoint string) (client.Client, error)

StartClient connects a client to the given tendermint endpoint

Types ¶

type RobustClient ¶

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

RobustClient is a client that recreates the server connection of a connection failure occurs

func NewRobustClient ¶

func NewRobustClient(factory func() (client.Client, error)) *RobustClient

NewRobustClient returns a new RobustClient instance

func (*RobustClient) BlockResults ¶

func (r *RobustClient) BlockResults(ctx context.Context, height *int64) (results *coretypes.ResultBlockResults, err error)

BlockResults returns the all results of the block of given height

func (*RobustClient) LatestSyncInfo ¶

func (r *RobustClient) LatestSyncInfo(ctx context.Context) (*coretypes.SyncInfo, error)

LatestSyncInfo returns the sync info of the node

func (*RobustClient) Stop ¶

func (r *RobustClient) Stop() error

Stop stops the client and closes the server connection

func (r *RobustClient) Subscribe(ctx context.Context, subscriber, query string, outCapacity ...int) (out <-chan coretypes.ResultEvent, err error)

Subscribe subscribes to the given query

func (*RobustClient) Unsubscribe ¶

func (r *RobustClient) Unsubscribe(ctx context.Context, subscriber, query string) error

Unsubscribe unsubsribes the given query, if a subscription exists

Source Files ¶

View all Source files

client.go

Directories ¶

Path	Synopsis
mock

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL