sdk

package module
v0.0.0-...-86db3f4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 16, 2025 License: Apache-2.0 Imports: 17 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func HandleError 

func HandleError(err error)

Types

type ClientOption 

type ClientOption func(*UtxorpcClient)

func WithBaseUrl 

func WithBaseUrl(baseUrl string) ClientOption

func WithHeaders 

func WithHeaders(headers map[string]string) ClientOption

func WithHttpClient 

func WithHttpClient(httpClient connect.HTTPClient) ClientOption

type QueryServiceClient 

type QueryServiceClient = queryconnect.QueryServiceClient

func NewQueryServiceClient 

func NewQueryServiceClient(u *UtxorpcClient) QueryServiceClient

type SubmitServiceClient 

type SubmitServiceClient = submitconnect.SubmitServiceClient

type SyncServiceClient 

type SyncServiceClient = syncconnect.SyncServiceClient

func NewSyncServiceClient 

func NewSyncServiceClient(u *UtxorpcClient) SyncServiceClient

type UtxorpcClient 

type UtxorpcClient struct {
	Query  QueryServiceClient
	Submit SubmitServiceClient
	Sync   SyncServiceClient
	Watch  WatchServiceClient
	// contains filtered or unexported fields
}

func NewClient 

func NewClient(options ...ClientOption) *UtxorpcClient

func (*UtxorpcClient) AddHeadersToRequest 

func (u *UtxorpcClient) AddHeadersToRequest(req connect.AnyRequest)

func (*UtxorpcClient) EvalTx 

func (u *UtxorpcClient) EvalTx(
	req *connect.Request[submit.EvalTxRequest],
) (*connect.Response[submit.EvalTxResponse], error)

func (*UtxorpcClient) EvalTxWithContext 

func (u *UtxorpcClient) EvalTxWithContext(
	ctx context.Context,
	req *connect.Request[submit.EvalTxRequest],
) (*connect.Response[submit.EvalTxResponse], error)

func (*UtxorpcClient) FetchBlock 

func (u *UtxorpcClient) FetchBlock(
	req *connect.Request[sync.FetchBlockRequest],
) (*connect.Response[sync.FetchBlockResponse], error)

func (*UtxorpcClient) FetchBlockWithContext 

func (u *UtxorpcClient) FetchBlockWithContext(
	ctx context.Context,
	req *connect.Request[sync.FetchBlockRequest],
) (*connect.Response[sync.FetchBlockResponse], error)

func (*UtxorpcClient) FollowTip 

func (u *UtxorpcClient) FollowTip(
	req *connect.Request[sync.FollowTipRequest],
) (*connect.ServerStreamForClient[sync.FollowTipResponse], error)

func (*UtxorpcClient) FollowTipWithContext 

func (u *UtxorpcClient) FollowTipWithContext(
	ctx context.Context,
	req *connect.Request[sync.FollowTipRequest],
) (*connect.ServerStreamForClient[sync.FollowTipResponse], error)

func (*UtxorpcClient) HTTPClient 

func (u *UtxorpcClient) HTTPClient() connect.HTTPClient

func (*UtxorpcClient) Headers 

func (u *UtxorpcClient) Headers() map[string]string

func (*UtxorpcClient) NewQueryServiceClient 

func (u *UtxorpcClient) NewQueryServiceClient() QueryServiceClient

func (*UtxorpcClient) NewSubmitServiceClient 

func (u *UtxorpcClient) NewSubmitServiceClient() SubmitServiceClient

func (*UtxorpcClient) NewSyncServiceClient 

func (u *UtxorpcClient) NewSyncServiceClient() SyncServiceClient

func (*UtxorpcClient) NewWatchServiceClient 

func (u *UtxorpcClient) NewWatchServiceClient() WatchServiceClient

func (*UtxorpcClient) QueryService 

func (u *UtxorpcClient) QueryService() QueryServiceClient

func (*UtxorpcClient) ReadData 

func (u *UtxorpcClient) ReadData(
	req *connect.Request[query.ReadDataRequest],
) (*connect.Response[query.ReadDataResponse], error)

func (*UtxorpcClient) ReadDataWithContext 

func (u *UtxorpcClient) ReadDataWithContext(
	ctx context.Context,
	req *connect.Request[query.ReadDataRequest],
) (*connect.Response[query.ReadDataResponse], error)

func (*UtxorpcClient) ReadEraSummary 

func (u *UtxorpcClient) ReadEraSummary(
	req *connect.Request[query.ReadEraSummaryRequest],
) (*connect.Response[query.ReadEraSummaryResponse], error)

func (*UtxorpcClient) ReadEraSummaryWithContext 

func (u *UtxorpcClient) ReadEraSummaryWithContext(
	ctx context.Context,
	req *connect.Request[query.ReadEraSummaryRequest],
) (*connect.Response[query.ReadEraSummaryResponse], error)

func (*UtxorpcClient) ReadGenesis 

func (u *UtxorpcClient) ReadGenesis(
	req *connect.Request[query.ReadGenesisRequest],
) (*connect.Response[query.ReadGenesisResponse], error)

func (*UtxorpcClient) ReadGenesisWithContext 

func (u *UtxorpcClient) ReadGenesisWithContext(
	ctx context.Context,
	req *connect.Request[query.ReadGenesisRequest],
) (*connect.Response[query.ReadGenesisResponse], error)

func (*UtxorpcClient) ReadMempool 

func (u *UtxorpcClient) ReadMempool(
	req *connect.Request[submit.ReadMempoolRequest],
) (*connect.Response[submit.ReadMempoolResponse], error)

func (*UtxorpcClient) ReadMempoolWithContext 

func (u *UtxorpcClient) ReadMempoolWithContext(
	ctx context.Context,
	req *connect.Request[submit.ReadMempoolRequest],
) (*connect.Response[submit.ReadMempoolResponse], error)

func (*UtxorpcClient) ReadParams 

func (u *UtxorpcClient) ReadParams(
	req *connect.Request[query.ReadParamsRequest],
) (*connect.Response[query.ReadParamsResponse], error)

func (*UtxorpcClient) ReadParamsWithContext 

func (u *UtxorpcClient) ReadParamsWithContext(
	ctx context.Context,
	req *connect.Request[query.ReadParamsRequest],
) (*connect.Response[query.ReadParamsResponse], error)

func (*UtxorpcClient) ReadTip 

func (u *UtxorpcClient) ReadTip(
	req *connect.Request[sync.ReadTipRequest],
) (*connect.Response[sync.ReadTipResponse], error)

func (*UtxorpcClient) ReadTipWithContext 

func (u *UtxorpcClient) ReadTipWithContext(
	ctx context.Context,
	req *connect.Request[sync.ReadTipRequest],
) (*connect.Response[sync.ReadTipResponse], error)

func (*UtxorpcClient) ReadTx 

func (u *UtxorpcClient) ReadTx(
	req *connect.Request[query.ReadTxRequest],
) (*connect.Response[query.ReadTxResponse], error)

func (*UtxorpcClient) ReadTxWithContext 

func (u *UtxorpcClient) ReadTxWithContext(
	ctx context.Context,
	req *connect.Request[query.ReadTxRequest],
) (*connect.Response[query.ReadTxResponse], error)

func (*UtxorpcClient) ReadUtxos 

func (u *UtxorpcClient) ReadUtxos(
	req *connect.Request[query.ReadUtxosRequest],
) (*connect.Response[query.ReadUtxosResponse], error)

func (*UtxorpcClient) ReadUtxosWithContext 

func (u *UtxorpcClient) ReadUtxosWithContext(
	ctx context.Context,
	req *connect.Request[query.ReadUtxosRequest],
) (*connect.Response[query.ReadUtxosResponse], error)

func (*UtxorpcClient) RemoveHeader 

func (u *UtxorpcClient) RemoveHeader(key string)

func (*UtxorpcClient) SearchUtxos 

func (u *UtxorpcClient) SearchUtxos(
	req *connect.Request[query.SearchUtxosRequest],
) (*connect.Response[query.SearchUtxosResponse], error)

func (*UtxorpcClient) SearchUtxosWithContext 

func (u *UtxorpcClient) SearchUtxosWithContext(
	ctx context.Context,
	req *connect.Request[query.SearchUtxosRequest],
) (*connect.Response[query.SearchUtxosResponse], error)

func (*UtxorpcClient) SetHeader 

func (u *UtxorpcClient) SetHeader(key, value string)

func (*UtxorpcClient) SetHeaders 

func (u *UtxorpcClient) SetHeaders(headers map[string]string)

func (*UtxorpcClient) SetURL 

func (u *UtxorpcClient) SetURL(baseUrl string)

func (*UtxorpcClient) SubmitTx 

func (u *UtxorpcClient) SubmitTx(
	req *connect.Request[submit.SubmitTxRequest],
) (*connect.Response[submit.SubmitTxResponse], error)

func (*UtxorpcClient) SubmitTxWithContext 

func (u *UtxorpcClient) SubmitTxWithContext(
	ctx context.Context,
	req *connect.Request[submit.SubmitTxRequest],
) (*connect.Response[submit.SubmitTxResponse], error)

func (*UtxorpcClient) URL 

func (u *UtxorpcClient) URL() string

func (*UtxorpcClient) WaitForTx 

func (u *UtxorpcClient) WaitForTx(
	req *connect.Request[submit.WaitForTxRequest],
) (*connect.ServerStreamForClient[submit.WaitForTxResponse], error)

func (*UtxorpcClient) WaitForTxWithContext 

func (u *UtxorpcClient) WaitForTxWithContext(
	ctx context.Context,
	req *connect.Request[submit.WaitForTxRequest],
) (*connect.ServerStreamForClient[submit.WaitForTxResponse], error)

func (*UtxorpcClient) WatchMempool 

func (u *UtxorpcClient) WatchMempool(
	req *connect.Request[submit.WatchMempoolRequest],
) (*connect.ServerStreamForClient[submit.WatchMempoolResponse], error)

func (*UtxorpcClient) WatchMempoolWithContext 

func (u *UtxorpcClient) WatchMempoolWithContext(
	ctx context.Context,
	req *connect.Request[submit.WatchMempoolRequest],
) (*connect.ServerStreamForClient[submit.WatchMempoolResponse], error)

func (*UtxorpcClient) WatchTx 

func (u *UtxorpcClient) WatchTx(
	req *connect.Request[watch.WatchTxRequest],
) (*connect.ServerStreamForClient[watch.WatchTxResponse], error)

func (*UtxorpcClient) WatchTxWithContext 

func (u *UtxorpcClient) WatchTxWithContext(
	ctx context.Context,
	req *connect.Request[watch.WatchTxRequest],
) (*connect.ServerStreamForClient[watch.WatchTxResponse], error)

type WatchServiceClient 

type WatchServiceClient = watchconnect.WatchServiceClient

func NewWatchServiceClient 

func NewWatchServiceClient(u *UtxorpcClient) WatchServiceClient

Source Files

View all Source files

Directories

Path Synopsis
examples
query command
submit command
sync command

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.