stream

package module

Go to main page

Versions in this module

v1

v1.14.0

Nov 16, 2018

v1.13.0

Oct 22, 2018

Changes in this version

type Client

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

+ func (c *Client) GetUserSessionTokenWithClaims(userID string, claims map[string]interface{}) (string, error)

v1.12.0

Sep 4, 2018

Changes in this version

type CollectionsClient

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

+ func (c *CollectionsClient) CreateUserReference(id string) string

v1.11.0

Aug 6, 2018

Changes in this version

type Client

+ func (c *Client) UpdateActivities(activities ...Activity) error

v1.10.0

Jul 30, 2018

Changes in this version

+ type GetCollectionResponseObject struct

+ Data map[string]interface{}

+ ForeignID string

v1.9.1

Jul 26, 2018

Changes in this version

type Client

+ func (c *Client) UpdateActivityByForeignID(foreignID string, timestamp Time, set map[string]interface{}, unset []string) (*UpdateActivityResponse, error)

+ func (c *Client) UpdateActivityByID(id string, set map[string]interface{}, unset []string) (*UpdateActivityResponse, error)

+ type UpdateActivityResponse struct

v1.9.0

Jun 12, 2018

Changes in this version

type Client

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

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

+ type ForeignIDTimePair struct

+ ForeignID string

+ Timestamp Time

+ func NewForeignIDTimePair(foreignID string, timestamp Time) ForeignIDTimePair

+ type GetActivitiesResponse struct

+ Results []Activity

v1.8.1

Jun 5, 2018

v1.8.0

May 1, 2018

Changes in this version

type Client

+ func (c *Client) UnfollowMany(relationships []UnfollowRelationship) error

+ type UnfollowRelationship struct

+ KeepHistory bool

+ Source string

+ Target string

v1.7.0

Apr 13, 2018

Changes in this version

type Client

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

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

+ type CollectionObject struct

+ Data map[string]interface{}

+ ID string

+ Name string

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

+ type CollectionsClient struct

+ func (c *CollectionsClient) Delete(collection string, ids ...string) error

+ func (c *CollectionsClient) Get(collection string, ids ...string) ([]CollectionObject, error)

+ func (c *CollectionsClient) Upsert(collection string, objects ...CollectionObject) error

+ type PersonalizationClient struct

+ func (c *PersonalizationClient) Delete(resource string, params map[string]interface{}) error

+ func (c *PersonalizationClient) Get(resource string, params map[string]interface{}) (*PersonalizationResponse, error)

+ func (c *PersonalizationClient) Post(resource string, params map[string]interface{}, data map[string]interface{}) error

+ type PersonalizationResponse struct

+ AppID int

+ Duration Duration

+ Limit int

+ Offset int

+ Results []map[string]interface{}

+ Version string

+ func (r *PersonalizationResponse) Extra() map[string]interface{}

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

v1.6.0

Apr 11, 2018

Changes in this version

+ type AnalyticsClient struct

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

+ func (c *AnalyticsClient) TrackEngagement(events ...EngagementEvent) error

+ func (c *AnalyticsClient) TrackImpression(eventsData ImpressionEventsData) error

type Client

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

+ type EngagementEvent map[string]interface

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

+ func (e EngagementEvent) WithContent(foreignID string, content map[string]interface{}) 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 EventFeature struct

+ Group string

+ Value string

+ func NewEventFeature(group, value string) EventFeature

+ type ImpressionEventsData map[string]interface

+ 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 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

v1.5.5

Mar 1, 2018

Changes in this version

+ var Version = "v1.5.5"

v1.5.4

Feb 9, 2018

v1.5.3

Feb 2, 2018

v1.5.1

Jan 31, 2018

Changes in this version

+ const TimeLayout

+ var ErrInvalidNextPage = fmt.Errorf("invalid format for Next field")

+ var ErrMissingNextPage = fmt.Errorf("request missing next page")

+ type APIError struct

+ Code int

+ Detail string

+ Duration Duration

+ Exception string

+ ExceptionFields map[string][]interface{}

+ StatusCode int

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

+ func (e APIError) Error() string

+ type Activity struct

+ Actor string

+ Extra map[string]interface{}

+ 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

+ ActivityCount int

+ ActorCount int

+ Group string

+ ID string

+ Verb string

+ type AddActivitiesResponse struct

+ Activities []Activity

+ type AddActivityResponse struct

+ type AddToManyRequest struct

+ Activity Activity

+ FeedIDs []string

+ type AggregatedFeed struct

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

+ func (f *AggregatedFeed) AddActivity(activity Activity) (*AddActivityResponse, error)

+ func (f *AggregatedFeed) Follow(feed *FlatFeed, opts ...FollowFeedOption) error

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

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

+ func (f *AggregatedFeed) GetNextPageActivities(resp *AggregatedFeedResponse) (*AggregatedFeedResponse, error)

+ func (f *AggregatedFeed) ID() string

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

+ func (f *AggregatedFeed) RemoveActivityByForeignID(foreignID string) error

+ func (f *AggregatedFeed) RemoveActivityByID(id string) error

+ func (f *AggregatedFeed) Slug() string

+ func (f *AggregatedFeed) Unfollow(target Feed, opts ...UnfollowOption) error

+ func (f *AggregatedFeed) UpdateActivities(activities ...Activity) error

+ func (f *AggregatedFeed) UpdateToTargets(activity Activity, opts ...UpdateToTargetsOption) error

+ func (f *AggregatedFeed) UserID() string

+ type AggregatedFeedResponse struct

+ Results []ActivityGroup

+ type Client struct

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

+ func NewClientFromEnv() (*Client, error)

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

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

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

+ func (c *Client) FollowMany(relationships []FollowRelationship, opts ...FollowManyOption) error

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

+ type ClientOption func(*Client)

+ func WithAPIRegion(region string) ClientOption

+ func WithAPIVersion(version string) ClientOption

+ func WithHTTPRequester(requester Requester) ClientOption

+ type Duration struct

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

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

+ type Feed interface

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

+ AddActivity func(Activity) (*AddActivityResponse, error)

+ Follow func(*FlatFeed, ...FollowFeedOption) error

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

+ ID func() string

+ RealtimeToken func(bool) string

+ RemoveActivityByForeignID func(string) error

+ RemoveActivityByID func(string) error

+ Slug func() string

+ Unfollow func(Feed, ...UnfollowOption) error

+ UpdateActivities func(...Activity) error

+ UpdateToTargets func(Activity, ...UpdateToTargetsOption) error

+ UserID func() string

+ type FlatFeed struct

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

+ func (f *FlatFeed) AddActivity(activity Activity) (*AddActivityResponse, error)

+ func (f *FlatFeed) Follow(feed *FlatFeed, opts ...FollowFeedOption) error

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

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

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

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

+ func (f *FlatFeed) GetNextPageActivities(resp *FlatFeedResponse) (*FlatFeedResponse, error)

+ func (f *FlatFeed) ID() string

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

+ func (f *FlatFeed) RemoveActivityByForeignID(foreignID string) error

+ func (f *FlatFeed) RemoveActivityByID(id string) error

+ func (f *FlatFeed) Slug() string

+ func (f *FlatFeed) Unfollow(target Feed, opts ...UnfollowOption) error

+ func (f *FlatFeed) UpdateActivities(activities ...Activity) error

+ func (f *FlatFeed) UpdateToTargets(activity Activity, opts ...UpdateToTargetsOption) 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 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 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 WithNotificationsMarkRead(all bool, activityIDs ...string) GetActivitiesOption

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

+ type NotificationFeed struct

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

+ func (f *NotificationFeed) AddActivity(activity Activity) (*AddActivityResponse, error)

+ func (f *NotificationFeed) Follow(feed *FlatFeed, opts ...FollowFeedOption) error

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

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

+ func (f *NotificationFeed) GetNextPageActivities(resp *NotificationFeedResponse) (*NotificationFeedResponse, error)

+ func (f *NotificationFeed) ID() string

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

+ func (f *NotificationFeed) RemoveActivityByForeignID(foreignID string) error

+ func (f *NotificationFeed) RemoveActivityByID(id string) error

+ func (f *NotificationFeed) Slug() string

+ func (f *NotificationFeed) Unfollow(target Feed, opts ...UnfollowOption) error

+ func (f *NotificationFeed) UpdateActivities(activities ...Activity) error

+ func (f *NotificationFeed) UpdateToTargets(activity Activity, opts ...UpdateToTargetsOption) error

+ func (f *NotificationFeed) UserID() string

+ type NotificationFeedResponse struct

+ Results []NotificationFeedResult

+ Unread int

+ Unseen int

+ type NotificationFeedResult struct

+ Activities []Activity

+ ActivityCount int

+ ActorCount int

+ Group string

+ ID string

+ IsRead bool

+ IsSeen bool

+ Verb 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 UpdateToTargetsOption func(*updateToTargetsRequest)

+ func WithToTargetsAdd(targets ...string) UpdateToTargetsOption

+ func WithToTargetsNew(targets ...string) UpdateToTargetsOption

+ func WithToTargetsRemove(targets ...string) UpdateToTargetsOption

Incompatible versions in this module

v3.2.1+incompatible

Mar 1, 2019

v3.2.0+incompatible

Feb 7, 2019

v3.1.1+incompatible

Jan 24, 2019

v3.1.0+incompatible

Jan 17, 2019

v3.0.0+incompatible

Jan 8, 2019

v2.0.1+incompatible

Dec 19, 2018

v2.0.0+incompatible

Dec 13, 2018

Other modules containing this package

github.com/flockfw64/stream-go2/v7

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