grpc

Documentation

Index

• Variables
• func GetProtoTypeName(msg proto.Message) string
• type GRPCServer
  • func NewGRPCServer(logger *common.Logger, config *config.Config, chain *local.Local, ...) (*GRPCServer, 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
  • 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)

Variables

var (
	TrackPlaysProtoName     string
	ManageEntitiesProtoName string
	SlaRollupProtoName      string
	SlaNodeReportProtoName  string
)

Functions

func GetProtoTypeName

func GetProtoTypeName(msg proto.Message) string

Types

type GRPCServer

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

func NewGRPCServer

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

func (*GRPCServer) GetServer

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

func (*GRPCServer) GetTransaction

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

func (*GRPCServer) Ping

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

func (*GRPCServer) SendTransaction

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

func (*GRPCServer) Serve

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

type TxHash

type TxHash = string

func SendRawTx

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

func SendTx

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

func ToTxHash

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