Documentation
¶
Index ¶
- func GrpcLogger(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (resp interface{}, err error)
- type Server
- func (server *Server) GetAccountBalanceChanges(ctx context.Context, req *pb.GetAccountBalanceChangesRequest) (*pb.GetAccountBalanceChangesResponse, error)
- func (server *Server) GetLastValidatedLedger(ctx context.Context, req *pb.GetLastValidatedLedgerRequest) (*pb.GetLedgerResponse, error)
- func (server *Server) GetLedger(ctx context.Context, req *pb.GetLedgerRequest) (*pb.GetLedgerResponse, error)
- func (server *Server) GetTransaction(ctx context.Context, req *pb.GetTransactionRequest) (*pb.GetTransactionResponse, error)
- func (server *Server) GetTransactionByHash(transactionHash string) (*pb.Transaction, error)
- func (server *Server) GetTransactionsByLedgerIndex(ledgerIndex int64) ([]pb.Transaction, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GrpcLogger ¶
func GrpcLogger( ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler, ) (resp interface{}, err error)
Types ¶
type Server ¶
type Server struct {
pb.UnimplementedGateHubDataAPIServer
Store gocqlx.Session
Cache *redis.ClusterClient
// contains filtered or unexported fields
}
Server serves gRPC requests for our GateHub Data Api service.
func (*Server) GetAccountBalanceChanges ¶
func (server *Server) GetAccountBalanceChanges(ctx context.Context, req *pb.GetAccountBalanceChangesRequest) (*pb.GetAccountBalanceChangesResponse, error)
func (*Server) GetLastValidatedLedger ¶
func (server *Server) GetLastValidatedLedger(ctx context.Context, req *pb.GetLastValidatedLedgerRequest) (*pb.GetLedgerResponse, error)
func (*Server) GetLedger ¶
func (server *Server) GetLedger(ctx context.Context, req *pb.GetLedgerRequest) (*pb.GetLedgerResponse, error)
func (*Server) GetTransaction ¶
func (server *Server) GetTransaction(ctx context.Context, req *pb.GetTransactionRequest) (*pb.GetTransactionResponse, error)
func (*Server) GetTransactionByHash ¶
func (server *Server) GetTransactionByHash(transactionHash string) (*pb.Transaction, error)
func (*Server) GetTransactionsByLedgerIndex ¶
func (server *Server) GetTransactionsByLedgerIndex(ledgerIndex int64) ([]pb.Transaction, error)
Click to show internal directories.
Click to hide internal directories.