wfb

Documentation

Index

• func AgentLocation(gid model.GoogleID)
• func AgentLogin(teams []model.TeamID, gid model.GoogleID) error
• func AssignLink(gid model.GoogleID, linkID model.TaskID, opID model.OperationID, ...) error
• func AssignMarker(gid model.GoogleID, markerID model.TaskID, opID model.OperationID, ...) error
• func AssignTask(gid model.GoogleID, taskID model.TaskID, opID model.OperationID, ...) error
• func LinkStatus(linkID model.TaskID, opID model.OperationID, teams []model.TeamID, ...) error
• func MapChange(teams []model.TeamID, opID model.OperationID, updateID string) error
• func MarkerStatus(markerID model.TaskID, opID model.OperationID, teams []model.TeamID, ...) error
• func ResetDefaultRateLimits()
• func Resubscribe()
• func Start(ctx context.Context)
• func TaskStatus(taskID model.TaskID, opID model.OperationID, teams []model.TeamID, ...) error

Functions

func AgentLocation

func AgentLocation(gid model.GoogleID)

AgentLocation alerts all appropriate teams about an agent's moving Do not send to topic since this hits the fanout-quota quickly We do the fanout manually, sending directly to tokens has a much higher quota

func AgentLogin

func AgentLogin(teams []model.TeamID, gid model.GoogleID) error

AgentLogin alerts a team of an agent on that team logging in

func AssignLink

func AssignLink(gid model.GoogleID, linkID model.TaskID, opID model.OperationID, updateID string) error

AssignLink lets an agent know they have a new assignment on a given operation

func AssignMarker

func AssignMarker(gid model.GoogleID, markerID model.TaskID, opID model.OperationID, updateID string) error

AssignMarker lets an gent know they have a new assignment on a given operation

func AssignTask

func AssignTask(gid model.GoogleID, taskID model.TaskID, opID model.OperationID, updateID string) error

AssignTask lets an gent know they have a new assignment on a given operation

func LinkStatus

func LinkStatus(linkID model.TaskID, opID model.OperationID, teams []model.TeamID, status string, updateID string) error

LinkStatus reports a link update to a team/topic

func MapChange

func MapChange(teams []model.TeamID, opID model.OperationID, updateID string) error

MapChange alerts teams of the need to need to refresh map data

func MarkerStatus

func MarkerStatus(markerID model.TaskID, opID model.OperationID, teams []model.TeamID, status string, updateID string) error

MarkerStatus reports a marker update to a team/topic

func ResetDefaultRateLimits

func ResetDefaultRateLimits()

func Resubscribe

func Resubscribe()

Resubscribe refreshes all the topic subscriptions for every team

func Start

func Start(ctx context.Context)

Start is the main startup function for the Firebase subsystem

func TaskStatus

func TaskStatus(taskID model.TaskID, opID model.OperationID, teams []model.TeamID, status string, updateID string) error

TaskStatus reports a task update to a team/topic