services

Documentation

Index

• Constants
• type RpcServer
  • func NewRpcServer(db *database.DB, config *RpcServerConfig) (*RpcServer, error)
  • func (s *RpcServer) Start(ctx context.Context) error
  • func (s *RpcServer) Stop(ctx context.Context) error
  • func (s *RpcServer) Stopped() bool
  • func (s *RpcServer) SubmitWithdrawInfo(ctx context.Context, in *wallet.WithdrawReq) (*wallet.WithdrawRep, error)
  • func (s *RpcServer) VerifyAddress(ctx context.Context, in *wallet.RiskVerifyAddressReq) (*wallet.RiskVerifyAddressRep, error)
  • func (s *RpcServer) VerifyRiskDOrWNotify(ctx context.Context, in *wallet.RiskDOrWNotifyVerifyReq) (*wallet.RiskDOrWNotifyVerifyRep, error)
  • func (s *RpcServer) VerifyWithdrawSign(ctx context.Context, in *wallet.RiskWithdrawVerifyReq) (*wallet.RiskWithdrawVerifyRep, error)
• type RpcServerConfig

Constants

const MaxRecvMessageSize = 1024 * 1024 * 300

Types

type RpcServer

type RpcServer struct {
	*RpcServerConfig

	wallet.UnimplementedWalletServiceServer
	// contains filtered or unexported fields
}

func NewRpcServer

func NewRpcServer(db *database.DB, config *RpcServerConfig) (*RpcServer, error)

func (*RpcServer) Start

func (s *RpcServer) Start(ctx context.Context) error

func (*RpcServer) Stop

func (s *RpcServer) Stop(ctx context.Context) error

func (*RpcServer) Stopped

func (s *RpcServer) Stopped() bool

func (*RpcServer) SubmitWithdrawInfo

func (s *RpcServer) SubmitWithdrawInfo(ctx context.Context, in *wallet.WithdrawReq) (*wallet.WithdrawRep, error)

func (*RpcServer) VerifyAddress

func (s *RpcServer) VerifyAddress(ctx context.Context, in *wallet.RiskVerifyAddressReq) (*wallet.RiskVerifyAddressRep, error)

func (*RpcServer) VerifyRiskDOrWNotify

func (s *RpcServer) VerifyRiskDOrWNotify(ctx context.Context, in *wallet.RiskDOrWNotifyVerifyReq) (*wallet.RiskDOrWNotifyVerifyRep, error)

func (*RpcServer) VerifyWithdrawSign

func (s *RpcServer) VerifyWithdrawSign(ctx context.Context, in *wallet.RiskWithdrawVerifyReq) (*wallet.RiskWithdrawVerifyRep, error)

type RpcServerConfig

type RpcServerConfig struct {
	GrpcHostname string
	GrpcPort     int
}