Documentation ¶
Index ¶
- type AddLineNotification
- type AddLineNotificationParams
- type CheckUstream
- type CrawlFeed
- type CrawlFeedParams
- type CrawlFeeds
- type EnqueueLines
- type EnqueueLinesParams
- type EnqueueTweets
- type EnqueueTweetsParams
- type HandleLineBotEvents
- type HandleLineBotEventsParams
- type LineNotify
- type LineNotifyBroadcast
- type LineNotifyBroadcastParams
- type LineNotifyParams
- type Remind
- type Tweet
- type TweetParams
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AddLineNotification ¶
type AddLineNotification struct {
// contains filtered or unexported fields
}
AddLineNotification use case
func NewAddLineNotification ¶
func NewAddLineNotification( logger core.Logger, token model.LineNotifyToken, repo model.LineNotificationRepository) *AddLineNotification
NewAddLineNotification returns AddLineNotification use case
func (*AddLineNotification) Do ¶
func (use *AddLineNotification) Do(params AddLineNotificationParams) error
Do add line notification entity
type AddLineNotificationParams ¶
type AddLineNotificationParams struct {
Code string
}
AddLineNotificationParams use case params
type CheckUstream ¶
type CheckUstream struct {
// contains filtered or unexported fields
}
CheckUstream use case
func NewCheckUstream ¶
func NewCheckUstream( logger core.Logger, taskQueue event.TaskQueue, checker model.UstreamStatusChecker, repo model.UstreamStatusRepository) *CheckUstream
NewCheckUstream returns CheckUstream use case
type CrawlFeed ¶
type CrawlFeed struct {
// contains filtered or unexported fields
}
CrawlFeed use case
func NewCrawlFeed ¶
func NewCrawlFeed( log core.Logger, feed model.FeedFetcher, taskQueue event.TaskQueue, repo model.LatestEntryRepository) *CrawlFeed
NewCrawlFeed returns Crawl use case
func (*CrawlFeed) Do ¶
func (use *CrawlFeed) Do(params CrawlFeedParams) error
Do crawls a site and invokes tweet and line event
type CrawlFeedParams ¶
CrawlFeedParams input parameters
type CrawlFeeds ¶
type CrawlFeeds struct {
// contains filtered or unexported fields
}
CrawlFeeds use case
func NewCrawlFeeds ¶
func NewCrawlFeeds(logger core.Logger, crawl *CrawlFeed) *CrawlFeeds
NewCrawlFeeds returns CrawlAll use case
type EnqueueLines ¶
type EnqueueLines struct {
// contains filtered or unexported fields
}
EnqueueLines use case
func NewEnqueueLines ¶
func NewEnqueueLines( log core.Logger, taskQueue event.TaskQueue, transactor model.Transactor, repo model.LineItemRepository) *EnqueueLines
NewEnqueueLines returns EnqueueLines use case
func (*EnqueueLines) Do ¶
func (use *EnqueueLines) Do(params EnqueueLinesParams) error
Do converts feeds to line notify requests and enqueue it
type EnqueueLinesParams ¶
EnqueueLinesParams input parameters
type EnqueueTweets ¶
type EnqueueTweets struct {
// contains filtered or unexported fields
}
EnqueueTweets use case
func NewEnqueueTweets ¶
func NewEnqueueTweets( log core.Logger, taskQueue event.TaskQueue, transactor model.Transactor, repo model.TweetItemRepository) *EnqueueTweets
NewEnqueueTweets returns EnqueueTweets use case
func (*EnqueueTweets) Do ¶
func (use *EnqueueTweets) Do(params EnqueueTweetsParams) error
Do converts feeds to tweet requests and enqueue it
type EnqueueTweetsParams ¶
EnqueueTweetsParams input parameters
type HandleLineBotEvents ¶
type HandleLineBotEvents struct {
// contains filtered or unexported fields
}
HandleLineBotEvents use case
func NewHandleLineBotEvents ¶
func NewHandleLineBotEvents( logger core.Logger, lineBot model.LineBot, imageSearcher model.ImageSearcher) *HandleLineBotEvents
NewHandleLineBotEvents returns HandleLineBotEvents use case
func (*HandleLineBotEvents) Do ¶
func (use *HandleLineBotEvents) Do(params HandleLineBotEventsParams) error
Do handles given line bot events
type HandleLineBotEventsParams ¶
type HandleLineBotEventsParams struct {
Events []model.LineBotEvent
}
HandleLineBotEventsParams use case params
type LineNotify ¶
type LineNotify struct {
// contains filtered or unexported fields
}
LineNotify use case
func NewLineNotify ¶
func NewLineNotify( log core.Logger, taskQueue event.TaskQueue, notify model.LineNotify, repo model.LineNotificationRepository) *LineNotify
NewLineNotify returns LineNotify use case
type LineNotifyBroadcast ¶
type LineNotifyBroadcast struct {
// contains filtered or unexported fields
}
LineNotifyBroadcast use case
func NewLineNotifyBroadcast ¶
func NewLineNotifyBroadcast( log core.Logger, taskQueue event.TaskQueue, repo model.LineNotificationRepository) *LineNotifyBroadcast
NewLineNotifyBroadcast returns LineNotifyBroadcast use case
func (*LineNotifyBroadcast) Do ¶
func (use *LineNotifyBroadcast) Do(params LineNotifyBroadcastParams) error
Do notify broadcast
type LineNotifyBroadcastParams ¶
type LineNotifyBroadcastParams struct {
Messages []model.LineNotifyMessage `validate:"min=1,dive"`
}
LineNotifyBroadcastParams input parameters
type LineNotifyParams ¶
type LineNotifyParams struct {
Request model.LineNotifyRequest
}
LineNotifyParams input parameters
type Remind ¶
type Remind struct {
// contains filtered or unexported fields
}
Remind use case
type Tweet ¶
type Tweet struct {
// contains filtered or unexported fields
}
Tweet use case
type TweetParams ¶
type TweetParams struct {
Requests []model.TweetRequest `validate:"min=1,dive"`
}
TweetParams input parameters