Golang crowdsound.CrowdSoundClient类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Go›Go教程

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Golang中github.com/crowdsoundsystem/go-client/pkg/crowdsound.CrowdSoundClient类的典型用法代码示例。如果您正苦于以下问题：Golang CrowdSoundClient类的具体用法？Golang CrowdSoundClient怎么用？Golang CrowdSoundClient使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

在下文中一共展示了CrowdSoundClient类的12个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Golang代码示例。

示例1: RunPostSongsBench

func RunPostSongsBench(c crowdsound.CrowdSoundClient, amount, songsToPost int) (metrics.Histogram, error) {
	h := metrics.NewHistogram(metrics.NewUniformSample(amount))

	userID := randomString(32)
	for i := 0; i < amount; i++ {
		start := time.Now()

		stream, err := c.PostSong(context.Background())
		if err != nil {
			return h, err
		}

		for song := range songGenerator(songsToPost, 0.1) {
			song.UserId = userID
			if err = stream.Send(song); err != nil {
				return h, err
			}
		}

		stream.CloseAndRecv()

		h.Update(time.Since(start).Nanoseconds())
	}

	return h, nil
}

开发者ID:CrowdSoundSystem，项目名称:go-client，代码行数:26，代码来源:posters.go

示例2: printQueue

func printQueue(client crowdsound.CrowdSoundClient) {
	stream, err := client.GetQueue(context.Background(), &crowdsound.GetQueueRequest{
		UserId: *userID,
	})
	if err != nil {
		log.Fatalf("Error calling GetQueue(): %v", err)
	}

	var count int

	for {
		song, err := stream.Recv()
		if err == io.EOF {
			break
		}
		if err != nil {
			log.Fatalf("Error retrieving song: %v", err)
		}

		if song.IsBuffered {
			if song.IsPlaying {
				log.Printf("Song: [%v] %v - %v (buffered) (playing)", song.Genre, song.Artist, song.Name)
			} else {
				log.Printf("Song: [%v] %v - %v (buffered)", song.Genre, song.Artist, song.Name)
			}
		} else {
			log.Printf("Song: [%v] %v - %v", song.Genre, song.Artist, song.Name)
		}
		count++
	}

	log.Println("Queue size:", count)
}

开发者ID:CrowdSoundSystem，项目名称:go-client，代码行数:33，代码来源:main.go

示例3: printPlaying

func printPlaying(client crowdsound.CrowdSoundClient) {
	resp, err := client.GetPlaying(context.Background(), &crowdsound.GetPlayingRequest{})
	if err != nil {
		log.Fatalf("Error calling GetPlaying(): %v", err)
	}

	log.Println("Playing:", resp)
}

开发者ID:CrowdSoundSystem，项目名称:go-client，代码行数:8，代码来源:main.go

示例4: printMeta

func printMeta(client crowdsound.CrowdSoundClient) {
	resp, err := client.GetSessionData(context.Background(), &crowdsound.GetSessionDataRequest{})
	if err != nil {
		log.Fatalf("Error calling GetSessionData(): %v", err)
	}

	log.Println("Session Data:", resp)
}

开发者ID:CrowdSoundSystem，项目名称:go-client，代码行数:8，代码来源:main.go

示例5: voteSkip

func voteSkip(client crowdsound.CrowdSoundClient) {
	_, err := client.VoteSkip(context.Background(), &crowdsound.VoteSkipRequest{
		UserId: *userID,
	})
	if err != nil {
		log.Fatalf("Error calling VoteSkip(): %v", err)
	}

	log.Println("Voted for skip")
}

开发者ID:CrowdSoundSystem，项目名称:go-client，代码行数:10，代码来源:main.go

示例6: vote

func vote(client crowdsound.CrowdSoundClient) {
	_, err := client.VoteSong(context.Background(), &crowdsound.VoteSongRequest{
		UserId: *userID,
		Name:   songs[4].Name,
		Artist: songs[4].Artist[0],
		Like:   true,
	})
	if err != nil {
		log.Fatalf("Error calling VoteSong(): %v", err)
	}
}

开发者ID:CrowdSoundSystem，项目名称:go-client，代码行数:11，代码来源:main.go

示例7: RunGetSessionDataBench

func RunGetSessionDataBench(c crowdsound.CrowdSoundClient, amount int) (metrics.Histogram, error) {
	h := metrics.NewHistogram(metrics.NewUniformSample(amount))
	for i := 0; i < amount; i++ {
		start := time.Now()
		if _, err := c.GetSessionData(context.Background(), &crowdsound.GetSessionDataRequest{}); err != nil {
			return h, err
		}

		h.Update(time.Since(start).Nanoseconds())
	}

	return h, nil
}

开发者ID:CrowdSoundSystem，项目名称:go-client，代码行数:13，代码来源:posters.go

示例8: postSongs

func postSongs(client crowdsound.CrowdSoundClient) {
	stream, err := client.PostSong(context.Background())
	if err != nil {
		log.Fatalf("Error calling PostSong(): %v", err)
	}
	defer stream.CloseAndRecv()

	for _, song := range songs {
		log.Println("Posting song:", song)
		song.UserId = *userID
		err := stream.Send(song)
		if err != nil {
			log.Fatalf("Error sending song: %v", err)
		}
	}
}

开发者ID:CrowdSoundSystem，项目名称:go-client，代码行数:16，代码来源:main.go

示例9: RunGetQueueBench

func RunGetQueueBench(c crowdsound.CrowdSoundClient, amount int) (metrics.Histogram, error) {
	h := metrics.NewHistogram(metrics.NewUniformSample(amount))

	// To make the queue meaningful, we want there to actually
	// be a queue. Idealy, we could try various queue sizes, but
	// time is of the essence!
	postStream, err := c.PostSong(context.Background())
	if err != nil {
		return h, err
	}

	for song := range songGenerator(10, 0) {
		song.UserId = randomString(32)
		if err = postStream.Send(song); err != nil {
			return h, err
		}
	}

	if _, err = postStream.CloseAndRecv(); err != nil {
		return h, err
	}

	for i := 0; i < amount; i++ {
		start := time.Now()
		queueStream, err := c.GetQueue(context.Background(), &crowdsound.GetQueueRequest{})
		if err != nil {
			return h, err
		}

		for {
			_, err := queueStream.Recv()
			if err == io.EOF {
				break
			}
			if err != nil {
				log.Fatal(err)
			}
		}

		h.Update(time.Since(start).Nanoseconds())
	}

	return h, nil
}

开发者ID:CrowdSoundSystem，项目名称:go-client，代码行数:44，代码来源:query.go

示例10: RunListTrendingArtists

func RunListTrendingArtists(c crowdsound.CrowdSoundClient, amount int) (metrics.Histogram, error) {
	h := metrics.NewHistogram(metrics.NewUniformSample(amount))

	// To make trending artists meaningful, add a bunch of artists.
	postStream, err := c.PostSong(context.Background())
	if err != nil {
		return h, err
	}

	for song := range songGenerator(100, 1.0) {
		song.UserId = randomString(32)
		if err = postStream.Send(song); err != nil {
			return h, err
		}
	}

	if _, err = postStream.CloseAndRecv(); err != nil {
		return h, err
	}

	for i := 0; i < amount; i++ {
		start := time.Now()
		listStream, err := c.ListTrendingArtists(context.Background(), &crowdsound.ListTrendingArtistsRequest{})
		if err != nil {
			return h, err
		}

		for {
			_, err := listStream.Recv()
			if err == io.EOF {
				break
			}
			if err != nil {
				log.Fatal(err)
			}
		}

		h.Update(time.Since(start).Nanoseconds())
	}

	return h, nil
}

开发者ID:CrowdSoundSystem，项目名称:go-client，代码行数:42，代码来源:query.go

示例11: RunVoteSongsBench

func RunVoteSongsBench(c crowdsound.CrowdSoundClient, amount int) (metrics.Histogram, error) {
	h := metrics.NewHistogram(metrics.NewUniformSample(amount))

	// Generate songs to vote on
	postStream, err := c.PostSong(context.Background())
	if err != nil {
		return h, err
	}

	var songToVote *crowdsound.PostSongRequest
	for song := range songGenerator(1, 0) {
		song.UserId = randomString(32)
		if err = postStream.Send(song); err != nil {
			return h, err
		}
		songToVote = song
	}

	if _, err = postStream.CloseAndRecv(); err != nil {
		return h, err
	}

	userID := randomString(32)
	for i := 0; i < amount; i++ {
		start := time.Now()
		_, err := c.VoteSong(context.Background(), &crowdsound.VoteSongRequest{
			UserId: userID,
			Name:   songToVote.Name,
			Artist: songToVote.Artist[0],
			Like:   true,
		})
		if err != nil {
			return h, err
		}

		h.Update(time.Since(start).Nanoseconds())
	}

	return h, nil
}

开发者ID:CrowdSoundSystem，项目名称:go-client，代码行数:40，代码来源:posters.go

示例12: ping

func ping(client crowdsound.CrowdSoundClient) {
	_, err := client.Ping(context.Background(), &crowdsound.PingRequest{UserId: *userID})
	if err != nil {
		log.Fatalf("Error calling Ping(): %v", err)
	}
}

开发者ID:CrowdSoundSystem，项目名称:go-client，代码行数:6，代码来源:main.go

注：本文中的github.com/crowdsoundsystem/go-client/pkg/crowdsound.CrowdSoundClient类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。