servicer

Documentation

Index

• type MarketdataServer
  • func NewMarketdataServer(pgx *pgxpool.Pool, md supplier.Marketdata) *MarketdataServer
  • func (fs *MarketdataServer) DownloadHistoricalData(ctx context.Context, req *pb.DownloadHistoricalDataRequest) (*pb.DownloadHistoricalDataResponse, error)
  • func (fs *MarketdataServer) GetAsset(ctx context.Context, req *pb.GetAssetRequest) (*pb.GetAssetResponse, error)
  • func (fs *MarketdataServer) GetIndex(ctx context.Context, req *pb.GetIndexRequest) (*pb.GetIndexResponse, error)
• type TradingServer
  • func NewTradingServer(pgx *pgxpool.Pool, trading supplier.Trading) *TradingServer
  • func (ts *TradingServer) GetOrders(ctx context.Context, req *pb.GetOrdersRequest) (*pb.GetOrdersResponse, error)
  • func (ts *TradingServer) GetPortfolio(ctx context.Context, req *pb.GetPortfolioRequest) (*pb.GetPortfolioResponse, error)
  • func (ts *TradingServer) PlaceOrder(ctx context.Context, req *pb.PlaceOrderRequest) (*pb.PlaceOrderResponse, error)

Types

type MarketdataServer

type MarketdataServer struct {
	pb.UnimplementedMarketdataServer
	// contains filtered or unexported fields
}

func NewMarketdataServer

func NewMarketdataServer(pgx *pgxpool.Pool, md supplier.Marketdata) *MarketdataServer

func (*MarketdataServer) DownloadHistoricalData

func (fs *MarketdataServer) DownloadHistoricalData(ctx context.Context, req *pb.DownloadHistoricalDataRequest) (*pb.DownloadHistoricalDataResponse, error)

func (*MarketdataServer) GetAsset

func (fs *MarketdataServer) GetAsset(ctx context.Context, req *pb.GetAssetRequest) (*pb.GetAssetResponse, error)

func (*MarketdataServer) GetIndex

func (fs *MarketdataServer) GetIndex(ctx context.Context, req *pb.GetIndexRequest) (*pb.GetIndexResponse, error)

type TradingServer

type TradingServer struct {
	pb.UnimplementedTradingServer
	// contains filtered or unexported fields
}

func NewTradingServer

func NewTradingServer(pgx *pgxpool.Pool, trading supplier.Trading) *TradingServer

func (*TradingServer) GetOrders

func (ts *TradingServer) GetOrders(ctx context.Context, req *pb.GetOrdersRequest) (*pb.GetOrdersResponse, error)

func (*TradingServer) GetPortfolio

func (ts *TradingServer) GetPortfolio(ctx context.Context, req *pb.GetPortfolioRequest) (*pb.GetPortfolioResponse, error)

func (*TradingServer) PlaceOrder

func (ts *TradingServer) PlaceOrder(ctx context.Context, req *pb.PlaceOrderRequest) (*pb.PlaceOrderResponse, error)