grpc

package

v0.0.0-...-dbca141 Latest Latest Go to latest Published: May 16, 2025 License: Apache-2.0 Imports: 22 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/thosenative/tigerbeetle_api

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func AccountBalanceFromTigerbeetleToProto(tbBalance types.AccountBalance) *proto.AccountBalance
func AccountFilterFromProtoToTigerbeetle(pAccountFilter *proto.AccountFilter) (*types.AccountFilter, error)
func AccountToProtoAccount(tbAccount types.Account) *proto.Account
func HexStringToUint128(hex string) (*types.Uint128, error)
func NewServer()
func ResultsToReply(results []types.TransferEventResult, transfers []types.Transfer, err error) []*proto.CreateTransfersReplyItem
func TransferToProtoTransfer(tbTransfer types.Transfer) *proto.Transfer
type App
- func NewApp() *App
type TimedPayload
type TimedPayloadResponse

Constants ¶

View Source

const TB_MAX_BATCH_SIZE = 8190

Variables ¶

View Source

var (
	ErrZeroAccounts  = errors.New("no accounts were specified")
	ErrZeroTransfers = errors.New("no transfers were specified")
)

Functions ¶

func AccountBalanceFromTigerbeetleToProto ¶

func AccountBalanceFromTigerbeetleToProto(tbBalance types.AccountBalance) *proto.AccountBalance

func AccountFilterFromProtoToTigerbeetle ¶

func AccountFilterFromProtoToTigerbeetle(pAccountFilter *proto.AccountFilter) (*types.AccountFilter, error)

func AccountToProtoAccount ¶

func AccountToProtoAccount(tbAccount types.Account) *proto.Account

func HexStringToUint128 ¶

func HexStringToUint128(hex string) (*types.Uint128, error)

func NewServer ¶

func NewServer()

func ResultsToReply ¶

func ResultsToReply(results []types.TransferEventResult, transfers []types.Transfer, err error) []*proto.CreateTransfersReplyItem

func TransferToProtoTransfer ¶

func TransferToProtoTransfer(tbTransfer types.Transfer) *proto.Transfer

Types ¶

type App ¶

type App struct {
	proto.UnimplementedTigerBeetleServer

	TB tigerbeetle_go.Client

	TBuf  *timedbuf.TimedBuf[TimedPayload]
	TBufs []*timedbuf.TimedBuf[TimedPayload]
}

func NewApp ¶

func NewApp() *App

func (*App) Close ¶

func (a *App) Close()

func (*App) CreateAccounts ¶

func (s *App) CreateAccounts(ctx context.Context, in *proto.CreateAccountsRequest) (*proto.CreateAccountsReply, error)

func (*App) CreateTransfers ¶

func (s *App) CreateTransfers(ctx context.Context, in *proto.CreateTransfersRequest) (*proto.CreateTransfersReply, error)

func (*App) GetAccountBalances ¶

func (s *App) GetAccountBalances(ctx context.Context, in *proto.GetAccountBalancesRequest) (*proto.GetAccountBalancesReply, error)

func (*App) GetAccountTransfers ¶

func (s *App) GetAccountTransfers(ctx context.Context, in *proto.GetAccountTransfersRequest) (*proto.GetAccountTransfersReply, error)

func (*App) GetID ¶

func (s *App) GetID(ctx context.Context, in *proto.GetIDRequest) (*proto.GetIDReply, error)

func (*App) LookupAccounts ¶

func (s *App) LookupAccounts(ctx context.Context, in *proto.LookupAccountsRequest) (*proto.LookupAccountsReply, error)

func (*App) LookupTransfers ¶

func (s *App) LookupTransfers(ctx context.Context, in *proto.LookupTransfersRequest) (*proto.LookupTransfersReply, error)

type TimedPayload ¶

type TimedPayload struct {
	Transfers []types.Transfer
	// contains filtered or unexported fields
}

type TimedPayloadResponse ¶

type TimedPayloadResponse struct {
	Replies []*proto.CreateTransfersReplyItem
	Error   error
}

Source Files ¶

View all Source files

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