server

Documentation

Index

• Variables
• type GRPC
  • func (g *GRPC) Build(ctx context.Context, req *wrapperspb.StringValue) (*emptypb.Empty, error)
  • func (g *GRPC) GetQuoteLatest(req *pb.QuoteRequest, resp pb.Repo_GetQuoteLatestServer) error
  • func (g *GRPC) GetStockFull(_ *emptypb.Empty, resp pb.Repo_GetStockFullServer) error
  • func (g *GRPC) ShutdownGRPC() error
  • func (g *GRPC) StartupGRPC() error

Variables

var (
	GrpcHost = ""
	GrpcPort = 0
)

Types

type GRPC

type GRPC struct {
	ServiceName string
	ExecTimeout time.Duration
	Client      *clientv3.Client

	pb.UnimplementedRepoServer
	// contains filtered or unexported fields
}

func (*GRPC) Build

func (g *GRPC) Build(ctx context.Context, req *wrapperspb.StringValue) (*emptypb.Empty, error)

func (*GRPC) GetQuoteLatest

func (g *GRPC) GetQuoteLatest(req *pb.QuoteRequest, resp pb.Repo_GetQuoteLatestServer) error

func (*GRPC) GetStockFull

func (g *GRPC) GetStockFull(_ *emptypb.Empty, resp pb.Repo_GetStockFullServer) error

func (*GRPC) ShutdownGRPC

func (g *GRPC) ShutdownGRPC() error

func (*GRPC) StartupGRPC

func (g *GRPC) StartupGRPC() error