server

Documentation

Index

• Constants
• type GRPC
  • func (g *GRPC) GetQuoteLatest(req *pb.QuoteRequest, resp pb.Storage_GetQuoteLatestServer) error
  • func (g *GRPC) GetStockFull(_ *emptypb.Empty, gs pb.Storage_GetStockFullServer) error
  • func (g *GRPC) PushMetadata(ps pb.Storage_PushMetadataServer) error
  • func (g *GRPC) Startup() error
  • func (g *GRPC) Stop() error

Constants

const PER_COMMIT_LIMIT = 32

Types

type GRPC

type GRPC struct {
	EtcdClient *clientv3.Client
	Host       string
	Port       int
	AppName    string

	pb.UnimplementedStorageServer
	// contains filtered or unexported fields
}

func (*GRPC) GetQuoteLatest

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

func (*GRPC) GetStockFull

func (g *GRPC) GetStockFull(_ *emptypb.Empty, gs pb.Storage_GetStockFullServer) error

func (*GRPC) PushMetadata

func (g *GRPC) PushMetadata(ps pb.Storage_PushMetadataServer) error

func (*GRPC) Startup

func (g *GRPC) Startup() error

func (*GRPC) Stop

func (g *GRPC) Stop() error