rpc

Documentation

Index

• func GRPCMetricsAndLogMiddleware(logger *zerolog.Logger) grpc.UnaryServerInterceptor
• type GRPCPanicker
  • func (pr *GRPCPanicker) GRPCPanicRecoveryHandler(p any) (err error)
• type MetaTransactionService
  • func NewMetaTransactionService(settings *config.Settings, logger *zerolog.Logger, dbs db.Store) *MetaTransactionService
  • func (m *MetaTransactionService) CleanStuckMetaTransactions(ctx context.Context, in *emptypb.Empty) (*pb.CleanStuckMetaTransactionsResponse, error)

Functions

func GRPCMetricsAndLogMiddleware

func GRPCMetricsAndLogMiddleware(logger *zerolog.Logger) grpc.UnaryServerInterceptor

GRPCMetricsAndLogMiddleware tracks error and success prom metrics for grpc, and also logs if there is an error

Types

type GRPCPanicker

type GRPCPanicker struct {
	Logger *zerolog.Logger
}

func (*GRPCPanicker) GRPCPanicRecoveryHandler

func (pr *GRPCPanicker) GRPCPanicRecoveryHandler(p any) (err error)

type MetaTransactionService

type MetaTransactionService struct {
	pb.MetaTransactionServiceServer
	Settings *config.Settings
	// contains filtered or unexported fields
}

func NewMetaTransactionService

func NewMetaTransactionService(settings *config.Settings, logger *zerolog.Logger, dbs db.Store) *MetaTransactionService

func (*MetaTransactionService) CleanStuckMetaTransactions

func (m *MetaTransactionService) CleanStuckMetaTransactions(ctx context.Context, in *emptypb.Empty) (*pb.CleanStuckMetaTransactionsResponse, error)