grpc

Documentation

Index

• Constants
• type TokenPriceRpcConfig
• type TokenPriceRpcService
  • func NewTokenPriceRpcService(conf *TokenPriceRpcConfig, db *database.DB) (*TokenPriceRpcService, error)
  • func (ms *TokenPriceRpcService) GetTokenPriceAndGasByChainId(ctx context.Context, in *gasfee.TokenGasPriceRequest) (*gasfee.TokenGasPriceResponse, error)
  • func (ms *TokenPriceRpcService) Start(ctx context.Context) error
  • func (ms *TokenPriceRpcService) Stop(ctx context.Context) error
  • func (ms *TokenPriceRpcService) Stopped() bool

Constants

const MaxRecvMessageSize = 1024 * 1024 * 30000

Types

type TokenPriceRpcConfig

type TokenPriceRpcConfig struct {
	Host string
	Port int
}

type TokenPriceRpcService

type TokenPriceRpcService struct {
	*TokenPriceRpcConfig

	gasfee.UnimplementedTokenGasPriceServicesServer
	// contains filtered or unexported fields
}

func NewTokenPriceRpcService

func NewTokenPriceRpcService(conf *TokenPriceRpcConfig, db *database.DB) (*TokenPriceRpcService, error)

func (*TokenPriceRpcService) GetTokenPriceAndGasByChainId

func (ms *TokenPriceRpcService) GetTokenPriceAndGasByChainId(ctx context.Context, in *gasfee.TokenGasPriceRequest) (*gasfee.TokenGasPriceResponse, error)

func (*TokenPriceRpcService) Start

func (ms *TokenPriceRpcService) Start(ctx context.Context) error

func (*TokenPriceRpcService) Stop

func (ms *TokenPriceRpcService) Stop(ctx context.Context) error

func (*TokenPriceRpcService) Stopped

func (ms *TokenPriceRpcService) Stopped() bool