core

Documentation

Index

• type Client
  • func NewClient(hosts []string, callTimeout time.Duration, logger *zap.Logger) *Client
  • func (n *Client) CoreNetworkParameters(ctx context.Context, parameterKey string) ([]*vega.NetworkParameter, error)
  • func (n *Client) DepositBuiltinAsset(ctx context.Context, vegaAssetId string, partyId string, amount string, ...) (bool, error)
  • func (n *Client) LastBlock(ctx context.Context) (*vegaapipb.LastBlockHeightResponse, error)
  • func (n *Client) MustDialConnection(ctx context.Context)
  • func (n *Client) MustDialConnectionIgnoreTime(ctx context.Context)
  • func (n *Client) SendTransaction(ctx context.Context, tx *commandspb.Transaction, ...) (*vegaapipb.SubmitTransactionResponse, error)
  • func (n *Client) Statistics(ctx context.Context) (*vegaapipb.StatisticsResponse, error)
  • func (n *Client) Target() string
  • func (n *Client) WaitForStateChange(ctx context.Context, state connectivity.State) bool

Types

type Client

type Client struct {
	CallTimeout time.Duration
	Conn        *grpc.ClientConn
	// contains filtered or unexported fields
}

Client stores state for a Vega Core node or Data Node.

func NewClient

func NewClient(hosts []string, callTimeout time.Duration, logger *zap.Logger) *Client

NewClient returns a new node.

func (*Client) CoreNetworkParameters

func (n *Client) CoreNetworkParameters(ctx context.Context, parameterKey string) ([]*vega.NetworkParameter, error)

func (*Client) DepositBuiltinAsset

func (n *Client) DepositBuiltinAsset(ctx context.Context, vegaAssetId string, partyId string, amount string, signAny func([]byte) ([]byte, string, error)) (bool, error)

func (*Client) LastBlock

func (n *Client) LastBlock(ctx context.Context) (*vegaapipb.LastBlockHeightResponse, error)

func (*Client) MustDialConnection

func (n *Client) MustDialConnection(ctx context.Context)

MustDialConnection tries to establish a connection to one of the nodes from a list of locations. It is idempotent, while it each call will block the caller until a connection is established.

func (*Client) MustDialConnectionIgnoreTime

func (n *Client) MustDialConnectionIgnoreTime(ctx context.Context)

func (*Client) SendTransaction

func (n *Client) SendTransaction(ctx context.Context, tx *commandspb.Transaction, reqType vegaapipb.SubmitTransactionRequest_Type) (*vegaapipb.SubmitTransactionResponse, error)

func (*Client) Statistics

func (n *Client) Statistics(ctx context.Context) (*vegaapipb.StatisticsResponse, error)

func (*Client) Target

func (n *Client) Target() string

func (*Client) WaitForStateChange

func (n *Client) WaitForStateChange(ctx context.Context, state connectivity.State) bool