hart

Documentation

Index

• func PushHandler(ctx context.Context, r *http.Request)
• func SyncAssetInfoFromHaRT(ctx context.Context, proj, topic string, ids []string)
• type PSRequest

Functions

func PushHandler

func PushHandler(ctx context.Context, r *http.Request)

PushHandler handles the pubsub push responses

Decodes the response sent by PubSub and updates datastore. It doesn't return anything as required by https://cloud.google.com/pubsub/docs/push, this is because by default the return is 200 OK for http POST requests. It does not return any 4xx codes on error because it could lead to a loop where PubSub tries to push same message again which is rejected.

func SyncAssetInfoFromHaRT

func SyncAssetInfoFromHaRT(ctx context.Context, proj, topic string, ids []string)

SyncAssetInfoFromHaRT publishes the request for the ids to be synced.

Types

type PSRequest

type PSRequest struct {
	Msg struct {
		Data      string `json:"data"`
		MessageID string `json:"messageId"`
	} `json:"message"`
	Sub string `json:"subscription"`
}

PSRequest helps to unmarshall json data sent from pubsub

The format of the data sent by PubSub is described in https://cloud.google.com/pubsub/docs/push?hl=en#receiving_push_messages