grpc

package

v1.5.66-0...-1e0c951 Latest Latest Go to latest Published: Nov 15, 2024 License: Apache-2.0 Imports: 20 Imported by: 0

Details

This section is empty.

View Source

var (
	TrackPlaysProtoName     string
	ManageEntitiesProtoName string
	SlaRollupProtoName      string
	SlaNodeReportProtoName  string
)

func GetProtoTypeName(msg proto.Message) string

type GRPCServer struct {
	proto.UnimplementedProtocolServer
	// contains filtered or unexported fields
}

func NewGRPCServer(logger *common.Logger, config *config.Config, chain *local.Local, pool *pgxpool.Pool) (*GRPCServer, error)

func (s *GRPCServer) GetBlock(ctx context.Context, req *proto.GetBlockRequest) (*proto.BlockResponse, error)

func (s *GRPCServer) GetNodeInfo(ctx context.Context, req *proto.GetNodeInfoRequest) (*proto.NodeInfoResponse, error)

func (s *GRPCServer) GetServer() *grpc.Server

func (s *GRPCServer) GetTransaction(ctx context.Context, req *proto.GetTransactionRequest) (*proto.TransactionResponse, error)

func (s *GRPCServer) Ping(ctx context.Context, req *proto.PingRequest) (*proto.PingResponse, error)

func (s *GRPCServer) SendTransaction(_ context.Context, req *proto.SendTransactionRequest) (*proto.TransactionResponse, error)

func (s *GRPCServer) Serve(lis net.Listener) error

type TxHash = string

func SendRawTx(ctx context.Context, logger *common.Logger, rpc *local.Local, tx []byte) (TxHash, error)

func SendTx[T proto.Message](logger *common.Logger, rpc *local.Local, msg T) (TxHash, error)

func ToTxHash(msg proto.Message) (TxHash, error)