krkstops

README

Krkstops

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

Documentation

Index

• Constants
• Variables
• type Clients
  • func (c *Clients) AddSuggestion(shortName, name string, score float64) error
  • func (c *Clients) ApplyScore(score float64, shortName string) error
  • func (c *Clients) CompareStops(stops ttss.Stops) (newStops ttss.Stops, oldStops ttss.Stops, err error)
  • func (c *Clients) FinishScoring() error
  • func (c *Clients) GetStopToScore() (shortName string, err error)
  • func (c *Clients) InitializeScoring() error
  • func (c *Clients) RestartScoring() error
  • func (c *Clients) ScoreStop(krk pb.KrkStopsClient, shortName string) (float64, error)
  • func (c *Clients) UpdateSuggestionsAndRedis(newStops ttss.Stops, oldStops ttss.Stops) error
• type KrkStopsServer
  • 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) GetDepartures(stop *pb.Stop, stream pb.KrkStops_GetDeparturesServer) error
  • func (s *KrkStopsServer) SearchStops(search *pb.StopSearch, stream pb.KrkStops_SearchStopsServer) error

Constants

const (
	STOPS_TO_SCORE = "stops.toScore"
	STOPS          = "stops"
	STOPS_NEW      = "stops.new"
	STOPS_TMP      = "stops.tmp"
)

Variables

var AirlyExpire = time.Minute * 10

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

var ScoringInitialized = errors.New("scoring is already initialized")

Types

type Clients

type Clients struct {
	Redis              *redis.Client
	RedisAutocompleter *redisearch.Autocompleter
	// contains filtered or unexported fields
}

func (*Clients) AddSuggestion

func (c *Clients) AddSuggestion(shortName, name string, score float64) error

func (*Clients) ApplyScore

func (c *Clients) ApplyScore(score float64, shortName string) error

func (*Clients) CompareStops

func (c *Clients) CompareStops(stops ttss.Stops) (newStops ttss.Stops, oldStops ttss.Stops, err error)

CompareStops and return new and old. New stops are stored in 'stops.tmp' set.

func (*Clients) FinishScoring

func (c *Clients) FinishScoring() error

func (*Clients) GetStopToScore

func (c *Clients) GetStopToScore() (shortName string, err error)

func (*Clients) InitializeScoring

func (c *Clients) InitializeScoring() error

func (*Clients) RestartScoring

func (c *Clients) RestartScoring() error

func (*Clients) ScoreStop

func (c *Clients) ScoreStop(krk pb.KrkStopsClient, shortName string) (float64, error)

func (*Clients) UpdateSuggestionsAndRedis

func (c *Clients) UpdateSuggestionsAndRedis(newStops ttss.Stops, oldStops ttss.Stops) error

UpdateSuggestionsAndRedis in Redisearch engine

type KrkStopsServer

type KrkStopsServer struct {
	pb.UnimplementedKrkStopsServer
	C     Clients
	Airly airly.Endpoint
	Ttss  []ttss.Endpointer
}

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) GetDepartures

func (s *KrkStopsServer) GetDepartures(stop *pb.Stop, stream pb.KrkStops_GetDeparturesServer) error

func (*KrkStopsServer) SearchStops

func (s *KrkStopsServer) SearchStops(search *pb.StopSearch, stream pb.KrkStops_SearchStopsServer) error