krkstops

README

Krkstops

Krkstops is golang backend for KrkStops web and mobile application. Enjoy!

Documentation

Index

• Constants
• Variables
• type Cache
  • func NewCache(redisURI, sugKey string) (*Cache, error)
  • func (c *Cache) Score(ctx context.Context, cancel <-chan os.Signal, cli pb.KrkStopsClient, ...) error
  • func (c *Cache) Search(ctx context.Context, phrase string) ([]*pb.Stop, error)
  • func (c *Cache) Update() error
• type KrkStopsServer
  • func NewServer(redisURI string) (*KrkStopsServer, error)
  • func (s *KrkStopsServer) FindNearestAirlyInstallation(ctx context.Context, location *pb.InstallationLocation) (*pb.Installation, error)
  • func (s *KrkStopsServer) GetAirly(ctx context.Context, installation *pb.Installation) (*pb.Airly, error)
  • func (s *KrkStopsServer) GetAirlyInstallation(ctx context.Context, installation *pb.Installation) (*pb.Installation, error)
  • func (s *KrkStopsServer) GetDepartures2(ctx context.Context, stop *pb.Stop) (*pb.Departures, error)
  • func (s *KrkStopsServer) SearchStops2(ctx context.Context, search *pb.StopSearch) (*pb.Stops, error)

Constants

const (
	TO_SCORE = "to.score"
	BUS      = "bus"
	TRAM     = "tram"
	NAMES    = "names"
	SUG      = "sug"
	SCORES   = "scores"
)

Variables

var ENDPOINT = "krkstops.germanywestcentral.cloudapp.azure.com:8080"

Types

type Cache

type Cache struct {
	// contains filtered or unexported fields
}

func NewCache

func NewCache(redisURI, sugKey string) (*Cache, error)

func (*Cache) Score

func (c *Cache) Score(ctx context.Context, cancel <-chan os.Signal, cli pb.KrkStopsClient, sleep time.Duration) error

func (*Cache) Search

func (c *Cache) Search(ctx context.Context, phrase string) ([]*pb.Stop, error)

func (*Cache) Update

func (c *Cache) Update() error

type KrkStopsServer

type KrkStopsServer struct {
	pb.UnimplementedKrkStopsServer

	Airly airly.Endpoint
	Ttss  []ttss.Endpointer
	// contains filtered or unexported fields
}

func NewServer

func NewServer(redisURI string) (*KrkStopsServer, error)

func (*KrkStopsServer) FindNearestAirlyInstallation

func (s *KrkStopsServer) FindNearestAirlyInstallation(ctx context.Context, location *pb.InstallationLocation) (*pb.Installation, error)

func (*KrkStopsServer) GetAirly

func (s *KrkStopsServer) GetAirly(ctx context.Context, installation *pb.Installation) (*pb.Airly, error)

func (*KrkStopsServer) GetAirlyInstallation

func (s *KrkStopsServer) GetAirlyInstallation(ctx context.Context, installation *pb.Installation) (*pb.Installation, error)

func (*KrkStopsServer) GetDepartures2

func (s *KrkStopsServer) GetDepartures2(ctx context.Context, stop *pb.Stop) (*pb.Departures, error)

func (*KrkStopsServer) SearchStops2

func (s *KrkStopsServer) SearchStops2(ctx context.Context, search *pb.StopSearch) (*pb.Stops, error)