frontend

Documentation

Index

• Variables
• func NewSQLiteStreamer(client *rpcclient.Client, cache *common.BlockCache, log *logrus.Entry) (walletrpc.CompactTxStreamerServer, error)
• func NewZRPCFromConf(confPath string) (*rpcclient.Client, error)
• func NewZRPCFromCreds(addr, username, password string) (*rpcclient.Client, error)
• type SqlStreamer
  • func (s *SqlStreamer) GetAddressTxids(addressBlockFilter *walletrpc.TransparentAddressBlockFilter, ...) error
  • func (s *SqlStreamer) GetBlock(ctx context.Context, id *walletrpc.BlockID) (*walletrpc.CompactBlock, error)
  • func (s *SqlStreamer) GetBlockRange(span *walletrpc.BlockRange, ...) error
  • func (s *SqlStreamer) GetCache() *common.BlockCache
  • func (s *SqlStreamer) GetCoinsupply(ctx context.Context, in *walletrpc.Empty) (*walletrpc.Coinsupply, error)
  • func (s *SqlStreamer) GetLatestBlock(ctx context.Context, placeholder *walletrpc.ChainSpec) (*walletrpc.BlockID, error)
  • func (s *SqlStreamer) GetLightdInfo(ctx context.Context, in *walletrpc.Empty) (*walletrpc.LightdInfo, error)
  • func (s *SqlStreamer) GetTransaction(ctx context.Context, txf *walletrpc.TxFilter) (*walletrpc.RawTransaction, error)
  • func (s *SqlStreamer) GracefulStop() error
  • func (s *SqlStreamer) SendTransaction(ctx context.Context, rawtx *walletrpc.RawTransaction) (*walletrpc.SendResponse, error)

Variables

var (
	ErrUnspecified = errors.New("request for unspecified identifier")
)

Functions

func NewSQLiteStreamer

func NewSQLiteStreamer(client *rpcclient.Client, cache *common.BlockCache, log *logrus.Entry) (walletrpc.CompactTxStreamerServer, error)

func NewZRPCFromConf

func NewZRPCFromConf(confPath string) (*rpcclient.Client, error)

func NewZRPCFromCreds

func NewZRPCFromCreds(addr, username, password string) (*rpcclient.Client, error)

Types

type SqlStreamer

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

the service type

func (*SqlStreamer) GetAddressTxids

func (s *SqlStreamer) GetAddressTxids(addressBlockFilter *walletrpc.TransparentAddressBlockFilter, resp walletrpc.CompactTxStreamer_GetAddressTxidsServer) error

func (*SqlStreamer) GetBlock

func (s *SqlStreamer) GetBlock(ctx context.Context, id *walletrpc.BlockID) (*walletrpc.CompactBlock, error)

func (*SqlStreamer) GetBlockRange

func (s *SqlStreamer) GetBlockRange(span *walletrpc.BlockRange, resp walletrpc.CompactTxStreamer_GetBlockRangeServer) error

func (*SqlStreamer) GetCache

func (s *SqlStreamer) GetCache() *common.BlockCache

func (*SqlStreamer) GetCoinsupply

func (s *SqlStreamer) GetCoinsupply(ctx context.Context, in *walletrpc.Empty) (*walletrpc.Coinsupply, error)

GetCoinsupply gets the Coinsupply info

func (*SqlStreamer) GetLatestBlock

func (s *SqlStreamer) GetLatestBlock(ctx context.Context, placeholder *walletrpc.ChainSpec) (*walletrpc.BlockID, error)

func (*SqlStreamer) GetLightdInfo

func (s *SqlStreamer) GetLightdInfo(ctx context.Context, in *walletrpc.Empty) (*walletrpc.LightdInfo, error)

GetLightdInfo gets the LightWalletD (this server) info

func (*SqlStreamer) GetTransaction

func (s *SqlStreamer) GetTransaction(ctx context.Context, txf *walletrpc.TxFilter) (*walletrpc.RawTransaction, error)

func (*SqlStreamer) GracefulStop

func (s *SqlStreamer) GracefulStop() error

func (*SqlStreamer) SendTransaction

func (s *SqlStreamer) SendTransaction(ctx context.Context, rawtx *walletrpc.RawTransaction) (*walletrpc.SendResponse, error)

SendTransaction forwards raw transaction bytes to a hushd instance over JSON-RPC