controller

Documentation

Index

• type Storage
  • func NewStorage() *Storage
  • func (g *Storage) GetQuoteLatest(req *pb.GetQuoteLatestRequest, resp pb.Storage_GetQuoteLatestServer) error
  • func (g *Storage) GetStockAll(_ *emptypb.Empty, gs pb.Storage_GetStockAllServer) error
  • func (g *Storage) PushMetadata(req grpc.ClientStreamingServer[entity.Metadata, pb.PushResponse]) error
  • func (g *Storage) Service() func(*grpc.Server)
  • func (g *Storage) ShowMetadata(ctx context.Context, req *wrapperspb.StringValue) (*pb.ShowResponse, error)

Types

type Storage

type Storage struct {
	pb.UnimplementedStorageServer
}

func NewStorage

func NewStorage() *Storage

func (*Storage) GetQuoteLatest

func (g *Storage) GetQuoteLatest(req *pb.GetQuoteLatestRequest, resp pb.Storage_GetQuoteLatestServer) error

func (*Storage) GetStockAll

func (g *Storage) GetStockAll(_ *emptypb.Empty, gs pb.Storage_GetStockAllServer) error

func (*Storage) PushMetadata

func (g *Storage) PushMetadata(req grpc.ClientStreamingServer[entity.Metadata, pb.PushResponse]) error

func (*Storage) Service

func (g *Storage) Service() func(*grpc.Server)

func (*Storage) ShowMetadata

func (g *Storage) ShowMetadata(ctx context.Context, req *wrapperspb.StringValue) (*pb.ShowResponse, error)