rpc

Documentation

Index

• func StartDRPCServer(db *pgxpool.Pool, cache redis.UniversalClient)
• type RatesDRPCServer
  • func (s *RatesDRPCServer) GetAllRates(ctx context.Context, req *pb.RateRequest) (*pb.RateListResponse, error)
  • func (s *RatesDRPCServer) StreamRates(req *pb.StreamRatesRequest, stream pb.DRPCRatesService_StreamRatesStream) error

Functions

func StartDRPCServer

func StartDRPCServer(db *pgxpool.Pool, cache redis.UniversalClient)

Types

type RatesDRPCServer

type RatesDRPCServer struct {
	pb.DRPCRatesServiceServer
	Cache redis.UniversalClient
	DB    *pgxpool.Pool
}

func (*RatesDRPCServer) GetAllRates

func (s *RatesDRPCServer) GetAllRates(ctx context.Context, req *pb.RateRequest) (*pb.RateListResponse, error)

GetAllRates returns all rates for the given currency.

func (*RatesDRPCServer) StreamRates

func (s *RatesDRPCServer) StreamRates(req *pb.StreamRatesRequest, stream pb.DRPCRatesService_StreamRatesStream) error

StreamRates streams real-time rate updates for the requested currencies.