server

package
v0.0.0-...-a2a535d Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 11, 2023 License: GPL-3.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Keyspaces 

type Keyspaces struct {
	System       *system.System
	Portfolio    *kp.Portfolios
	Savingsplans *ks.SavingsPlans
	Timelines    *kt.Timeline
}

type Server 

type Server struct {
	*pb.UnimplementedTradePipeServer

	Lock sync.Mutex

	Keyspaces
	// contains filtered or unexported fields
}

func NewServer 

func NewServer() *Server

func (*Server) CloseKeySpaceConnection 

func (s *Server) CloseKeySpaceConnection()

func (*Server) CreateKeySpaceConnection 

func (s *Server) CreateKeySpaceConnection(contactPoint string, port int, dbAttempts int, delay time.Duration) error

func (*Server) Login 

func (s *Server) Login(ctx context.Context, in *login.Credentials) (*login.ProcessId, error)

func (*Server) ReadPortfolio 

func (s *Server) ReadPortfolio(ctx context.Context, in *portfolio.RequestPortfolio) (*portfolio.ResponsePortfolio, error)

func (*Server) ReadSavingsPlans 

func (s *Server) ReadSavingsPlans(ctx context.Context, in *savingsplan.RequestSavingsplan) (*savingsplan.ResponseSavingsplan, error)

func (*Server) ReadTimeline 

func (s *Server) ReadTimeline(ctx context.Context, in *timeline.RequestTimeline) (*timeline.ResponseTimeline, error)

func (*Server) ReadTimelineDetails 

func (s *Server) ReadTimelineDetails(ctx context.Context, in *timeline.RequestTimelineDetails) (*timeline.ResponseTimelineDetails, error)

func (*Server) Run 

func (s *Server) Run(done chan struct{}, dbAddress string, dbPort, dbAttempts int, dbTimeOut time.Duration) error

func (*Server) SetBaseHTTPClient 

func (s *Server) SetBaseHTTPClient(client *http.Client)

func (*Server) SetBaseURL 

func (s *Server) SetBaseURL(url string)

func (*Server) SetOverWriteTls 

func (s *Server) SetOverWriteTls(overWriteTls bool)

func (*Server) SetWsURL 

func (s *Server) SetWsURL(url string)

func (*Server) Status 

func (s *Server) Status(ctx context.Context, in *emptypb.Empty) (*emptypb.Empty, error)

func (*Server) UpdatePortfolio 

func (s *Server) UpdatePortfolio(ctx context.Context, in *portfolio.RequestPortfolioUpdate) (*emptypb.Empty, error)

func (*Server) UpdateSavingsPlans 

func (s *Server) UpdateSavingsPlans(ctx context.Context, in *savingsplan.RequestSavingsplanUpdate) (*emptypb.Empty, error)

func (*Server) UpdateTimeline 

func (s *Server) UpdateTimeline(ctx context.Context, in *timeline.RequestTimelineUpdate) (*emptypb.Empty, error)

func (*Server) Verify 

func (s *Server) Verify(ctx context.Context, in *login.TwoFAAsks) (*login.TwoFAReturn, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.