streaming

Documentation

Index

• type Streaming
  • func New(cfgs ...StreamingConfiguration) (Streaming, error)
  • func (s Streaming) FloatAndGiftCommit(userId int64, transactionId int64) (entity.FloatMessageInfo, error)
  • func (s Streaming) FloatMessageInit(userId int64, liveId int64, floatMessageChatBody entity.FloatMessageChatBody) (entity.RequestGiftInfo, error)
  • func (s Streaming) GetLiveUrlInfo(liveId int64) (entity.LiveUrlInfo, error)
  • func (s Streaming) GetMemberLiveInfo(userId string, liveId string) (entity.LiveInfoData, error)
  • func (s Streaming) GetMemberLiveUrlInfo(userId int64, liveId string) (entity.LiveUrlInfo, error)
  • func (s Streaming) GiftInit(userId int64, liveId int64, giftBody entity.GiftBody) (entity.RequestGiftInfo, error)
  • func (s Streaming) SendMemberLiveGift(userId int64, liveId string, giftBody entity.GiftBody) (resty.Response, error)
  • func (s Streaming) UpdateUserFavorite(userId string, liveId string) (resty.Response, error)
  • func (s Streaming) UpdateUserUnFavorite(userId string, liveId string) (resty.Response, error)
• type StreamingConfiguration
  • func WithClient(client *resty.Client) StreamingConfiguration
• type StreamingRepository

Types

type Streaming

type Streaming struct {
	Client *resty.Client
}

func New

func New(cfgs ...StreamingConfiguration) (Streaming, error)

func (Streaming) FloatAndGiftCommit

func (s Streaming) FloatAndGiftCommit(userId int64, transactionId int64) (entity.FloatMessageInfo, error)

func (Streaming) FloatMessageInit

func (s Streaming) FloatMessageInit(userId int64, liveId int64, floatMessageChatBody entity.FloatMessageChatBody) (entity.RequestGiftInfo, error)

func (Streaming) GetLiveUrlInfo

func (s Streaming) GetLiveUrlInfo(liveId int64) (entity.LiveUrlInfo, error)

func (Streaming) GetMemberLiveInfo

func (s Streaming) GetMemberLiveInfo(userId string, liveId string) (entity.LiveInfoData, error)

func (Streaming) GetMemberLiveUrlInfo

func (s Streaming) GetMemberLiveUrlInfo(userId int64, liveId string) (entity.LiveUrlInfo, error)

func (Streaming) GiftInit

func (s Streaming) GiftInit(userId int64, liveId int64, giftBody entity.GiftBody) (entity.RequestGiftInfo, error)

func (Streaming) SendMemberLiveGift

func (s Streaming) SendMemberLiveGift(userId int64, liveId string, giftBody entity.GiftBody) (resty.Response, error)

func (Streaming) UpdateUserFavorite

func (s Streaming) UpdateUserFavorite(userId string, liveId string) (resty.Response, error)

func (Streaming) UpdateUserUnFavorite

func (s Streaming) UpdateUserUnFavorite(userId string, liveId string) (resty.Response, error)

type StreamingConfiguration

type StreamingConfiguration func(*Streaming) error

func WithClient

func WithClient(client *resty.Client) StreamingConfiguration

type StreamingRepository

type StreamingRepository interface {
	// @POST("/user/{userId}/transaction/{transactionId}/commit")
	// g.b.l<FloatMessageInfo> floatAndGiftCommit(@Path("userId") long j2, @Path("transactionId") long j3);
	FloatAndGiftCommit(userId int64, transactionId int64) (entity.FloatMessageInfo, error)

	// @POST("/user/{userId}/floatmsg/member-live/{liveId}/request")
	// g.b.l<RequestGiftInfo> floatMessageInit(@Path("userId") long j2, @Path("liveId") long j3, @Body @NotNull FloatMessageChatBody floatMessageChatBody);
	FloatMessageInit(userId int64, liveId int64, floatMessageChatBody entity.FloatMessageChatBody) (entity.RequestGiftInfo, error)

	// @GET("/live/{liveId}")
	// g.b.l<LiveUrlInfo> getLiveUrlInfo(@Path("liveId") long j2);
	GetLiveUrlInfo(liveId int64) (entity.LiveUrlInfo, error)

	// @GET("/user/{userId}/info/member-live/{liveId}")
	// g.b.l<LiveInfoData> getMemberLiveInfo(@Path("userId") @NotNull String str, @Path("liveId") @NotNull String str2);
	GetMemberLiveInfo(userId string, liveId string) (entity.LiveInfoData, error)

	// @GET("/user/{userId}/watch/member-live/{liveId}")
	// g.b.l<LiveUrlInfo> getMemberLiveUrlInfo(@Path("userId") long j2, @Path("liveId") @NotNull String str);
	GetMemberLiveUrlInfo(userId int64, liveId string) (entity.LiveUrlInfo, error)

	// @POST("/user/{userId}/gifts/member-live/{liveId}/request")
	// g.b.l<RequestGiftInfo> giftInit(@Path("userId") long j2, @Path("liveId") long j3, @Body @NotNull GiftBody giftBody);
	GiftInit(userId int64, liveId int64, giftBody entity.GiftBody) (entity.RequestGiftInfo, error)

	// @POST("/user/{userId}/gifts/member-live/{liveId}")
	// g.b.l<f0> sendGift(@Path("userId") long j2, @Path("liveId") @NotNull String str, @Body @NotNull GiftBody giftBody);
	// Renamed to SendMemberLiveGift
	SendMemberLiveGift(userId int64, liveId string, giftBody entity.GiftBody) (resty.Response, error)

	// @PUT("/user/{userId}/favorite/member-live/{liveId}")
	// g.b.l<f0> updateUserFavorite(@Path("userId") @NotNull String str, @Path("liveId") @NotNull String str2);
	UpdateUserFavorite(userId string, liveId string) (resty.Response, error)

	// @DELETE("/user/{userId}/favorite/member-live/{liveId}")
	// g.b.l<f0> updateUserUnFavorite(@Path("userId") @NotNull String str, @Path("liveId") @NotNull String str2);
	UpdateUserUnFavorite(userId string, liveId string) (resty.Response, error)
}