node

Documentation

Index

• Variables
• type ErrorCode
• type Forwarder
  • func NewForwarder(log *zap.Logger, nodeConfigs network.GRPCConfig) (*Forwarder, error)
  • func (n *Forwarder) CheckTx(ctx context.Context, tx *commandspb.Transaction, cltIdx int) (*api.CheckTransactionResponse, error)
  • func (n *Forwarder) HealthCheck(ctx context.Context) error
  • func (n *Forwarder) LastBlockHeightAndHash(ctx context.Context) (*api.LastBlockHeightResponse, int, error)
  • func (n *Forwarder) SendTx(ctx context.Context, tx *commandspb.Transaction, ...) (string, error)
  • func (n *Forwarder) Stop() error
• type StatusError
  • func (e *StatusError) Error() string

Variables

var ErrNoHostSpecified = errors.New("no host specified")

Types

type ErrorCode

type ErrorCode codes.Code

type Forwarder

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

func NewForwarder

func NewForwarder(log *zap.Logger, nodeConfigs network.GRPCConfig) (*Forwarder, error)

func (*Forwarder) CheckTx

func (n *Forwarder) CheckTx(ctx context.Context, tx *commandspb.Transaction, cltIdx int) (*api.CheckTransactionResponse, error)

func (*Forwarder) HealthCheck

func (n *Forwarder) HealthCheck(ctx context.Context) error

func (*Forwarder) LastBlockHeightAndHash

func (n *Forwarder) LastBlockHeightAndHash(ctx context.Context) (*api.LastBlockHeightResponse, int, error)

LastBlockHeightAndHash returns information about the last block from vega and the node it used to fetch it.

func (*Forwarder) SendTx

func (n *Forwarder) SendTx(ctx context.Context, tx *commandspb.Transaction, ty api.SubmitTransactionRequest_Type, cltIdx int) (string, error)

func (*Forwarder) Stop

func (n *Forwarder) Stop() error

type StatusError

type StatusError struct {
	Code    codes.Code
	Details []string
}

func (*StatusError) Error

func (e *StatusError) Error() string