summaryrefslogtreecommitdiffstats
path: root/vendor/github.com/SevereCloud/vksdk/v2/api/streaming.go
blob: c3484e69dd5a10a1f084a791ff3ef0e9dda2a079 (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
package api // import "github.com/SevereCloud/vksdk/v2/api"

// StreamingGetServerURLResponse struct.
type StreamingGetServerURLResponse struct {
	Endpoint string `json:"endpoint"`
	Key      string `json:"key"`
}

// StreamingGetServerURL allows to receive data for the connection to Streaming API.
//
// https://vk.com/dev/streaming.getServerUrl
func (vk *VK) StreamingGetServerURL(params Params) (response StreamingGetServerURLResponse, err error) {
	err = vk.RequestUnmarshal("streaming.getServerUrl", &response, params)
	return
}

// StreamingGetSettingsResponse struct.
type StreamingGetSettingsResponse struct {
	MonthlyLimit string `json:"monthly_limit"`
}

// StreamingGetSettings allows to receive monthly tier for Streaming API.
//
// https://vk.com/dev/streaming.getSettings
func (vk *VK) StreamingGetSettings(params Params) (response StreamingGetSettingsResponse, err error) {
	err = vk.RequestUnmarshal("streaming.getSettings", &response, params)
	return
}

// StreamingGetStatsResponse struct.
type StreamingGetStatsResponse []struct {
	EventType string `json:"event_type"`
	Stats     []struct {
		Timestamp int `json:"timestamp"`
		Value     int `json:"value"`
	} `json:"stats"`
}

// StreamingGetStats allows to receive statistics for prepared and received events in Streaming API.
//
// https://vk.com/dev/streaming.getStats
func (vk *VK) StreamingGetStats(params Params) (response StreamingGetStatsResponse, err error) {
	err = vk.RequestUnmarshal("streaming.getStats", &response, params)
	return
}

// StreamingGetStemResponse struct.
type StreamingGetStemResponse struct {
	Stem string `json:"stem"`
}

// StreamingGetStem allows to receive the stem of the word.
//
// https://vk.com/dev/streaming.getStem
func (vk *VK) StreamingGetStem(params Params) (response StreamingGetStemResponse, err error) {
	err = vk.RequestUnmarshal("streaming.getStem", &response, params)
	return
}

// StreamingSetSettings allows to set monthly tier for Streaming API.
//
// https://vk.com/dev/streaming.setSettings
func (vk *VK) StreamingSetSettings(params Params) (response int, err error) {
	err = vk.RequestUnmarshal("streaming.setSettings", &response, params)

	return
}