stream

package module

Go to main page

Versions in this module

v8

v8.4.3

Jun 25, 2024

Changes in this version

type ModerationClient

+ func (c *ModerationClient) InvalidateUserCache(ctx context.Context, userID string) error

v8.4.2

Jun 18, 2024

Changes in this version

+ const ModerationActivity

+ const ModerationReaction

+ const ModerationUser

type Client

+ func (c *Client) Moderation() *ModerationClient

+ type ModerationClient struct

+ func (c *ModerationClient) FlagActivity(ctx context.Context, userID, activityID, reason string) error

+ func (c *ModerationClient) FlagReaction(ctx context.Context, userID, reactionID, reason string) error

+ func (c *ModerationClient) FlagUser(ctx context.Context, userID, targetUserID, reason string) error

+ func (c *ModerationClient) UpdateActivityModerationStatus(ctx context.Context, activityID, status, recAction, modAction string) error

+ func (c *ModerationClient) UpdateReactionModerationStatus(ctx context.Context, reactionID, status, recAction, modAction string) error

v8.4.1

Jun 14, 2024

Changes in this version

type ClientOption

+ func WithAPIAddr(addr string) ClientOption

v8.4.0

Jan 9, 2024

Changes in this version

type FilterReactionsOption

+ func WithRanking(ranking string) FilterReactionsOption

type GetActivitiesOption

+ func WithActivitiesRanking(ranking string) GetActivitiesOption

+ func WithExternalRankingVars(externalVarJSON string) GetActivitiesOption

type Reaction

+ Score float64

v8.3.0

Nov 20, 2023

Changes in this version

type Activity

+ ScoreVars map[string]any

type GetActivitiesOption

+ func WithRankingScoreVars() GetActivitiesOption

type Reaction

+ DeletedAt *time.Time

type ReactionsClient

+ func (c *ReactionsClient) Restore(ctx context.Context, id string) error

+ func (c *ReactionsClient) SoftDelete(ctx context.Context, id string) error

v8.2.1

Aug 17, 2023

Changes in this version

type Feed

+ BatchUpdateToTargets func(context.Context, []UpdateToTargetsRequest) (*UpdateToTargetsResponse, error)

v8.2.0

Aug 17, 2023

Changes in this version

type AggregatedFeed

+ func (f *AggregatedFeed) BatchUpdateToTargets(ctx context.Context, reqs []UpdateToTargetsRequest) (*UpdateToTargetsResponse, error)

type FlatFeed

+ func (f *FlatFeed) BatchUpdateToTargets(ctx context.Context, reqs []UpdateToTargetsRequest) (*UpdateToTargetsResponse, error)

type NotificationFeed

+ func (f *NotificationFeed) BatchUpdateToTargets(ctx context.Context, reqs []UpdateToTargetsRequest) (*UpdateToTargetsResponse, error)

+ type UpdateToTargetsRequest struct

+ ForeignID string

+ Opts []UpdateToTargetsOption

+ Time Time

v8.1.0

Jul 25, 2023

Changes in this version

type GetActivitiesOption

+ func WithEnrichUserReactions(userID string) GetActivitiesOption

v8.0.2

May 10, 2023

v8.0.1

Feb 14, 2023

v8.0.0

Oct 20, 2022

Changes in this version

+ const HeaderRateLimit

+ const HeaderRateRemaining

+ const HeaderRateReset

+ const ReactionTimeLayout

+ const TimeLayout

+ var CreateCollectionReference = (&CollectionsClient{}).CreateReference

+ var CreateUserReference = (&UsersClient{}).CreateReference

+ var ErrInvalidNextPage = errors.New("invalid format for Next field")

+ var ErrMissingNextPage = errors.New("request missing next page")

+ var Version = "v8.0.0"

+ type APIError struct

+ Code int

+ Detail string

+ Duration Duration

+ Exception string

+ ExceptionFields map[string][]any

+ Rate *Rate

+ StatusCode int

+ func ToAPIError(err error) (APIError, bool)

+ func (e APIError) Error() string

+ type Activity struct

+ Actor string

+ Extra map[string]any

+ ForeignID string

+ ID string

+ Object string

+ Origin string

+ Score float64

+ Target string

+ Time Time

+ To []string

+ Verb string

+ func (a *Activity) UnmarshalJSON(b []byte) error

+ func (a Activity) MarshalJSON() ([]byte, error)

+ type ActivityGroup struct

+ Activities []Activity

+ type AddActivitiesResponse struct

+ Activities []Activity

+ type AddActivityResponse struct

+ func (a *AddActivityResponse) UnmarshalJSON(buf []byte) error

+ type AddObjectOption func(*addCollectionRequest)

+ func WithUserID(userID string) AddObjectOption

+ type AddReactionRequestObject struct

+ ActivityID string

+ Data map[string]any

+ ID string

+ Kind string

+ ParentID string

+ TargetFeeds []string

+ TargetFeedsExtraData map[string]any

+ UserID string

+ type AddToManyRequest struct

+ Activity Activity

+ FeedIDs []string

+ type AggregatedFeed struct

+ func (f *AggregatedFeed) AddActivities(ctx context.Context, activities ...Activity) (*AddActivitiesResponse, error)

+ func (f *AggregatedFeed) AddActivity(ctx context.Context, activity Activity) (*AddActivityResponse, error)

+ func (f *AggregatedFeed) Follow(ctx context.Context, feed *FlatFeed, opts ...FollowFeedOption) (*BaseResponse, error)

+ func (f *AggregatedFeed) GetActivities(ctx context.Context, opts ...GetActivitiesOption) (*AggregatedFeedResponse, error)

+ func (f *AggregatedFeed) GetActivitiesWithRanking(ctx context.Context, ranking string, opts ...GetActivitiesOption) (*AggregatedFeedResponse, error)

+ func (f *AggregatedFeed) GetEnrichedActivities(ctx context.Context, opts ...GetActivitiesOption) (*EnrichedAggregatedFeedResponse, error)

+ func (f *AggregatedFeed) GetEnrichedActivitiesWithRanking(ctx context.Context, ranking string, opts ...GetActivitiesOption) (*EnrichedAggregatedFeedResponse, error)

+ func (f *AggregatedFeed) GetFollowing(ctx context.Context, opts ...FollowingOption) (*FollowingResponse, error)

+ func (f *AggregatedFeed) GetNextPageActivities(ctx context.Context, resp *AggregatedFeedResponse) (*AggregatedFeedResponse, error)

+ func (f *AggregatedFeed) GetNextPageEnrichedActivities(ctx context.Context, resp *EnrichedAggregatedFeedResponse) (*EnrichedAggregatedFeedResponse, error)

+ func (f *AggregatedFeed) ID() string

+ func (f *AggregatedFeed) RealtimeToken(readonly bool) string

+ func (f *AggregatedFeed) RemoveActivityByForeignID(ctx context.Context, foreignID string) (*RemoveActivityResponse, error)

+ func (f *AggregatedFeed) RemoveActivityByID(ctx context.Context, id string) (*RemoveActivityResponse, error)

+ func (f *AggregatedFeed) Slug() string

+ func (f *AggregatedFeed) Unfollow(ctx context.Context, target Feed, opts ...UnfollowOption) (*BaseResponse, error)

+ func (f *AggregatedFeed) UpdateToTargets(ctx context.Context, activity Activity, opts ...UpdateToTargetsOption) (*UpdateToTargetsResponse, error)

+ func (f *AggregatedFeed) UserID() string

+ type AggregatedFeedResponse struct

+ Results []ActivityGroup

+ type AnalyticsClient struct

+ func (c *AnalyticsClient) RedirectAndTrack(url string, events ...map[string]any) (string, error)

+ func (c *AnalyticsClient) TrackEngagement(ctx context.Context, events ...EngagementEvent) (*BaseResponse, error)

+ func (c *AnalyticsClient) TrackImpression(ctx context.Context, eventsData ImpressionEventsData) (*BaseResponse, error)

+ type BaseResponse struct

+ type Client struct

+ func New(key, secret string, opts ...ClientOption) (*Client, error)

+ func NewFromEnv(extraOptions ...ClientOption) (*Client, error)

+ func (c *Client) AddToMany(ctx context.Context, activity Activity, feeds ...Feed) error

+ func (c *Client) AggregatedFeed(slug, userID string) (*AggregatedFeed, error)

+ func (c *Client) Analytics() *AnalyticsClient

+ func (c *Client) Collections() *CollectionsClient

+ func (c *Client) CreateUserToken(userID string) (string, error)

+ func (c *Client) CreateUserTokenWithClaims(userID string, claims map[string]any) (string, error)

+ func (c *Client) FlatFeed(slug, userID string) (*FlatFeed, error)

+ func (c *Client) FollowMany(ctx context.Context, relationships []FollowRelationship, ...) error

+ func (c *Client) GenericFeed(targetID string) (Feed, error)

+ func (c *Client) GetActivitiesByForeignID(ctx context.Context, values ...ForeignIDTimePair) (*GetActivitiesResponse, error)

+ func (c *Client) GetActivitiesByID(ctx context.Context, ids ...string) (*GetActivitiesResponse, error)

+ func (c *Client) GetEnrichedActivitiesByForeignID(ctx context.Context, values []ForeignIDTimePair, opts ...GetActivitiesOption) (*GetEnrichedActivitiesResponse, error)

+ func (c *Client) GetEnrichedActivitiesByID(ctx context.Context, ids []string, opts ...GetActivitiesOption) (*GetEnrichedActivitiesResponse, error)

+ func (c *Client) NotificationFeed(slug, userID string) (*NotificationFeed, error)

+ func (c *Client) PartialUpdateActivities(ctx context.Context, changesets ...UpdateActivityRequest) (*UpdateActivitiesResponse, error)

+ func (c *Client) Personalization() *PersonalizationClient

+ func (c *Client) Reactions() *ReactionsClient

+ func (c *Client) UnfollowMany(ctx context.Context, relationships []UnfollowRelationship) error

+ func (c *Client) UpdateActivities(ctx context.Context, activities ...Activity) (*BaseResponse, error)

+ func (c *Client) UpdateActivityByForeignID(ctx context.Context, foreignID string, timestamp Time, set map[string]any, ...) (*UpdateActivityResponse, error)

+ func (c *Client) UpdateActivityByID(ctx context.Context, id string, set map[string]any, unset []string) (*UpdateActivityResponse, error)

+ func (c *Client) Users() *UsersClient

+ func (c *Client) WithTimeout(timeout time.Duration) *Client

+ type ClientOption func(*Client)

+ func WithAPIRegion(region string) ClientOption

+ func WithAPIVersion(version string) ClientOption

+ func WithHTTPRequester(requester Requester) ClientOption

+ func WithTimeout(dur time.Duration) ClientOption

+ type CollectionObject struct

+ Data map[string]any

+ ID string

+ func (o CollectionObject) MarshalJSON() ([]byte, error)

+ type CollectionObjectResponse struct

+ type CollectionsClient struct

+ func (c *CollectionsClient) Add(ctx context.Context, collection string, object CollectionObject, ...) (*CollectionObjectResponse, error)

+ func (c *CollectionsClient) CreateReference(collection, id string) string

+ func (c *CollectionsClient) Delete(ctx context.Context, collection, id string) (*BaseResponse, error)

+ func (c *CollectionsClient) DeleteMany(ctx context.Context, collection string, ids ...string) (*BaseResponse, error)

+ func (c *CollectionsClient) Get(ctx context.Context, collection, id string) (*CollectionObjectResponse, error)

+ func (c *CollectionsClient) Select(ctx context.Context, collection string, ids ...string) (*GetCollectionResponse, error)

+ func (c *CollectionsClient) Update(ctx context.Context, collection, id string, data map[string]any) (*CollectionObjectResponse, error)

+ func (c *CollectionsClient) Upsert(ctx context.Context, collection string, objects ...CollectionObject) (*BaseResponse, error)

+ type Data struct

+ Extra map[string]any

+ ID string

+ func (a Data) MarshalJSON() ([]byte, error)

+ type Duration struct

+ func (d *Duration) UnmarshalJSON(b []byte) error

+ func (d Duration) MarshalJSON() ([]byte, error)

+ type EngagementEvent map[string]any

+ func (e EngagementEvent) WithBoost(boost int) EngagementEvent

+ func (e EngagementEvent) WithContent(foreignID string, content map[string]any) EngagementEvent

+ func (e EngagementEvent) WithFeatures(features ...EventFeature) EngagementEvent

+ func (e EngagementEvent) WithFeedID(feedID string) EngagementEvent

+ func (e EngagementEvent) WithForeignID(foreignID string) EngagementEvent

+ func (e EngagementEvent) WithLabel(label string) EngagementEvent

+ func (e EngagementEvent) WithLocation(location string) EngagementEvent

+ func (e EngagementEvent) WithPosition(position int) EngagementEvent

+ func (e EngagementEvent) WithTrackedAt(trackedAt time.Time) EngagementEvent

+ func (e EngagementEvent) WithUserData(userData *UserData) EngagementEvent

+ type EnrichedActivity struct

+ Actor Data

+ Extra map[string]any

+ ForeignID string

+ ID string

+ LatestReactions map[string][]*EnrichedReaction

+ Object Data

+ Origin Data

+ OwnReactions map[string][]*EnrichedReaction

+ ReactionCounts map[string]int

+ Score float64

+ Target Data

+ Time Time

+ To []string

+ Verb string

+ func (a *EnrichedActivity) UnmarshalJSON(b []byte) error

+ func (a EnrichedActivity) MarshalJSON() ([]byte, error)

+ type EnrichedActivityGroup struct

+ Activities []EnrichedActivity

+ Score float64

+ type EnrichedAggregatedFeedResponse struct

+ Results []EnrichedActivityGroup

+ type EnrichedFlatFeedResponse struct

+ Results []EnrichedActivity

+ type EnrichedNotificationFeedResponse struct

+ Results []EnrichedNotificationFeedResult

+ type EnrichedNotificationFeedResult struct

+ Activities []EnrichedActivity

+ type EnrichedReaction struct

+ ActivityID string

+ ChildrenCounters map[string]int

+ ChildrenReactions map[string][]*EnrichedReaction

+ CreatedAt Time

+ Data map[string]any

+ ID string

+ Kind string

+ OwnChildren map[string][]*EnrichedReaction

+ ParentID string

+ TargetFeeds []string

+ UpdatedAt Time

+ User Data

+ UserID string

+ type EventFeature struct

+ Group string

+ Value string

+ func NewEventFeature(group, value string) EventFeature

+ type Feed interface

+ AddActivities func(context.Context, ...Activity) (*AddActivitiesResponse, error)

+ AddActivity func(context.Context, Activity) (*AddActivityResponse, error)

+ Follow func(context.Context, *FlatFeed, ...FollowFeedOption) (*BaseResponse, error)

+ GetFollowing func(context.Context, ...FollowingOption) (*FollowingResponse, error)

+ ID func() string

+ RealtimeToken func(bool) string

+ RemoveActivityByForeignID func(context.Context, string) (*RemoveActivityResponse, error)

+ RemoveActivityByID func(context.Context, string) (*RemoveActivityResponse, error)

+ Slug func() string

+ Unfollow func(context.Context, Feed, ...UnfollowOption) (*BaseResponse, error)

+ UpdateToTargets func(context.Context, Activity, ...UpdateToTargetsOption) (*UpdateToTargetsResponse, error)

+ UserID func() string

+ type FilterReactionResponse struct

+ Activity map[string]any

+ Results []Reaction

+ type FilterReactionsAttribute func() string

+ func ByActivityID(activityID string) FilterReactionsAttribute

+ func ByReactionID(reactionID string) FilterReactionsAttribute

+ func ByUserID(userID string) FilterReactionsAttribute

+ func (a FilterReactionsAttribute) ByKind(kind string) FilterReactionsAttribute

+ type FilterReactionsOption struct

+ func WithActivityData() FilterReactionsOption

+ func WithChildrenUserID(userID string) FilterReactionsOption

+ func WithIDGT(id string) FilterReactionsOption

+ func WithIDGTE(id string) FilterReactionsOption

+ func WithIDLT(id string) FilterReactionsOption

+ func WithIDLTE(id string) FilterReactionsOption

+ func WithLimit(limit int) FilterReactionsOption

+ func WithOwnChildren() FilterReactionsOption

+ func WithOwnUserID(userID string) FilterReactionsOption

+ type FlatFeed struct

+ func (f *FlatFeed) AddActivities(ctx context.Context, activities ...Activity) (*AddActivitiesResponse, error)

+ func (f *FlatFeed) AddActivity(ctx context.Context, activity Activity) (*AddActivityResponse, error)

+ func (f *FlatFeed) Follow(ctx context.Context, feed *FlatFeed, opts ...FollowFeedOption) (*BaseResponse, error)

+ func (f *FlatFeed) FollowStats(ctx context.Context, opts ...FollowStatOption) (*FollowStatResponse, error)

+ func (f *FlatFeed) GetActivities(ctx context.Context, opts ...GetActivitiesOption) (*FlatFeedResponse, error)

+ func (f *FlatFeed) GetActivitiesWithRanking(ctx context.Context, ranking string, opts ...GetActivitiesOption) (*FlatFeedResponse, error)

+ func (f *FlatFeed) GetEnrichedActivities(ctx context.Context, opts ...GetActivitiesOption) (*EnrichedFlatFeedResponse, error)

+ func (f *FlatFeed) GetEnrichedActivitiesWithRanking(ctx context.Context, ranking string, opts ...GetActivitiesOption) (*EnrichedFlatFeedResponse, error)

+ func (f *FlatFeed) GetFollowers(ctx context.Context, opts ...FollowersOption) (*FollowersResponse, error)

+ func (f *FlatFeed) GetFollowing(ctx context.Context, opts ...FollowingOption) (*FollowingResponse, error)

+ func (f *FlatFeed) GetNextPageActivities(ctx context.Context, resp *FlatFeedResponse) (*FlatFeedResponse, error)

+ func (f *FlatFeed) GetNextPageEnrichedActivities(ctx context.Context, resp *EnrichedFlatFeedResponse) (*EnrichedFlatFeedResponse, error)

+ func (f *FlatFeed) ID() string

+ func (f *FlatFeed) RealtimeToken(readonly bool) string

+ func (f *FlatFeed) RemoveActivityByForeignID(ctx context.Context, foreignID string) (*RemoveActivityResponse, error)

+ func (f *FlatFeed) RemoveActivityByID(ctx context.Context, id string) (*RemoveActivityResponse, error)

+ func (f *FlatFeed) Slug() string

+ func (f *FlatFeed) Unfollow(ctx context.Context, target Feed, opts ...UnfollowOption) (*BaseResponse, error)

+ func (f *FlatFeed) UpdateToTargets(ctx context.Context, activity Activity, opts ...UpdateToTargetsOption) (*UpdateToTargetsResponse, error)

+ func (f *FlatFeed) UserID() string

+ type FlatFeedResponse struct

+ Results []Activity

+ type FollowFeedOption func(*followFeedOptions)

+ func WithFollowFeedActivityCopyLimit(activityCopyLimit int) FollowFeedOption

+ type FollowManyOption struct

+ func WithFollowManyActivityCopyLimit(activityCopyLimit int) FollowManyOption

+ type FollowRelationship struct

+ ActivityCopyLimit *int

+ Source string

+ Target string

+ func NewFollowRelationship(source, target Feed, opts ...FollowRelationshipOption) FollowRelationship

+ type FollowRelationshipOption func(r *FollowRelationship)

+ func WithFollowRelationshipActivityCopyLimit(activityCopyLimit int) FollowRelationshipOption

+ type FollowStatOption struct

+ func WithFollowerSlugs(slugs ...string) FollowStatOption

+ func WithFollowingSlugs(slugs ...string) FollowStatOption

+ type FollowStatResponse struct

+ type Follower struct

+ FeedID string

+ TargetID string

+ type FollowersOption struct

+ func WithFollowersLimit(limit int) FollowersOption

+ func WithFollowersOffset(offset int) FollowersOption

+ type FollowersResponse struct

+ type FollowingOption struct

+ func WithFollowingFilter(ids ...string) FollowingOption

+ func WithFollowingLimit(limit int) FollowingOption

+ func WithFollowingOffset(offset int) FollowingOption

+ type FollowingResponse struct

+ type ForeignIDTimePair struct

+ ForeignID string

+ Timestamp Time

+ func NewForeignIDTimePair(foreignID string, timestamp Time) ForeignIDTimePair

+ type GetActivitiesOption struct

+ func WithActivitiesIDGT(id string) GetActivitiesOption

+ func WithActivitiesIDGTE(id string) GetActivitiesOption

+ func WithActivitiesIDLT(id string) GetActivitiesOption

+ func WithActivitiesIDLTE(id string) GetActivitiesOption

+ func WithActivitiesLimit(limit int) GetActivitiesOption

+ func WithActivitiesOffset(offset int) GetActivitiesOption

+ func WithCustomParam(name, value string) GetActivitiesOption

+ func WithEnrichFirstReactions() GetActivitiesOption

+ func WithEnrichOwnChildren() GetActivitiesOption

+ func WithEnrichOwnChildrenKindsFilter(kinds ...string) GetActivitiesOption

+ func WithEnrichOwnReactions() GetActivitiesOption

+ func WithEnrichReactionCounts() GetActivitiesOption

+ func WithEnrichReactionKindsFilter(kinds ...string) GetActivitiesOption

+ func WithEnrichReactionsLimit(limit int) GetActivitiesOption

+ func WithEnrichRecentReactions() GetActivitiesOption

+ func WithEnrichRecentReactionsLimit(limit int) GetActivitiesOption

+ func WithNotificationsMarkRead(all bool, activityIDs ...string) GetActivitiesOption

+ func WithNotificationsMarkSeen(all bool, activityIDs ...string) GetActivitiesOption

+ type GetActivitiesResponse struct

+ Results []Activity

+ type GetCollectionResponse struct

+ Objects []GetCollectionResponseObject

+ type GetCollectionResponseObject struct

+ Data map[string]any

+ ForeignID string

+ type GetEnrichedActivitiesResponse struct

+ Results []EnrichedActivity

+ type ImpressionEventsData map[string]any

+ func (d ImpressionEventsData) AddForeignIDs(foreignIDs ...string) ImpressionEventsData

+ func (d ImpressionEventsData) WithFeatures(features ...EventFeature) ImpressionEventsData

+ func (d ImpressionEventsData) WithFeedID(feedID string) ImpressionEventsData

+ func (d ImpressionEventsData) WithForeignIDs(foreignIDs ...string) ImpressionEventsData

+ func (d ImpressionEventsData) WithLocation(location string) ImpressionEventsData

+ func (d ImpressionEventsData) WithPosition(position int) ImpressionEventsData

+ func (d ImpressionEventsData) WithTrackedAt(trackedAt time.Time) ImpressionEventsData

+ func (d ImpressionEventsData) WithUserData(userData *UserData) ImpressionEventsData

+ type NotificationFeed struct

+ func (f *NotificationFeed) AddActivities(ctx context.Context, activities ...Activity) (*AddActivitiesResponse, error)

+ func (f *NotificationFeed) AddActivity(ctx context.Context, activity Activity) (*AddActivityResponse, error)

+ func (f *NotificationFeed) Follow(ctx context.Context, feed *FlatFeed, opts ...FollowFeedOption) (*BaseResponse, error)

+ func (f *NotificationFeed) GetActivities(ctx context.Context, opts ...GetActivitiesOption) (*NotificationFeedResponse, error)

+ func (f *NotificationFeed) GetEnrichedActivities(ctx context.Context, opts ...GetActivitiesOption) (*EnrichedNotificationFeedResponse, error)

+ func (f *NotificationFeed) GetFollowing(ctx context.Context, opts ...FollowingOption) (*FollowingResponse, error)

+ func (f *NotificationFeed) GetNextPageActivities(ctx context.Context, resp *NotificationFeedResponse) (*NotificationFeedResponse, error)

+ func (f *NotificationFeed) GetNextPageEnrichedActivities(ctx context.Context, resp *EnrichedNotificationFeedResponse) (*EnrichedNotificationFeedResponse, error)

+ func (f *NotificationFeed) ID() string

+ func (f *NotificationFeed) RealtimeToken(readonly bool) string

+ func (f *NotificationFeed) RemoveActivityByForeignID(ctx context.Context, foreignID string) (*RemoveActivityResponse, error)

+ func (f *NotificationFeed) RemoveActivityByID(ctx context.Context, id string) (*RemoveActivityResponse, error)

+ func (f *NotificationFeed) Slug() string

+ func (f *NotificationFeed) Unfollow(ctx context.Context, target Feed, opts ...UnfollowOption) (*BaseResponse, error)

+ func (f *NotificationFeed) UpdateToTargets(ctx context.Context, activity Activity, opts ...UpdateToTargetsOption) (*UpdateToTargetsResponse, error)

+ func (f *NotificationFeed) UserID() string

+ type NotificationFeedResponse struct

+ Results []NotificationFeedResult

+ type NotificationFeedResult struct

+ Activities []Activity

+ type PersonalizationClient struct

+ func (c *PersonalizationClient) Delete(ctx context.Context, resource string, params map[string]any) (*PersonalizationResponse, error)

+ func (c *PersonalizationClient) Get(ctx context.Context, resource string, params map[string]any) (*PersonalizationResponse, error)

+ func (c *PersonalizationClient) Post(ctx context.Context, resource string, params, data map[string]any) (*PersonalizationResponse, error)

+ type PersonalizationResponse struct

+ AppID int

+ Duration Duration

+ Limit int

+ Next string

+ Offset int

+ Rate Rate

+ Results []map[string]any

+ Version string

+ func (r *PersonalizationResponse) Extra() map[string]any

+ func (r *PersonalizationResponse) UnmarshalJSON(data []byte) error

+ type Rate struct

+ Limit int

+ Remaining int

+ Reset Time

+ func NewRate(headers http.Header) *Rate

+ type Reaction struct

+ ChildrenCounters map[string]any

+ ChildrenReactions map[string][]*Reaction

+ CreatedAt time.Time

+ OwnChildren map[string][]*Reaction

+ UpdatedAt time.Time

+ User User

+ type ReactionResponse struct

+ type ReactionsClient struct

+ func (c *ReactionsClient) Add(ctx context.Context, r AddReactionRequestObject) (*ReactionResponse, error)

+ func (c *ReactionsClient) AddChild(ctx context.Context, parentID string, r AddReactionRequestObject) (*ReactionResponse, error)

+ func (c *ReactionsClient) Delete(ctx context.Context, id string) (*ReactionResponse, error)

+ func (c *ReactionsClient) Filter(ctx context.Context, attr FilterReactionsAttribute, ...) (*FilterReactionResponse, error)

+ func (c *ReactionsClient) Get(ctx context.Context, id string) (*ReactionResponse, error)

+ func (c *ReactionsClient) GetNextPageFilteredReactions(ctx context.Context, resp *FilterReactionResponse) (*FilterReactionResponse, error)

+ func (c *ReactionsClient) Update(ctx context.Context, id string, data map[string]any, targetFeeds []string) (*ReactionResponse, error)

+ type RemoveActivityResponse struct

+ Removed string

+ type Requester interface

+ Do func(*http.Request) (*http.Response, error)

+ type Time struct

+ func (t *Time) UnmarshalJSON(b []byte) error

+ func (t Time) MarshalJSON() ([]byte, error)

+ type UnfollowOption struct

+ func WithUnfollowKeepHistory(keepHistory bool) UnfollowOption

+ type UnfollowRelationship struct

+ KeepHistory bool

+ Source string

+ Target string

+ func NewUnfollowRelationship(source, target Feed, opts ...UnfollowRelationshipOption) UnfollowRelationship

+ type UnfollowRelationshipOption func(r *UnfollowRelationship)

+ func WithUnfollowRelationshipKeepHistory() UnfollowRelationshipOption

+ type UpdateActivitiesResponse struct

+ Activities []*Activity

+ type UpdateActivityRequest struct

+ ForeignID *string

+ ID *string

+ Set map[string]any

+ Time *Time

+ Unset []string

+ func NewUpdateActivityRequestByForeignID(foreignID string, timestamp Time, set map[string]any, unset []string) UpdateActivityRequest

+ func NewUpdateActivityRequestByID(id string, set map[string]any, unset []string) UpdateActivityRequest

+ type UpdateActivityResponse struct

+ func (a *UpdateActivityResponse) UnmarshalJSON(buf []byte) error

+ type UpdateToTargetsOption func(*updateToTargetsRequest)

+ func WithToTargetsAdd(targets ...string) UpdateToTargetsOption

+ func WithToTargetsNew(targets ...string) UpdateToTargetsOption

+ func WithToTargetsRemove(targets ...string) UpdateToTargetsOption

+ type UpdateToTargetsResponse struct

+ Activity map[string]any

+ Added []string

+ Removed []string

+ type User struct

+ Data map[string]any

+ ID string

+ type UserData struct

+ func NewUserData() *UserData

+ func (d *UserData) Alias(alias string) *UserData

+ func (d *UserData) Int(id int) *UserData

+ func (d *UserData) String(id string) *UserData

+ type UserResponse struct

+ type UsersClient struct

+ func (c *UsersClient) Add(ctx context.Context, user User, getOrCreate bool) (*UserResponse, error)

+ func (c *UsersClient) CreateReference(id string) string

+ func (c *UsersClient) Delete(ctx context.Context, id string) (*BaseResponse, error)

+ func (c *UsersClient) Get(ctx context.Context, id string) (*UserResponse, error)

+ func (c *UsersClient) Update(ctx context.Context, id string, data map[string]any) (*UserResponse, error)

Other modules containing this package

github.com/GetStream/stream-go2

github.com/GetStream/stream-go2/v4

github.com/GetStream/stream-go2/v5

github.com/GetStream/stream-go2/v6

github.com/GetStream/stream-go2/v7

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL