tweetworfklow

Documentation

Index

• Variables
• func ProcessTweet(ctx workflow.Context, tweet *tweetDomainModel.Tweet) error
• type TweetActivities
  • func NewTweetActivities(tweetRepository tweet.Repository) TweetActivities

Variables

var SaveTweetReference = (&tweetActivities{}).SaveTweet

Functions

func ProcessTweet

func ProcessTweet(ctx workflow.Context, tweet *tweetDomainModel.Tweet) error

Types

type TweetActivities

type TweetActivities interface {
	SaveTweet(tweet *tweetDomainModel.Tweet) error
}

func NewTweetActivities

func NewTweetActivities(tweetRepository tweet.Repository) TweetActivities