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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AgentLocation ¶
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 ¶
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 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
Types ¶
This section is empty.