rpc

Documentation

Index

• Constants
• type RpcServer
  • func NewRpcServer(db *database.DB, config *RpcServerConfig) (*RpcServer, error)
  • func (s *RpcServer) GetSupportCoins(ctx context.Context, in *wallet.SupportCoinsRequest) (*wallet.SupportCoinsResponse, error)
  • func (s *RpcServer) GetWalletAddress(ctx context.Context, in *wallet.WalletAddressRequest) (*wallet.WalletAddressResponse, error)
  • func (s *RpcServer) Start(ctx context.Context) error
  • func (s *RpcServer) Stop(ctx context.Context) error
  • func (s *RpcServer) Stopped() bool
• 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) GetSupportCoins

func (s *RpcServer) GetSupportCoins(ctx context.Context, in *wallet.SupportCoinsRequest) (*wallet.SupportCoinsResponse, error)

func (*RpcServer) GetWalletAddress

func (s *RpcServer) GetWalletAddress(ctx context.Context, in *wallet.WalletAddressRequest) (*wallet.WalletAddressResponse, 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

type RpcServerConfig

type RpcServerConfig struct {
	GrpcHostname string
	GrpcPort     int
}