Documentation ¶
Index ¶
- Variables
- func AddUsersToCircle(circleID string, userIDs []string) (*v1.NotificationEvent, error)
- func AddUsersToGroupChat(groupChatID string, userIDs []string) (*v1.NotificationEvent, error)
- func CreateCircleHasANewDirectorEvent(circleID, circleName, newDirectorID string) (*v1.NotificationEvent, error)
- func CreateCircleMessageRemovedByPicnicEvent(messageID, messageOwnerID, circleID, circleName, actionID, reason string) (*v1.NotificationEvent, error)
- func CreateCommentLikedEvent(commentID, commentOwnerID, userID, thumbnail string) (*v1.NotificationEvent, error)
- func CreateCommentRemovedByPicnicEvent(...) (*v1.NotificationEvent, error)
- func CreateCommentUnlikedEvent(commentID, commentOwnerID, userID string) (*v1.NotificationEvent, error)
- func CreateElectionAboutToLoseEvent(circleID, circleName, currentDirectorID, possibleWinnerID string) (*v1.NotificationEvent, error)
- func CreateElectionSomeonePassedEvent(circleID, circleName, currentDirectorID, newDirectorID string) (*v1.NotificationEvent, error)
- func CreateGlitterBombSendEvent(senderID, senderName, receiverID, glitterBombID, thumbnail string) (*v1.NotificationEvent, error)
- func CreateGroupChatCreatedEvent(groupChatID string, userIDs []string) (*v1.NotificationEvent, error)
- func CreateGroupChatMessageSentEvent(groupChatID, senderID, messageID, messageText, thumbnailURL string) (*v1.NotificationEvent, error)
- func CreateInvitedToACircleEvent(userID, circleID, circleName, InvitedUserID string) (*v1.NotificationEvent, error)
- func CreateNotifyCircleModeratorsForWaitingReportsEvent(moderatorIDs []string, circleName string, waitingReportsCount int32) (*v1.NotificationEvent, error)
- func CreatePostCommentDeletedEvent(postID, postOwnerID, commentID, commenterID string) (*v1.NotificationEvent, error)
- func CreatePostCommentedEvent(postID, postOwnerID, commentID, commentText, commenterID, thumbnail string) (*v1.NotificationEvent, error)
- func CreatePostLikedEvent(postID, postOwnerID, userID, thumbnail string) (*v1.NotificationEvent, error)
- func CreatePostRemovedFromAppByPicnicEvent(postID, postOwnerID, circleID, reason string) (*v1.NotificationEvent, error)
- func CreatePostRemovedFromCircleByModeratorEvent(postID, postOwnerID, circleID, circleName, reason string) (*v1.NotificationEvent, error)
- func CreatePostReportedToCircleModeratorsEvent(postID, reporterID, circleID, circleName, reportType string, ...) (*v1.NotificationEvent, error)
- func CreatePostUnlikedEvent(postID, postOwnerID, userID string) (*v1.NotificationEvent, error)
- func CreatePrivateMessageSentEvent(senderID, receiverID, chatID, messageID, messageText, thumbnailURL string) (*v1.NotificationEvent, error)
- func CreateSeedsReceived(senderID, receiverID, circleID, circleName string, amount int64) (*v1.NotificationEvent, error)
- func CreateThreadCommentDeletedEvent(parentCommentID, parentCommentOwnerID, commentID, commenterID string) (*v1.NotificationEvent, error)
- func CreateThreadCommentedEvent(...) (*v1.NotificationEvent, error)
- func CreateTrendingPostEvent(userID, postID, templateID, title, body, thumbnail string) (*v1.NotificationEvent, error)
- func CreateUserBannedFromAppEvent(userID, reason string) (*v1.NotificationEvent, error)
- func CreateUserBannedFromCircle(userID, circleID, circleName, reason string) (*v1.NotificationEvent, error)
- func CreateUserFollowedEvent(followerID, followerName, followeeID, thumbnail string) (*v1.NotificationEvent, error)
- func CreateUserJoinedACircleEvent(circleID, circleName, userID, directorID string) (*v1.NotificationEvent, error)
- func CreateUserMentionedEvent(userID, mentionedUserID, postID, userProfileURL string) (*v1.NotificationEvent, error)
- func CreateUserSavedPostEvent(postID, postOwnerID, postThumbnailHTTPSURL string, savedCount int) (*v1.NotificationEvent, error)
- func CreateUserSharedPostEvent(postID, postOwnerID, postThumbnailHTTPSURL string, sharedCount int) (*v1.NotificationEvent, error)
- func CreateUserTaggedEvent(...) (*v1.NotificationEvent, error)
- func CreateUserUnbannedFromAppEvent(userID string) (*v1.NotificationEvent, error)
- func CreateUserUnbannedFromCircle(userID, circleID, circleName string) (*v1.NotificationEvent, error)
- func CreateUserUnfollowedEvent(followerID, followeeID string) (*v1.NotificationEvent, error)
- func DontLoseStreakEvent(userStreakID, streakID, userID, title, body string) (*v1.NotificationEvent, error)
- func NewPubSubClient(ctx context.Context, projectID, adcCredPath string) (*pubsub.Client, error)
- func RemoveUsersFromCircle(circleID string, userIDs []string) (*v1.NotificationEvent, error)
- func RemoveUsersFromGroupChat(groupChatID string, userIDs []string) (*v1.NotificationEvent, error)
- func StreakLvlUppedEvent(userStreakID, streakID, userID, title, body string) (*v1.NotificationEvent, error)
- type NotificationIngestTopic
- type Publisher
Constants ¶
This section is empty.
Variables ¶
var ( // SingleNotificationIngestTopic represents a topic that should be used to send single notification. SingleNotificationIngestTopic = NotificationIngestTopic{"notification_ingest"} // BulkNotificationIngestTopic represents a topic that should be used to send bulk notification. BulkNotificationIngestTopic = NotificationIngestTopic{"notification_bulk_ingest"} )
Functions ¶
func AddUsersToCircle ¶
func AddUsersToCircle(circleID string, userIDs []string) (*v1.NotificationEvent, error)
AddUsersToCircle creates AddUsersToCircle notification event.
func AddUsersToGroupChat ¶
func AddUsersToGroupChat(groupChatID string, userIDs []string) (*v1.NotificationEvent, error)
AddUsersToGroupChat creates AddUsersToGroupChat notification event.
func CreateCircleHasANewDirectorEvent ¶
func CreateCircleHasANewDirectorEvent(circleID, circleName, newDirectorID string) (*v1.NotificationEvent, error)
CreateCircleHasANewDirectorEvent creates CircleHasANewDirector notification event.
func CreateCircleMessageRemovedByPicnicEvent ¶
func CreateCircleMessageRemovedByPicnicEvent(messageID, messageOwnerID, circleID, circleName, actionID, reason string) (*v1.NotificationEvent, error)
CreateCircleMessageRemovedByPicnicEvent creates CircleMessageRemovedByPicnic notification event.
func CreateCommentLikedEvent ¶
func CreateCommentLikedEvent(commentID, commentOwnerID, userID, thumbnail string) (*v1.NotificationEvent, error)
CreateCommentLikedEvent creates CommentLiked notification event.
func CreateCommentRemovedByPicnicEvent ¶
func CreateCommentRemovedByPicnicEvent(commentID, commentOwnerID, postID, circleID, circleName, actionID, reason string) (*v1.NotificationEvent, error)
CreateCommentRemovedByPicnicEvent creates CommentRemovedByPicnic notification event.
func CreateCommentUnlikedEvent ¶
func CreateCommentUnlikedEvent(commentID, commentOwnerID, userID string) (*v1.NotificationEvent, error)
CreateCommentUnlikedEvent creates CommentLiked notification event.
func CreateElectionAboutToLoseEvent ¶
func CreateElectionAboutToLoseEvent(circleID, circleName, currentDirectorID, possibleWinnerID string) (*v1.NotificationEvent, error)
CreateElectionAboutToLoseEvent creates ElectionAboutToLose notification event.
func CreateElectionSomeonePassedEvent ¶
func CreateElectionSomeonePassedEvent(circleID, circleName, currentDirectorID, newDirectorID string) (*v1.NotificationEvent, error)
CreateElectionSomeonePassedEvent creates ElectionSomeonePassed notification event.
func CreateGlitterBombSendEvent ¶
func CreateGlitterBombSendEvent(senderID, senderName, receiverID, glitterBombID, thumbnail string) (*v1.NotificationEvent, error)
CreateGlitterBombSendEvent creates GlitterBombSend notification event.
func CreateGroupChatCreatedEvent ¶
func CreateGroupChatCreatedEvent(groupChatID string, userIDs []string) (*v1.NotificationEvent, error)
CreateGroupChatCreatedEvent creates GroupChatCreated notification event.
func CreateGroupChatMessageSentEvent ¶
func CreateGroupChatMessageSentEvent( groupChatID, senderID, messageID, messageText, thumbnailURL string, ) (*v1.NotificationEvent, error)
CreateGroupChatMessageSentEvent creates GroupChatMessageSent notification event.
func CreateInvitedToACircleEvent ¶
func CreateInvitedToACircleEvent(userID, circleID, circleName, InvitedUserID string) (*v1.NotificationEvent, error)
CreateInvitedToACircleEvent creates InvitedToACircle notification event.
func CreateNotifyCircleModeratorsForWaitingReportsEvent ¶
func CreateNotifyCircleModeratorsForWaitingReportsEvent(moderatorIDs []string, circleName string, waitingReportsCount int32) (*v1.NotificationEvent, error)
CreateNotifyCircleModeratorsForWaitingReportsEvent creates NotifyCircleModeratorsForWaitingReports notification event.
func CreatePostCommentDeletedEvent ¶
func CreatePostCommentDeletedEvent(postID, postOwnerID, commentID, commenterID string) (*v1.NotificationEvent, error)
CreatePostCommentDeletedEvent creates PostCommented notification event.
func CreatePostCommentedEvent ¶
func CreatePostCommentedEvent(postID, postOwnerID, commentID, commentText, commenterID, thumbnail string) (*v1.NotificationEvent, error)
CreatePostCommentedEvent creates PostCommented notification event.
func CreatePostLikedEvent ¶
func CreatePostLikedEvent(postID, postOwnerID, userID, thumbnail string) (*v1.NotificationEvent, error)
CreatePostLikedEvent creates PostLiked notification event.
func CreatePostRemovedFromAppByPicnicEvent ¶
func CreatePostRemovedFromAppByPicnicEvent(postID, postOwnerID, circleID, reason string) (*v1.NotificationEvent, error)
CreatePostRemovedFromAppByPicnicEvent creates PostRemovedFromAppByPicnic notification event.
func CreatePostRemovedFromCircleByModeratorEvent ¶
func CreatePostRemovedFromCircleByModeratorEvent(postID, postOwnerID, circleID, circleName, reason string) (*v1.NotificationEvent, error)
CreatePostRemovedFromCircleByModeratorEvent creates PostRemovedFromCircleByModerator notification event.
func CreatePostReportedToCircleModeratorsEvent ¶
func CreatePostReportedToCircleModeratorsEvent(postID, reporterID, circleID, circleName, reportType string, moderatorIDs []string) (*v1.NotificationEvent, error)
CreatePostReportedToCircleModeratorsEvent creates PostReportedToCircleModerators notification event.
func CreatePostUnlikedEvent ¶
func CreatePostUnlikedEvent(postID, postOwnerID, userID string) (*v1.NotificationEvent, error)
CreatePostUnlikedEvent creates PostLiked notification event.
func CreatePrivateMessageSentEvent ¶
func CreatePrivateMessageSentEvent( senderID, receiverID, chatID, messageID, messageText, thumbnailURL string, ) (*v1.NotificationEvent, error)
CreatePrivateMessageSentEvent creates PrivateMessageSent notification event.
func CreateSeedsReceived ¶
func CreateSeedsReceived(senderID, receiverID, circleID, circleName string, amount int64) (*v1.NotificationEvent, error)
CreateSeedsReceived creates SeedsReceived notification event.
func CreateThreadCommentDeletedEvent ¶
func CreateThreadCommentDeletedEvent(parentCommentID, parentCommentOwnerID, commentID, commenterID string) (*v1.NotificationEvent, error)
CreateThreadCommentDeletedEvent creates ThreadCommented notification event.
func CreateThreadCommentedEvent ¶
func CreateThreadCommentedEvent(parentCommentID, parentCommentOwnerID, commentID, threadText, commenterID, thumbnail string) (*v1.NotificationEvent, error)
CreateThreadCommentedEvent creates ThreadCommented notification event.
func CreateTrendingPostEvent ¶ added in v0.3.2
func CreateTrendingPostEvent(userID, postID, templateID, title, body, thumbnail string) (*v1.NotificationEvent, error)
CreateTrendingPostEvent creates trending post event.
func CreateUserBannedFromAppEvent ¶
func CreateUserBannedFromAppEvent(userID, reason string) (*v1.NotificationEvent, error)
CreateUserBannedFromAppEvent creates UserBannedFromApp notification event.
func CreateUserBannedFromCircle ¶
func CreateUserBannedFromCircle(userID, circleID, circleName, reason string) (*v1.NotificationEvent, error)
CreateUserBannedFromCircle creates UserBannedFromCircle notification event.
func CreateUserFollowedEvent ¶
func CreateUserFollowedEvent(followerID, followerName, followeeID, thumbnail string) (*v1.NotificationEvent, error)
CreateUserFollowedEvent creates UserFollowed notification event.
func CreateUserJoinedACircleEvent ¶
func CreateUserJoinedACircleEvent(circleID, circleName, userID, directorID string) (*v1.NotificationEvent, error)
CreateUserJoinedACircleEvent creates UserJoinedACircle notification event.
func CreateUserMentionedEvent ¶
func CreateUserMentionedEvent(userID, mentionedUserID, postID, userProfileURL string) (*v1.NotificationEvent, error)
CreateUserMentionedEvent creates UserMentioned notification event.
func CreateUserSavedPostEvent ¶
func CreateUserSavedPostEvent(postID, postOwnerID, postThumbnailHTTPSURL string, savedCount int) (*v1.NotificationEvent, error)
CreateUserSavedPostEvent creates UserSavedPost notification event.
func CreateUserSharedPostEvent ¶
func CreateUserSharedPostEvent(postID, postOwnerID, postThumbnailHTTPSURL string, sharedCount int) (*v1.NotificationEvent, error)
CreateUserSharedPostEvent creates UserSharedPost notification event.
func CreateUserTaggedEvent ¶
func CreateUserTaggedEvent( entityID, taggerUserID, taggerUsername, TaggedUserID, entityThumbnailHTTPSURL, subEntityID string, entityType v1.EntityType, ) (*v1.NotificationEvent, error)
CreateUserTaggedEvent created UserTagged notification event.
func CreateUserUnbannedFromAppEvent ¶
func CreateUserUnbannedFromAppEvent(userID string) (*v1.NotificationEvent, error)
CreateUserUnbannedFromAppEvent creates UserUnbannedFromApp notification event.
func CreateUserUnbannedFromCircle ¶
func CreateUserUnbannedFromCircle(userID, circleID, circleName string) (*v1.NotificationEvent, error)
CreateUserUnbannedFromCircle creates UserUnbannedFromCircle notification event.
func CreateUserUnfollowedEvent ¶
func CreateUserUnfollowedEvent(followerID, followeeID string) (*v1.NotificationEvent, error)
CreateUserUnfollowedEvent creates UserFollowed notification event.
func DontLoseStreakEvent ¶ added in v0.3.1
func DontLoseStreakEvent(userStreakID, streakID, userID, title, body string) (*v1.NotificationEvent, error)
DontLoseStreakEvent ...
func NewPubSubClient ¶
NewPubSubClient creates a new PubSub client.
func RemoveUsersFromCircle ¶
func RemoveUsersFromCircle(circleID string, userIDs []string) (*v1.NotificationEvent, error)
RemoveUsersFromCircle creates RemoveUsersFromCircle notification event.
func RemoveUsersFromGroupChat ¶
func RemoveUsersFromGroupChat(groupChatID string, userIDs []string) (*v1.NotificationEvent, error)
RemoveUsersFromGroupChat creates AddUserRemoveUsersFromGroupChatsToGroupChat notification event.
func StreakLvlUppedEvent ¶ added in v0.3.1
func StreakLvlUppedEvent(userStreakID, streakID, userID, title, body string) (*v1.NotificationEvent, error)
StreakLvlUppedEvent ...
Types ¶
type NotificationIngestTopic ¶
type NotificationIngestTopic struct {
// contains filtered or unexported fields
}
NotificationIngestTopic is an enum that represents available topics for the publisher to use.
func (NotificationIngestTopic) String ¶
func (n NotificationIngestTopic) String() string
type Publisher ¶
type Publisher struct {
// contains filtered or unexported fields
}
Publisher represents struct that is responsible for publishing messages to Google Pub?Sub topic.
func NewPublisher ¶
func NewPublisher(ctx context.Context, envID string, client *pubsub.Client, topic NotificationIngestTopic) (*Publisher, error)
NewPublisher returns a new publisher.