server

package
v1.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 14, 2020 License: Apache-2.0 Imports: 37 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var RelatedLocationsPrefixMap = map[bool]map[bool]string{
	// contains filtered or unexported fields
}

RelatedLocationsPrefixMap is a map from different scenarios to key prefix for RelatedLocations cache.

The three levels of keys are: - Whether related locations have the same ancestor. - Whether related locations have the same place type. - Whether closeness computaion is per capita.

Functions

func NewBtTable 

func NewBtTable(
	ctx context.Context, projectID, instanceID, tableID string) (
	*bigtable.Table, error)

NewBtTable creates a new bigtable.Table instance.

func ReadBranchCacheFolder 

func ReadBranchCacheFolder(
	ctx context.Context, bucket, versionFile string) (string, error)

ReadBranchCacheFolder reads branch cache folder from GCS.

Types

type LandingPageData added in v1.1.0 

type LandingPageData struct {
	Data map[string]*ObsTimeSeries `json:"data,omitempty"`
}

LandingPageData represents the landing page cache data.

type LandingPageResponse added in v1.6.0 

type LandingPageResponse struct {
	Data            map[string]map[string]*ObsTimeSeries `json:"data,omitempty"`
	AllChildPlaces  map[string][]*place                  `json:"allChildPlaces,omitempty"`
	ChildPlacesType string                               `json:"childPlacesType,omitempty"`
	ChildPlaces     []string                             `json:"childPlaces,omitempty"`
	ParentPlaces    []string                             `json:"parentPlaces,omitempty"`
	SimilarPlaces   []string                             `json:"similarPlaces,omitempty"`
	NearbyPlaces    []string                             `json:"nearbyPlaces,omitempty"`
}

LandingPageResponse represents all the data needed for rendering landing page.

type Memcache 

type Memcache struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Memcache represents a Read Write locked object for in-memory key-value cache.

func NewMemcache 

func NewMemcache(data map[string][]byte) *Memcache

NewMemcache initialize a new Memcache instance from a key value map.

func NewMemcacheFromGCS 

func NewMemcacheFromGCS(
	ctx context.Context, bucket, folder string) (*Memcache, error)

NewMemcacheFromGCS initialize a Memcache instance from a Google Cloud Storage folder.

func (*Memcache) Read 

func (m *Memcache) Read(key string) ([]byte, bool)

Read is used for key value look up for Cache.

func (*Memcache) ReadParallel 

func (m *Memcache) ReadParallel(
	rowList bigtable.RowList,
	transform func(string, []byte) (interface{}, error),
	getToken func(string) (string, error),
) map[string]interface{}

ReadParallel read multiple entries from memecache concurrently. This takes a function which transforms raw data into an object.

func (*Memcache) Update 

func (m *Memcache) Update(data map[string][]byte)

Update is used to update the data in Cache.

type Metadata 

type Metadata struct {
	Mappings   []*base.Mapping
	OutArcInfo map[string]map[string][]translator.OutArcInfo
	InArcInfo  map[string][]translator.InArcInfo
	SubTypeMap map[string]string
	Bq         string
}

Metadata represents the metadata used by the server.

func NewMetadata 

func NewMetadata(bqDataset string) (*Metadata, error)

NewMetadata initialize the metadata for translator.

type Node 

type Node struct {
	Dcid   string   `json:"dcid,omitempty"`
	Name   string   `json:"name,omitempty"`
	ProvID string   `json:"provenanceId,omitempty"`
	Value  string   `json:"value,omitempty"`
	Types  []string `json:"types,omitempty"`
}

Node represents a information about a node.

type ObsTimeSeries added in v1.1.0 

type ObsTimeSeries struct {
	Data             map[string]float64 `json:"data,omitempty"`
	PlaceName        string             `json:"placeName,omitempty"`
	PlaceDcid        string             `json:"placeDcid,omitempty"`
	SourceSeries     []*SourceSeries    `json:"sourceSeries,omitempty"`
	ProvenanceDomain string             `json:"provenanceDomain,omitempty"`
}

ObsTimeSeries repesents multiple time series data.

type PlacePopInfo 

type PlacePopInfo struct {
	PlaceID      string `json:"dcid,omitempty"`
	PopulationID string `json:"population,omitempty"`
}

PlacePopInfo contains basic info for a place and a population.

type PlaceStatsVar 

type PlaceStatsVar struct {
	StatVarIds []string `json:"statVarIds,omitempty"`
}

PlaceStatsVar contains the place stats var list.

type PopObs 

type PopObs struct {
	PopulationID     string `json:"dcid,omitempty"`
	ObservationValue string `json:"observation,omitempty"`
}

PopObs represents a pair of population and observation node.

type PropLabelCache 

type PropLabelCache struct {
	InLabels  []string `json:"inLabels"`
	OutLabels []string `json:"outLabels"`
}

PropLabelCache represents the json structure returned by the BT Prop cache

type PropValueCache 

type PropValueCache struct {
	Nodes []*Node `json:"entities,omitempty"`
}

PropValueCache represents the json structure returned by the BT PropVal cache

type RelatedPlacesInfo 

type RelatedPlacesInfo struct {
	RelatedPlaces  []string `json:"relatedPlaces,omitempty"`
	RankFromTop    int32    `json:"rankFromTop,omitempty"`
	RankFromBottom int32    `json:"rankFromBottom,omitempty"`
}

RelatedPlacesInfo represents the json structure returned by the RelatedPlaces cache.

type Server 

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

Server holds resources for a mixer server

func NewServer 

func NewServer(
	bqClient *bigquery.Client,
	btTable *bigtable.Table,
	memcache *Memcache,
	metadata *Metadata) *Server

NewServer creates a new server instance.

func (*Server) GetLandingPage 

func (s *Server) GetLandingPage(
	ctx context.Context, in *pb.GetLandingPageRequest) (
	*pb.GetLandingPageResponse, error)

GetLandingPage implements API for Mixer.GetLandingPage.

func (*Server) GetLandingPageData added in v1.6.0 

func (s *Server) GetLandingPageData(
	ctx context.Context, in *pb.GetLandingPageDataRequest) (
	*pb.GetLandingPageDataResponse, error)

GetLandingPageData implements API for Mixer.GetLandingPageData.

TODO(shifucun):For each related place, it is supposed to have dcid, name and population but it's not complete now as the client in most cases only requires the dcid. Should consider have the full name, even with parent place abbreviations like "CA" filled in here so the client won't bother to fetch those again.

func (*Server) GetLocationsRankings added in v1.4.0 

func (s *Server) GetLocationsRankings(ctx context.Context,
	in *pb.GetLocationsRankingsRequest) (*pb.GetLocationsRankingsResponse, error)

GetLocationsRankings implements API for Mixer.GetLocationsRankings.

func (*Server) GetObservations 

func (s *Server) GetObservations(
	ctx context.Context, in *pb.GetObservationsRequest) (
	*pb.GetObservationsResponse, error)

GetObservations implements API for Mixer.GetObservations.

func (*Server) GetPlaceObs 

func (s *Server) GetPlaceObs(ctx context.Context, in *pb.GetPlaceObsRequest) (
	*pb.GetPlaceObsResponse, error)

GetPlaceObs implements API for Mixer.GetPlaceObs.

func (*Server) GetPlaceStatsVar 

func (s *Server) GetPlaceStatsVar(
	ctx context.Context, in *pb.GetPlaceStatsVarRequest) (
	*pb.GetPlaceStatsVarResponse, error)

GetPlaceStatsVar implements API for Mixer.GetPlaceStatsVar.

func (*Server) GetPlacesIn 

func (s *Server) GetPlacesIn(ctx context.Context, in *pb.GetPlacesInRequest) (
	*pb.GetPlacesInResponse, error)

GetPlacesIn implements API for Mixer.GetPlacesIn.

func (*Server) GetPlacesInPost 

func (s *Server) GetPlacesInPost(ctx context.Context,
	in *pb.GetPlacesInRequest) (*pb.GetPlacesInResponse, error)

GetPlacesInPost implements API for Mixer.GetPlacesInPost.

func (*Server) GetPopObs 

func (s *Server) GetPopObs(ctx context.Context, in *pb.GetPopObsRequest) (
	*pb.GetPopObsResponse, error)

GetPopObs implements API for Mixer.GetPopObs.

func (*Server) GetPopulations 

func (s *Server) GetPopulations(
	ctx context.Context, in *pb.GetPopulationsRequest) (
	*pb.GetPopulationsResponse, error)

GetPopulations implements API for Mixer.GetPopulations.

func (*Server) GetPropertyLabels 

func (s *Server) GetPropertyLabels(ctx context.Context,
	in *pb.GetPropertyLabelsRequest) (*pb.GetPropertyLabelsResponse, error)

GetPropertyLabels implements API for Mixer.GetPropertyLabels.

func (*Server) GetPropertyLabelsPost 

func (s *Server) GetPropertyLabelsPost(ctx context.Context,
	in *pb.GetPropertyLabelsRequest) (*pb.GetPropertyLabelsResponse, error)

GetPropertyLabelsPost implements API for Mixer.GetPropertyLabelsPost.

func (*Server) GetPropertyValues 

func (s *Server) GetPropertyValues(ctx context.Context,
	in *pb.GetPropertyValuesRequest) (*pb.GetPropertyValuesResponse, error)

GetPropertyValues implements API for Mixer.GetPropertyValues.

func (*Server) GetPropertyValuesPost 

func (s *Server) GetPropertyValuesPost(ctx context.Context,
	in *pb.GetPropertyValuesRequest) (*pb.GetPropertyValuesResponse, error)

GetPropertyValuesPost implements API for Mixer.GetPropertyValuesPost.

func (*Server) GetRelatedLocations 

func (s *Server) GetRelatedLocations(ctx context.Context,
	in *pb.GetRelatedLocationsRequest) (*pb.GetRelatedLocationsResponse, error)

GetRelatedLocations implements API for Mixer.GetRelatedLocations.

func (*Server) GetStatAll added in v1.2.0 

func (s *Server) GetStatAll(ctx context.Context, in *pb.GetStatAllRequest) (
	*pb.GetStatAllResponse, error)

GetStatAll implements API for Mixer.GetStatAll.

func (*Server) GetStatSeries added in v1.2.0 

func (s *Server) GetStatSeries(ctx context.Context, in *pb.GetStatSeriesRequest) (
	*pb.GetStatSeriesResponse, error)

GetStatSeries implements API for Mixer.GetStatSeries. TODO(shifucun): consilidate and dedup the logic among these similar APIs.

func (*Server) GetStatValue added in v1.2.0 

func (s *Server) GetStatValue(ctx context.Context, in *pb.GetStatValueRequest) (
	*pb.GetStatValueResponse, error)

GetStatValue implements API for Mixer.GetStatValue.

func (*Server) GetStats 

func (s *Server) GetStats(ctx context.Context, in *pb.GetStatsRequest) (
	*pb.GetStatsResponse, error)

GetStats implements API for Mixer.GetStats.

func (*Server) GetTriples 

func (s *Server) GetTriples(ctx context.Context, in *pb.GetTriplesRequest) (
	*pb.GetTriplesResponse, error)

GetTriples implements API for Mixer.GetTriples.

func (*Server) GetTriplesPost 

func (s *Server) GetTriplesPost(ctx context.Context,
	in *pb.GetTriplesRequest) (*pb.GetTriplesResponse, error)

GetTriplesPost implements API for Mixer.GetTriplesPost.

func (*Server) Query 

func (s *Server) Query(
	ctx context.Context, in *pb.QueryRequest) (*pb.QueryResponse, error)

Query implements API for Mixer.Query.

func (*Server) QueryPost 

func (s *Server) QueryPost(
	ctx context.Context, in *pb.QueryRequest) (*pb.QueryResponse, error)

QueryPost implements API for Mixer.QueryPost.

func (*Server) Search 

func (s *Server) Search(
	ctx context.Context, in *pb.SearchRequest) (*pb.SearchResponse, error)

Search implements API for Mixer.Search.

func (*Server) SubscribeBranchCacheUpdate 

func (s *Server) SubscribeBranchCacheUpdate(
	ctx context.Context, pubsubProjectID, branchCacheBucket, subscriberPrefix,
	pubsubTopic string) error

SubscribeBranchCacheUpdate subscribe server for branch cache update.

func (*Server) Translate 

func (s *Server) Translate(ctx context.Context,
	in *pb.TranslateRequest) (*pb.TranslateResponse, error)

Translate implements API for Mixer.Translate.

type SourceSeries added in v1.1.0 

type SourceSeries struct {
	ImportName        string             `json:"importName,omitempty"`
	ObservationPeriod string             `json:"observationPeriod,omitempty"`
	MeasurementMethod string             `json:"measurementMethod,omitempty"`
	ScalingFactor     string             `json:"scalingFactor,omitempty"`
	Unit              string             `json:"unit,omitempty"`
	ProvenanceDomain  string             `json:"provenanceDomain,omitempty"`
	Val               map[string]float64 `json:"val,omitempty"`
}

SourceSeries represents time series data for a particular source.

type StatisticalVariable 

type StatisticalVariable struct {
	PopType                string            `json:"popType,omitempty"`
	PVs                    map[string]string `json:"pvs,omitempty"`
	MeasuredProp           string            `json:"measuredProp,omitempty"`
	MeasurementMethod      string            `json:"measurementMethod,omitempty"`
	MeasurementDenominator string            `json:"measurementDeonominator,omitempty"`
	MeasurementQualifier   string            `json:"measurementQualifier,omitempty"`
	ScalingFactor          string            `json:"scalingFactor,omitempty"`
	Unit                   string            `json:"unit,omitempty"`
	StatType               string            `json:"statType,omitempty"`
}

StatisticalVariable contains key info of population and observation.

type Triple 

type Triple struct {
	SubjectID    string   `json:"subjectId,omitempty"`
	SubjectName  string   `json:"subjectName,omitempty"`
	SubjectTypes []string `json:"subjectTypes,omitempty"`
	Predicate    string   `json:"predicate,omitempty"`
	ObjectID     string   `json:"objectId,omitempty"`
	ObjectName   string   `json:"objectName,omitempty"`
	ObjectValue  string   `json:"objectValue,omitempty"`
	ObjectTypes  []string `json:"objectTypes,omitempty"`
	ProvenanceID string   `json:"provenanceId,omitempty"`
}

Triple represents a triples entry in the BT triples cache.

type TriplesCache 

type TriplesCache struct {
	Triples []*Triple `json:"triples"`
}

TriplesCache represents the json structure returned by the BT triples cache

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.