Documentation ¶
Index ¶
- type EmailSender
- type TwProxyServiceClient
- func (_m *TwProxyServiceClient) GetUserInfo(ctx context.Context, in *rpc.UserInfoRequest, opts ...grpc.CallOption) (*rpc.UserInfo, error)
- func (_m *TwProxyServiceClient) GetUserTimeline(ctx context.Context, in *rpc.UserTimelineRequest, opts ...grpc.CallOption) (*rpc.UserTimelineResponse, error)
- func (_m *TwProxyServiceClient) SearchUsers(ctx context.Context, in *rpc.UserSearchRequest, opts ...grpc.CallOption) (*rpc.UserSearchResult, error)
- type UserDatastore
- func (_m *UserDatastore) AcquireLock(ctx context.Context, key uint) (bool, error)
- func (_m *UserDatastore) DeleteSubscription(ctx context.Context, subscription models.Subscription) error
- func (_m *UserDatastore) GetNewSubscriptionsUsers(ctx context.Context, subscriptionIDs ...uuid.UUID) (map[uuid.UUID][]string, error)
- func (_m *UserDatastore) GetReadySubscriptionsStates(ctx context.Context, subscriptionIDs ...uuid.UUID) ([]models.SubscriptionState, error)
- func (_m *UserDatastore) GetSubscription(ctx context.Context, subscriptionID uuid.UUID) (models.Subscription, error)
- func (_m *UserDatastore) GetSubscriptionTweets(ctx context.Context, subscriptionStateID uint) ([]models.Tweet, error)
- func (_m *UserDatastore) GetSubscriptionUserTweets(ctx context.Context, subscriptionID uuid.UUID) (models.SubscriptionUserTweets, error)
- func (_m *UserDatastore) GetSubscriptions(ctx context.Context, userID uuid.UUID) ([]models.Subscription, error)
- func (_m *UserDatastore) GetTodaySubscriptionsIDs(ctx context.Context) ([]uuid.UUID, error)
- func (_m *UserDatastore) GetTwitterUser(ctx context.Context, userID uuid.UUID) (models.TwitterUser, error)
- func (_m *UserDatastore) GetTwitterUserByID(ctx context.Context, twitterUserID string) (models.TwitterUser, error)
- func (_m *UserDatastore) GetUser(ctx context.Context, userID uuid.UUID) (models.User, error)
- func (_m *UserDatastore) GetUserEmail(ctx context.Context, userEmail models.UserEmail) (models.UserEmail, error)
- func (_m *UserDatastore) GetUserEmails(ctx context.Context, status string) ([]models.UserEmail, error)
- func (_m *UserDatastore) InsertSubscription(ctx context.Context, subscription models.Subscription) (models.Subscription, error)
- func (_m *UserDatastore) InsertSubscriptionState(ctx context.Context, state models.SubscriptionState) (models.SubscriptionState, error)
- func (_m *UserDatastore) InsertSubscriptionUserState(ctx context.Context, subscriptionID uuid.UUID, userTwitterID string, ...) error
- func (_m *UserDatastore) InsertTweet(ctx context.Context, tweet models.Tweet, subscriptionStateID uint) (models.Tweet, error)
- func (_m *UserDatastore) InsertTwitterUser(ctx context.Context, twitterUser models.TwitterUser) (models.TwitterUser, error)
- func (_m *UserDatastore) InsertUser(ctx context.Context, user models.User) (models.User, error)
- func (_m *UserDatastore) InsertUserEmail(ctx context.Context, userEmail models.UserEmail) (models.UserEmail, error)
- func (_m *UserDatastore) ReleaseLock(ctx context.Context, key uint) (bool, error)
- func (_m *UserDatastore) RemoveOldTweets(ctx context.Context, tweetTTL int) error
- func (_m *UserDatastore) RemoveUser(ctx context.Context, userID uuid.UUID) error
- func (_m *UserDatastore) UpdateSubscription(ctx context.Context, subscription models.Subscription) (models.Subscription, error)
- func (_m *UserDatastore) UpdateSubscriptionState(ctx context.Context, state models.SubscriptionState) (models.SubscriptionState, error)
- func (_m *UserDatastore) UpdateSubscriptionUserState(ctx context.Context, subscriptionID uuid.UUID, userTwitterID string, ...) error
- func (_m *UserDatastore) UpdateSubscriptionUserStateTweets(ctx context.Context) error
- func (_m *UserDatastore) UpdateTwitterUser(ctx context.Context, twitterUser models.TwitterUser) (models.TwitterUser, error)
- func (_m *UserDatastore) UpdateUser(ctx context.Context, user models.User) (models.User, error)
- func (_m *UserDatastore) UpdateUserEmail(ctx context.Context, userEmail models.UserEmail) (models.UserEmail, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EmailSender ¶
EmailSender is an autogenerated mock type for the EmailSender type
type TwProxyServiceClient ¶
TwProxyServiceClient is an autogenerated mock type for the TwProxyServiceClient type
func (*TwProxyServiceClient) GetUserInfo ¶
func (_m *TwProxyServiceClient) GetUserInfo(ctx context.Context, in *rpc.UserInfoRequest, opts ...grpc.CallOption) (*rpc.UserInfo, error)
GetUserInfo provides a mock function with given fields: ctx, in, opts
func (*TwProxyServiceClient) GetUserTimeline ¶
func (_m *TwProxyServiceClient) GetUserTimeline(ctx context.Context, in *rpc.UserTimelineRequest, opts ...grpc.CallOption) (*rpc.UserTimelineResponse, error)
GetUserTimeline provides a mock function with given fields: ctx, in, opts
func (*TwProxyServiceClient) SearchUsers ¶
func (_m *TwProxyServiceClient) SearchUsers(ctx context.Context, in *rpc.UserSearchRequest, opts ...grpc.CallOption) (*rpc.UserSearchResult, error)
SearchUsers provides a mock function with given fields: ctx, in, opts
type UserDatastore ¶
UserDatastore is an autogenerated mock type for the UserDatastore type
func (*UserDatastore) AcquireLock ¶
AcquireLock provides a mock function with given fields: ctx, key
func (*UserDatastore) DeleteSubscription ¶
func (_m *UserDatastore) DeleteSubscription(ctx context.Context, subscription models.Subscription) error
DeleteSubscription provides a mock function with given fields: ctx, subscription
func (*UserDatastore) GetNewSubscriptionsUsers ¶
func (_m *UserDatastore) GetNewSubscriptionsUsers(ctx context.Context, subscriptionIDs ...uuid.UUID) (map[uuid.UUID][]string, error)
GetNewSubscriptionsUsers provides a mock function with given fields: ctx, subscriptionIDs
func (*UserDatastore) GetReadySubscriptionsStates ¶
func (_m *UserDatastore) GetReadySubscriptionsStates(ctx context.Context, subscriptionIDs ...uuid.UUID) ([]models.SubscriptionState, error)
GetReadySubscriptionsStates provides a mock function with given fields: ctx, subscriptionIDs
func (*UserDatastore) GetSubscription ¶
func (_m *UserDatastore) GetSubscription(ctx context.Context, subscriptionID uuid.UUID) (models.Subscription, error)
GetSubscription provides a mock function with given fields: ctx, subscriptionID
func (*UserDatastore) GetSubscriptionTweets ¶
func (_m *UserDatastore) GetSubscriptionTweets(ctx context.Context, subscriptionStateID uint) ([]models.Tweet, error)
GetSubscriptionTweets provides a mock function with given fields: ctx, subscriptionStateID
func (*UserDatastore) GetSubscriptionUserTweets ¶
func (_m *UserDatastore) GetSubscriptionUserTweets(ctx context.Context, subscriptionID uuid.UUID) (models.SubscriptionUserTweets, error)
GetSubscriptionUserTweets provides a mock function with given fields: ctx, subscriptionID
func (*UserDatastore) GetSubscriptions ¶
func (_m *UserDatastore) GetSubscriptions(ctx context.Context, userID uuid.UUID) ([]models.Subscription, error)
GetSubscriptions provides a mock function with given fields: ctx, userID
func (*UserDatastore) GetTodaySubscriptionsIDs ¶
GetTodaySubscriptionsIDs provides a mock function with given fields: ctx
func (*UserDatastore) GetTwitterUser ¶
func (_m *UserDatastore) GetTwitterUser(ctx context.Context, userID uuid.UUID) (models.TwitterUser, error)
GetTwitterUser provides a mock function with given fields: ctx, userID
func (*UserDatastore) GetTwitterUserByID ¶
func (_m *UserDatastore) GetTwitterUserByID(ctx context.Context, twitterUserID string) (models.TwitterUser, error)
GetTwitterUserByID provides a mock function with given fields: ctx, twitterUserID
func (*UserDatastore) GetUserEmail ¶
func (_m *UserDatastore) GetUserEmail(ctx context.Context, userEmail models.UserEmail) (models.UserEmail, error)
GetUserEmail provides a mock function with given fields: ctx, userEmail
func (*UserDatastore) GetUserEmails ¶
func (_m *UserDatastore) GetUserEmails(ctx context.Context, status string) ([]models.UserEmail, error)
GetUserEmails provides a mock function with given fields: ctx, status
func (*UserDatastore) InsertSubscription ¶
func (_m *UserDatastore) InsertSubscription(ctx context.Context, subscription models.Subscription) (models.Subscription, error)
InsertSubscription provides a mock function with given fields: ctx, subscription
func (*UserDatastore) InsertSubscriptionState ¶
func (_m *UserDatastore) InsertSubscriptionState(ctx context.Context, state models.SubscriptionState) (models.SubscriptionState, error)
InsertSubscriptionState provides a mock function with given fields: ctx, state
func (*UserDatastore) InsertSubscriptionUserState ¶
func (_m *UserDatastore) InsertSubscriptionUserState(ctx context.Context, subscriptionID uuid.UUID, userTwitterID string, lastTweetID string) error
InsertSubscriptionUserState provides a mock function with given fields: ctx, subscriptionID, userTwitterID, lastTweetID
func (*UserDatastore) InsertTweet ¶
func (_m *UserDatastore) InsertTweet(ctx context.Context, tweet models.Tweet, subscriptionStateID uint) (models.Tweet, error)
InsertTweet provides a mock function with given fields: ctx, tweet, subscriptionStateID
func (*UserDatastore) InsertTwitterUser ¶
func (_m *UserDatastore) InsertTwitterUser(ctx context.Context, twitterUser models.TwitterUser) (models.TwitterUser, error)
InsertTwitterUser provides a mock function with given fields: ctx, twitterUser
func (*UserDatastore) InsertUser ¶
InsertUser provides a mock function with given fields: ctx, user
func (*UserDatastore) InsertUserEmail ¶
func (_m *UserDatastore) InsertUserEmail(ctx context.Context, userEmail models.UserEmail) (models.UserEmail, error)
InsertUserEmail provides a mock function with given fields: ctx, userEmail
func (*UserDatastore) ReleaseLock ¶
ReleaseLock provides a mock function with given fields: ctx, key
func (*UserDatastore) RemoveOldTweets ¶
func (_m *UserDatastore) RemoveOldTweets(ctx context.Context, tweetTTL int) error
RemoveOldTweets provides a mock function with given fields: ctx, tweetTTL
func (*UserDatastore) RemoveUser ¶
RemoveUser provides a mock function with given fields: ctx, userID
func (*UserDatastore) UpdateSubscription ¶
func (_m *UserDatastore) UpdateSubscription(ctx context.Context, subscription models.Subscription) (models.Subscription, error)
UpdateSubscription provides a mock function with given fields: ctx, subscription
func (*UserDatastore) UpdateSubscriptionState ¶
func (_m *UserDatastore) UpdateSubscriptionState(ctx context.Context, state models.SubscriptionState) (models.SubscriptionState, error)
UpdateSubscriptionState provides a mock function with given fields: ctx, state
func (*UserDatastore) UpdateSubscriptionUserState ¶
func (_m *UserDatastore) UpdateSubscriptionUserState(ctx context.Context, subscriptionID uuid.UUID, userTwitterID string, lastTweetID string) error
UpdateSubscriptionUserState provides a mock function with given fields: ctx, subscriptionID, userTwitterID, lastTweetID
func (*UserDatastore) UpdateSubscriptionUserStateTweets ¶
func (_m *UserDatastore) UpdateSubscriptionUserStateTweets(ctx context.Context) error
UpdateSubscriptionUserStateTweets provides a mock function with given fields: ctx
func (*UserDatastore) UpdateTwitterUser ¶
func (_m *UserDatastore) UpdateTwitterUser(ctx context.Context, twitterUser models.TwitterUser) (models.TwitterUser, error)
UpdateTwitterUser provides a mock function with given fields: ctx, twitterUser
func (*UserDatastore) UpdateUser ¶
UpdateUser provides a mock function with given fields: ctx, user
func (*UserDatastore) UpdateUserEmail ¶
func (_m *UserDatastore) UpdateUserEmail(ctx context.Context, userEmail models.UserEmail) (models.UserEmail, error)
UpdateUserEmail provides a mock function with given fields: ctx, userEmail