diff --git a/ChangeLog.txt b/ChangeLog.txt index ff8f8bae6..b969cfead 100644 --- a/ChangeLog.txt +++ b/ChangeLog.txt @@ -1,3 +1,7 @@ +2023-08-08 Version: v1.62.507 +- Generated 2016-11-01 for `live`. +undefined + 2023-08-03 Version: v1.62.506 - Generated 2021-01-01 for `Ft`. undefined diff --git a/services/live/add_custom_live_stream_transcode.go b/services/live/add_custom_live_stream_transcode.go index 42af5afde..c5e593ed2 100644 --- a/services/live/add_custom_live_stream_transcode.go +++ b/services/live/add_custom_live_stream_transcode.go @@ -71,24 +71,28 @@ func (client *Client) AddCustomLiveStreamTranscodeWithCallback(request *AddCusto // AddCustomLiveStreamTranscodeRequest is the request struct for api AddCustomLiveStreamTranscode type AddCustomLiveStreamTranscodeRequest struct { *requests.RpcRequest - Template string `position:"Query" name:"Template"` - Lazy string `position:"Query" name:"Lazy"` + ResWithSource string `position:"Query" name:"ResWithSource"` Gop string `position:"Query" name:"Gop"` - KmsKeyExpireInterval string `position:"Query" name:"KmsKeyExpireInterval"` AudioCodec string `position:"Query" name:"AudioCodec"` KmsUID string `position:"Query" name:"KmsUID"` - TemplateType string `position:"Query" name:"TemplateType"` - AudioProfile string `position:"Query" name:"AudioProfile"` Height requests.Integer `position:"Query" name:"Height"` App string `position:"Query" name:"App"` + Profile requests.Integer `position:"Query" name:"Profile"` + OwnerId requests.Integer `position:"Query" name:"OwnerId"` + ExtWithSource string `position:"Query" name:"ExtWithSource"` + BitrateWithSource string `position:"Query" name:"BitrateWithSource"` + Domain string `position:"Query" name:"Domain"` + Template string `position:"Query" name:"Template"` + Lazy string `position:"Query" name:"Lazy"` + KmsKeyExpireInterval string `position:"Query" name:"KmsKeyExpireInterval"` + TemplateType string `position:"Query" name:"TemplateType"` + AudioProfile string `position:"Query" name:"AudioProfile"` EncryptParameters string `position:"Query" name:"EncryptParameters"` AudioChannelNum requests.Integer `position:"Query" name:"AudioChannelNum"` - Profile requests.Integer `position:"Query" name:"Profile"` FPS requests.Integer `position:"Query" name:"FPS"` - OwnerId requests.Integer `position:"Query" name:"OwnerId"` AudioRate requests.Integer `position:"Query" name:"AudioRate"` + FpsWithSource string `position:"Query" name:"FpsWithSource"` AudioBitrate requests.Integer `position:"Query" name:"AudioBitrate"` - Domain string `position:"Query" name:"Domain"` Width requests.Integer `position:"Query" name:"Width"` VideoBitrate requests.Integer `position:"Query" name:"VideoBitrate"` KmsKeyID string `position:"Query" name:"KmsKeyID"` diff --git a/services/live/add_live_app_record_config.go b/services/live/add_live_app_record_config.go index ae4adbc44..a5212b48e 100644 --- a/services/live/add_live_app_record_config.go +++ b/services/live/add_live_app_record_config.go @@ -72,6 +72,7 @@ func (client *Client) AddLiveAppRecordConfigWithCallback(request *AddLiveAppReco type AddLiveAppRecordConfigRequest struct { *requests.RpcRequest OssEndpoint string `position:"Query" name:"OssEndpoint"` + DelayTime requests.Integer `position:"Query" name:"DelayTime"` TranscodeTemplates *[]string `position:"Query" name:"TranscodeTemplates" type:"Repeated"` StartTime string `position:"Query" name:"StartTime"` AppName string `position:"Query" name:"AppName"` diff --git a/services/live/add_live_record_vod_config.go b/services/live/add_live_record_vod_config.go index 82f391b6f..b8322f128 100644 --- a/services/live/add_live_record_vod_config.go +++ b/services/live/add_live_record_vod_config.go @@ -75,6 +75,7 @@ type AddLiveRecordVodConfigRequest struct { ComposeVodTranscodeGroupId string `position:"Query" name:"ComposeVodTranscodeGroupId"` StorageLocation string `position:"Query" name:"StorageLocation"` AppName string `position:"Query" name:"AppName"` + OnDemand requests.Integer `position:"Query" name:"OnDemand"` StreamName string `position:"Query" name:"StreamName"` VodTranscodeGroupId string `position:"Query" name:"VodTranscodeGroupId"` DomainName string `position:"Query" name:"DomainName"` diff --git a/services/live/create_event_sub.go b/services/live/create_event_sub.go index 25ae53e72..258c6e9f3 100644 --- a/services/live/create_event_sub.go +++ b/services/live/create_event_sub.go @@ -71,13 +71,14 @@ func (client *Client) CreateEventSubWithCallback(request *CreateEventSubRequest, // CreateEventSubRequest is the request struct for api CreateEventSub type CreateEventSubRequest struct { *requests.RpcRequest - Role requests.Integer `position:"Query" name:"Role"` - ClientToken string `position:"Query" name:"ClientToken"` - Users *[]string `position:"Query" name:"Users" type:"Repeated"` - AppId string `position:"Query" name:"AppId"` - CallbackUrl string `position:"Query" name:"CallbackUrl"` - ChannelId string `position:"Query" name:"ChannelId"` - Events *[]string `position:"Query" name:"Events" type:"Repeated"` + Role requests.Integer `position:"Query" name:"Role"` + ClientToken string `position:"Query" name:"ClientToken"` + NeedCallbackAuthorization requests.Boolean `position:"Query" name:"NeedCallbackAuthorization"` + Users *[]string `position:"Query" name:"Users" type:"Repeated"` + AppId string `position:"Query" name:"AppId"` + CallbackUrl string `position:"Query" name:"CallbackUrl"` + ChannelId string `position:"Query" name:"ChannelId"` + Events *[]string `position:"Query" name:"Events" type:"Repeated"` } // CreateEventSubResponse is the response struct for api CreateEventSub diff --git a/services/live/delete_live_stream_block.go b/services/live/delete_live_stream_block.go new file mode 100644 index 000000000..54480a7fd --- /dev/null +++ b/services/live/delete_live_stream_block.go @@ -0,0 +1,104 @@ +package live + +//Licensed under the Apache License, Version 2.0 (the "License"); +//you may not use this file except in compliance with the License. +//You may obtain a copy of the License at +// +//http://www.apache.org/licenses/LICENSE-2.0 +// +//Unless required by applicable law or agreed to in writing, software +//distributed under the License is distributed on an "AS IS" BASIS, +//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +//See the License for the specific language governing permissions and +//limitations under the License. +// +// Code generated by Alibaba Cloud SDK Code Generator. +// Changes may cause incorrect behavior and will be lost if the code is regenerated. + +import ( + "github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests" + "github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses" +) + +// DeleteLiveStreamBlock invokes the live.DeleteLiveStreamBlock API synchronously +func (client *Client) DeleteLiveStreamBlock(request *DeleteLiveStreamBlockRequest) (response *DeleteLiveStreamBlockResponse, err error) { + response = CreateDeleteLiveStreamBlockResponse() + err = client.DoAction(request, response) + return +} + +// DeleteLiveStreamBlockWithChan invokes the live.DeleteLiveStreamBlock API asynchronously +func (client *Client) DeleteLiveStreamBlockWithChan(request *DeleteLiveStreamBlockRequest) (<-chan *DeleteLiveStreamBlockResponse, <-chan error) { + responseChan := make(chan *DeleteLiveStreamBlockResponse, 1) + errChan := make(chan error, 1) + err := client.AddAsyncTask(func() { + defer close(responseChan) + defer close(errChan) + response, err := client.DeleteLiveStreamBlock(request) + if err != nil { + errChan <- err + } else { + responseChan <- response + } + }) + if err != nil { + errChan <- err + close(responseChan) + close(errChan) + } + return responseChan, errChan +} + +// DeleteLiveStreamBlockWithCallback invokes the live.DeleteLiveStreamBlock API asynchronously +func (client *Client) DeleteLiveStreamBlockWithCallback(request *DeleteLiveStreamBlockRequest, callback func(response *DeleteLiveStreamBlockResponse, err error)) <-chan int { + result := make(chan int, 1) + err := client.AddAsyncTask(func() { + var response *DeleteLiveStreamBlockResponse + var err error + defer close(result) + response, err = client.DeleteLiveStreamBlock(request) + callback(response, err) + result <- 1 + }) + if err != nil { + defer close(result) + callback(nil, err) + result <- 0 + } + return result +} + +// DeleteLiveStreamBlockRequest is the request struct for api DeleteLiveStreamBlock +type DeleteLiveStreamBlockRequest struct { + *requests.RpcRequest + AppName string `position:"Query" name:"AppName"` + StreamName string `position:"Query" name:"StreamName"` + DomainName string `position:"Query" name:"DomainName"` + OwnerId requests.Integer `position:"Query" name:"OwnerId"` +} + +// DeleteLiveStreamBlockResponse is the response struct for api DeleteLiveStreamBlock +type DeleteLiveStreamBlockResponse struct { + *responses.BaseResponse + Status string `json:"Status" xml:"Status"` + RequestId string `json:"RequestId" xml:"RequestId"` + Description string `json:"Description" xml:"Description"` +} + +// CreateDeleteLiveStreamBlockRequest creates a request to invoke DeleteLiveStreamBlock API +func CreateDeleteLiveStreamBlockRequest() (request *DeleteLiveStreamBlockRequest) { + request = &DeleteLiveStreamBlockRequest{ + RpcRequest: &requests.RpcRequest{}, + } + request.InitWithApiInfo("live", "2016-11-01", "DeleteLiveStreamBlock", "live", "openAPI") + request.Method = requests.POST + return +} + +// CreateDeleteLiveStreamBlockResponse creates a response to parse from DeleteLiveStreamBlock response +func CreateDeleteLiveStreamBlockResponse() (response *DeleteLiveStreamBlockResponse) { + response = &DeleteLiveStreamBlockResponse{ + BaseResponse: &responses.BaseResponse{}, + } + return +} diff --git a/services/live/describe_channel_users.go b/services/live/describe_channel_users.go new file mode 100644 index 000000000..4afc08634 --- /dev/null +++ b/services/live/describe_channel_users.go @@ -0,0 +1,106 @@ +package live + +//Licensed under the Apache License, Version 2.0 (the "License"); +//you may not use this file except in compliance with the License. +//You may obtain a copy of the License at +// +//http://www.apache.org/licenses/LICENSE-2.0 +// +//Unless required by applicable law or agreed to in writing, software +//distributed under the License is distributed on an "AS IS" BASIS, +//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +//See the License for the specific language governing permissions and +//limitations under the License. +// +// Code generated by Alibaba Cloud SDK Code Generator. +// Changes may cause incorrect behavior and will be lost if the code is regenerated. + +import ( + "github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests" + "github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses" +) + +// DescribeChannelUsers invokes the live.DescribeChannelUsers API synchronously +func (client *Client) DescribeChannelUsers(request *DescribeChannelUsersRequest) (response *DescribeChannelUsersResponse, err error) { + response = CreateDescribeChannelUsersResponse() + err = client.DoAction(request, response) + return +} + +// DescribeChannelUsersWithChan invokes the live.DescribeChannelUsers API asynchronously +func (client *Client) DescribeChannelUsersWithChan(request *DescribeChannelUsersRequest) (<-chan *DescribeChannelUsersResponse, <-chan error) { + responseChan := make(chan *DescribeChannelUsersResponse, 1) + errChan := make(chan error, 1) + err := client.AddAsyncTask(func() { + defer close(responseChan) + defer close(errChan) + response, err := client.DescribeChannelUsers(request) + if err != nil { + errChan <- err + } else { + responseChan <- response + } + }) + if err != nil { + errChan <- err + close(responseChan) + close(errChan) + } + return responseChan, errChan +} + +// DescribeChannelUsersWithCallback invokes the live.DescribeChannelUsers API asynchronously +func (client *Client) DescribeChannelUsersWithCallback(request *DescribeChannelUsersRequest, callback func(response *DescribeChannelUsersResponse, err error)) <-chan int { + result := make(chan int, 1) + err := client.AddAsyncTask(func() { + var response *DescribeChannelUsersResponse + var err error + defer close(result) + response, err = client.DescribeChannelUsers(request) + callback(response, err) + result <- 1 + }) + if err != nil { + defer close(result) + callback(nil, err) + result <- 0 + } + return result +} + +// DescribeChannelUsersRequest is the request struct for api DescribeChannelUsers +type DescribeChannelUsersRequest struct { + *requests.RpcRequest + AppId string `position:"Query" name:"AppId"` + ChannelId string `position:"Query" name:"ChannelId"` +} + +// DescribeChannelUsersResponse is the response struct for api DescribeChannelUsers +type DescribeChannelUsersResponse struct { + *responses.BaseResponse + RequestId string `json:"RequestId" xml:"RequestId"` + Timestamp int64 `json:"Timestamp" xml:"Timestamp"` + IsChannelExists bool `json:"IsChannelExists" xml:"IsChannelExists"` + InteractiveUserNumber int `json:"InteractiveUserNumber" xml:"InteractiveUserNumber"` + LiveUserNumber int `json:"LiveUserNumber" xml:"LiveUserNumber"` + InteractiveUserList []string `json:"InteractiveUserList" xml:"InteractiveUserList"` + LiveUserList []string `json:"LiveUserList" xml:"LiveUserList"` +} + +// CreateDescribeChannelUsersRequest creates a request to invoke DescribeChannelUsers API +func CreateDescribeChannelUsersRequest() (request *DescribeChannelUsersRequest) { + request = &DescribeChannelUsersRequest{ + RpcRequest: &requests.RpcRequest{}, + } + request.InitWithApiInfo("live", "2016-11-01", "DescribeChannelUsers", "live", "openAPI") + request.Method = requests.POST + return +} + +// CreateDescribeChannelUsersResponse creates a response to parse from DescribeChannelUsers response +func CreateDescribeChannelUsersResponse() (response *DescribeChannelUsersResponse) { + response = &DescribeChannelUsersResponse{ + BaseResponse: &responses.BaseResponse{}, + } + return +} diff --git a/services/live/describe_live_cdn_diagnose_info.go b/services/live/describe_live_cdn_diagnose_info.go new file mode 100644 index 000000000..cc7190d41 --- /dev/null +++ b/services/live/describe_live_cdn_diagnose_info.go @@ -0,0 +1,107 @@ +package live + +//Licensed under the Apache License, Version 2.0 (the "License"); +//you may not use this file except in compliance with the License. +//You may obtain a copy of the License at +// +//http://www.apache.org/licenses/LICENSE-2.0 +// +//Unless required by applicable law or agreed to in writing, software +//distributed under the License is distributed on an "AS IS" BASIS, +//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +//See the License for the specific language governing permissions and +//limitations under the License. +// +// Code generated by Alibaba Cloud SDK Code Generator. +// Changes may cause incorrect behavior and will be lost if the code is regenerated. + +import ( + "github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests" + "github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses" +) + +// DescribeLiveCdnDiagnoseInfo invokes the live.DescribeLiveCdnDiagnoseInfo API synchronously +func (client *Client) DescribeLiveCdnDiagnoseInfo(request *DescribeLiveCdnDiagnoseInfoRequest) (response *DescribeLiveCdnDiagnoseInfoResponse, err error) { + response = CreateDescribeLiveCdnDiagnoseInfoResponse() + err = client.DoAction(request, response) + return +} + +// DescribeLiveCdnDiagnoseInfoWithChan invokes the live.DescribeLiveCdnDiagnoseInfo API asynchronously +func (client *Client) DescribeLiveCdnDiagnoseInfoWithChan(request *DescribeLiveCdnDiagnoseInfoRequest) (<-chan *DescribeLiveCdnDiagnoseInfoResponse, <-chan error) { + responseChan := make(chan *DescribeLiveCdnDiagnoseInfoResponse, 1) + errChan := make(chan error, 1) + err := client.AddAsyncTask(func() { + defer close(responseChan) + defer close(errChan) + response, err := client.DescribeLiveCdnDiagnoseInfo(request) + if err != nil { + errChan <- err + } else { + responseChan <- response + } + }) + if err != nil { + errChan <- err + close(responseChan) + close(errChan) + } + return responseChan, errChan +} + +// DescribeLiveCdnDiagnoseInfoWithCallback invokes the live.DescribeLiveCdnDiagnoseInfo API asynchronously +func (client *Client) DescribeLiveCdnDiagnoseInfoWithCallback(request *DescribeLiveCdnDiagnoseInfoRequest, callback func(response *DescribeLiveCdnDiagnoseInfoResponse, err error)) <-chan int { + result := make(chan int, 1) + err := client.AddAsyncTask(func() { + var response *DescribeLiveCdnDiagnoseInfoResponse + var err error + defer close(result) + response, err = client.DescribeLiveCdnDiagnoseInfo(request) + callback(response, err) + result <- 1 + }) + if err != nil { + defer close(result) + callback(nil, err) + result <- 0 + } + return result +} + +// DescribeLiveCdnDiagnoseInfoRequest is the request struct for api DescribeLiveCdnDiagnoseInfo +type DescribeLiveCdnDiagnoseInfoRequest struct { + *requests.RpcRequest + IntervalType string `position:"Query" name:"intervalType"` + StreamSuffix string `position:"Query" name:"streamSuffix"` + StartTime requests.Integer `position:"Query" name:"startTime"` + RequestType string `position:"Query" name:"requestType"` + StreamName string `position:"Query" name:"streamName"` + App string `position:"Query" name:"app"` + Phase requests.Integer `position:"Query" name:"phase"` + EndTime requests.Integer `position:"Query" name:"endTime"` + Domain string `position:"Query" name:"domain"` +} + +// DescribeLiveCdnDiagnoseInfoResponse is the response struct for api DescribeLiveCdnDiagnoseInfo +type DescribeLiveCdnDiagnoseInfoResponse struct { + *responses.BaseResponse + RequestId string `json:"RequestId" xml:"RequestId"` +} + +// CreateDescribeLiveCdnDiagnoseInfoRequest creates a request to invoke DescribeLiveCdnDiagnoseInfo API +func CreateDescribeLiveCdnDiagnoseInfoRequest() (request *DescribeLiveCdnDiagnoseInfoRequest) { + request = &DescribeLiveCdnDiagnoseInfoRequest{ + RpcRequest: &requests.RpcRequest{}, + } + request.InitWithApiInfo("live", "2016-11-01", "DescribeLiveCdnDiagnoseInfo", "live", "openAPI") + request.Method = requests.POST + return +} + +// CreateDescribeLiveCdnDiagnoseInfoResponse creates a response to parse from DescribeLiveCdnDiagnoseInfo response +func CreateDescribeLiveCdnDiagnoseInfoResponse() (response *DescribeLiveCdnDiagnoseInfoResponse) { + response = &DescribeLiveCdnDiagnoseInfoResponse{ + BaseResponse: &responses.BaseResponse{}, + } + return +} diff --git a/services/live/describe_live_domain_transcode_params.go b/services/live/describe_live_domain_transcode_params.go new file mode 100644 index 000000000..b1254a1a8 --- /dev/null +++ b/services/live/describe_live_domain_transcode_params.go @@ -0,0 +1,101 @@ +package live + +//Licensed under the Apache License, Version 2.0 (the "License"); +//you may not use this file except in compliance with the License. +//You may obtain a copy of the License at +// +//http://www.apache.org/licenses/LICENSE-2.0 +// +//Unless required by applicable law or agreed to in writing, software +//distributed under the License is distributed on an "AS IS" BASIS, +//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +//See the License for the specific language governing permissions and +//limitations under the License. +// +// Code generated by Alibaba Cloud SDK Code Generator. +// Changes may cause incorrect behavior and will be lost if the code is regenerated. + +import ( + "github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests" + "github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses" +) + +// DescribeLiveDomainTranscodeParams invokes the live.DescribeLiveDomainTranscodeParams API synchronously +func (client *Client) DescribeLiveDomainTranscodeParams(request *DescribeLiveDomainTranscodeParamsRequest) (response *DescribeLiveDomainTranscodeParamsResponse, err error) { + response = CreateDescribeLiveDomainTranscodeParamsResponse() + err = client.DoAction(request, response) + return +} + +// DescribeLiveDomainTranscodeParamsWithChan invokes the live.DescribeLiveDomainTranscodeParams API asynchronously +func (client *Client) DescribeLiveDomainTranscodeParamsWithChan(request *DescribeLiveDomainTranscodeParamsRequest) (<-chan *DescribeLiveDomainTranscodeParamsResponse, <-chan error) { + responseChan := make(chan *DescribeLiveDomainTranscodeParamsResponse, 1) + errChan := make(chan error, 1) + err := client.AddAsyncTask(func() { + defer close(responseChan) + defer close(errChan) + response, err := client.DescribeLiveDomainTranscodeParams(request) + if err != nil { + errChan <- err + } else { + responseChan <- response + } + }) + if err != nil { + errChan <- err + close(responseChan) + close(errChan) + } + return responseChan, errChan +} + +// DescribeLiveDomainTranscodeParamsWithCallback invokes the live.DescribeLiveDomainTranscodeParams API asynchronously +func (client *Client) DescribeLiveDomainTranscodeParamsWithCallback(request *DescribeLiveDomainTranscodeParamsRequest, callback func(response *DescribeLiveDomainTranscodeParamsResponse, err error)) <-chan int { + result := make(chan int, 1) + err := client.AddAsyncTask(func() { + var response *DescribeLiveDomainTranscodeParamsResponse + var err error + defer close(result) + response, err = client.DescribeLiveDomainTranscodeParams(request) + callback(response, err) + result <- 1 + }) + if err != nil { + defer close(result) + callback(nil, err) + result <- 0 + } + return result +} + +// DescribeLiveDomainTranscodeParamsRequest is the request struct for api DescribeLiveDomainTranscodeParams +type DescribeLiveDomainTranscodeParamsRequest struct { + *requests.RpcRequest + Pushdomain string `position:"Query" name:"pushdomain"` + App string `position:"Query" name:"app"` + TemplateName string `position:"Query" name:"template_name"` +} + +// DescribeLiveDomainTranscodeParamsResponse is the response struct for api DescribeLiveDomainTranscodeParams +type DescribeLiveDomainTranscodeParamsResponse struct { + *responses.BaseResponse + RequestId string `json:"RequestId" xml:"RequestId"` +} + +// CreateDescribeLiveDomainTranscodeParamsRequest creates a request to invoke DescribeLiveDomainTranscodeParams API +func CreateDescribeLiveDomainTranscodeParamsRequest() (request *DescribeLiveDomainTranscodeParamsRequest) { + request = &DescribeLiveDomainTranscodeParamsRequest{ + RpcRequest: &requests.RpcRequest{}, + } + request.InitWithApiInfo("live", "2016-11-01", "DescribeLiveDomainTranscodeParams", "live", "openAPI") + request.Method = requests.POST + return +} + +// CreateDescribeLiveDomainTranscodeParamsResponse creates a response to parse from DescribeLiveDomainTranscodeParams response +func CreateDescribeLiveDomainTranscodeParamsResponse() (response *DescribeLiveDomainTranscodeParamsResponse) { + response = &DescribeLiveDomainTranscodeParamsResponse{ + BaseResponse: &responses.BaseResponse{}, + } + return +} diff --git a/services/live/describe_live_stream_preload_tasks.go b/services/live/describe_live_stream_preload_tasks.go new file mode 100644 index 000000000..976004505 --- /dev/null +++ b/services/live/describe_live_stream_preload_tasks.go @@ -0,0 +1,112 @@ +package live + +//Licensed under the Apache License, Version 2.0 (the "License"); +//you may not use this file except in compliance with the License. +//You may obtain a copy of the License at +// +//http://www.apache.org/licenses/LICENSE-2.0 +// +//Unless required by applicable law or agreed to in writing, software +//distributed under the License is distributed on an "AS IS" BASIS, +//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +//See the License for the specific language governing permissions and +//limitations under the License. +// +// Code generated by Alibaba Cloud SDK Code Generator. +// Changes may cause incorrect behavior and will be lost if the code is regenerated. + +import ( + "github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests" + "github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses" +) + +// DescribeLiveStreamPreloadTasks invokes the live.DescribeLiveStreamPreloadTasks API synchronously +func (client *Client) DescribeLiveStreamPreloadTasks(request *DescribeLiveStreamPreloadTasksRequest) (response *DescribeLiveStreamPreloadTasksResponse, err error) { + response = CreateDescribeLiveStreamPreloadTasksResponse() + err = client.DoAction(request, response) + return +} + +// DescribeLiveStreamPreloadTasksWithChan invokes the live.DescribeLiveStreamPreloadTasks API asynchronously +func (client *Client) DescribeLiveStreamPreloadTasksWithChan(request *DescribeLiveStreamPreloadTasksRequest) (<-chan *DescribeLiveStreamPreloadTasksResponse, <-chan error) { + responseChan := make(chan *DescribeLiveStreamPreloadTasksResponse, 1) + errChan := make(chan error, 1) + err := client.AddAsyncTask(func() { + defer close(responseChan) + defer close(errChan) + response, err := client.DescribeLiveStreamPreloadTasks(request) + if err != nil { + errChan <- err + } else { + responseChan <- response + } + }) + if err != nil { + errChan <- err + close(responseChan) + close(errChan) + } + return responseChan, errChan +} + +// DescribeLiveStreamPreloadTasksWithCallback invokes the live.DescribeLiveStreamPreloadTasks API asynchronously +func (client *Client) DescribeLiveStreamPreloadTasksWithCallback(request *DescribeLiveStreamPreloadTasksRequest, callback func(response *DescribeLiveStreamPreloadTasksResponse, err error)) <-chan int { + result := make(chan int, 1) + err := client.AddAsyncTask(func() { + var response *DescribeLiveStreamPreloadTasksResponse + var err error + defer close(result) + response, err = client.DescribeLiveStreamPreloadTasks(request) + callback(response, err) + result <- 1 + }) + if err != nil { + defer close(result) + callback(nil, err) + result <- 0 + } + return result +} + +// DescribeLiveStreamPreloadTasksRequest is the request struct for api DescribeLiveStreamPreloadTasks +type DescribeLiveStreamPreloadTasksRequest struct { + *requests.RpcRequest + StartTime string `position:"Query" name:"StartTime"` + PageNum requests.Integer `position:"Query" name:"PageNum"` + PageSize requests.Integer `position:"Query" name:"PageSize"` + TaskId string `position:"Query" name:"TaskId"` + DomainName string `position:"Query" name:"DomainName"` + EndTime string `position:"Query" name:"EndTime"` + OwnerId requests.Integer `position:"Query" name:"OwnerId"` + PlayUrl string `position:"Query" name:"PlayUrl"` + Status string `position:"Query" name:"Status"` +} + +// DescribeLiveStreamPreloadTasksResponse is the response struct for api DescribeLiveStreamPreloadTasks +type DescribeLiveStreamPreloadTasksResponse struct { + *responses.BaseResponse + TotalPage int `json:"TotalPage" xml:"TotalPage"` + PageNum int `json:"PageNum" xml:"PageNum"` + PageSize int `json:"PageSize" xml:"PageSize"` + RequestId string `json:"RequestId" xml:"RequestId"` + TotalNum int `json:"TotalNum" xml:"TotalNum"` + PreloadTasks PreloadTasks `json:"PreloadTasks" xml:"PreloadTasks"` +} + +// CreateDescribeLiveStreamPreloadTasksRequest creates a request to invoke DescribeLiveStreamPreloadTasks API +func CreateDescribeLiveStreamPreloadTasksRequest() (request *DescribeLiveStreamPreloadTasksRequest) { + request = &DescribeLiveStreamPreloadTasksRequest{ + RpcRequest: &requests.RpcRequest{}, + } + request.InitWithApiInfo("live", "2016-11-01", "DescribeLiveStreamPreloadTasks", "live", "openAPI") + request.Method = requests.POST + return +} + +// CreateDescribeLiveStreamPreloadTasksResponse creates a response to parse from DescribeLiveStreamPreloadTasks response +func CreateDescribeLiveStreamPreloadTasksResponse() (response *DescribeLiveStreamPreloadTasksResponse) { + response = &DescribeLiveStreamPreloadTasksResponse{ + BaseResponse: &responses.BaseResponse{}, + } + return +} diff --git a/services/live/describe_live_stream_transcode_info.go b/services/live/describe_live_stream_transcode_info.go index dbf19385a..b3bdf3cb7 100644 --- a/services/live/describe_live_stream_transcode_info.go +++ b/services/live/describe_live_stream_transcode_info.go @@ -71,6 +71,7 @@ func (client *Client) DescribeLiveStreamTranscodeInfoWithCallback(request *Descr // DescribeLiveStreamTranscodeInfoRequest is the request struct for api DescribeLiveStreamTranscodeInfo type DescribeLiveStreamTranscodeInfoRequest struct { *requests.RpcRequest + AppName string `position:"Query" name:"AppName"` OwnerId requests.Integer `position:"Query" name:"OwnerId"` DomainTranscodeName string `position:"Query" name:"DomainTranscodeName"` } diff --git a/services/live/describe_stream_location_block.go b/services/live/describe_stream_location_block.go new file mode 100644 index 000000000..70e54043d --- /dev/null +++ b/services/live/describe_stream_location_block.go @@ -0,0 +1,110 @@ +package live + +//Licensed under the Apache License, Version 2.0 (the "License"); +//you may not use this file except in compliance with the License. +//You may obtain a copy of the License at +// +//http://www.apache.org/licenses/LICENSE-2.0 +// +//Unless required by applicable law or agreed to in writing, software +//distributed under the License is distributed on an "AS IS" BASIS, +//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +//See the License for the specific language governing permissions and +//limitations under the License. +// +// Code generated by Alibaba Cloud SDK Code Generator. +// Changes may cause incorrect behavior and will be lost if the code is regenerated. + +import ( + "github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests" + "github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses" +) + +// DescribeStreamLocationBlock invokes the live.DescribeStreamLocationBlock API synchronously +func (client *Client) DescribeStreamLocationBlock(request *DescribeStreamLocationBlockRequest) (response *DescribeStreamLocationBlockResponse, err error) { + response = CreateDescribeStreamLocationBlockResponse() + err = client.DoAction(request, response) + return +} + +// DescribeStreamLocationBlockWithChan invokes the live.DescribeStreamLocationBlock API asynchronously +func (client *Client) DescribeStreamLocationBlockWithChan(request *DescribeStreamLocationBlockRequest) (<-chan *DescribeStreamLocationBlockResponse, <-chan error) { + responseChan := make(chan *DescribeStreamLocationBlockResponse, 1) + errChan := make(chan error, 1) + err := client.AddAsyncTask(func() { + defer close(responseChan) + defer close(errChan) + response, err := client.DescribeStreamLocationBlock(request) + if err != nil { + errChan <- err + } else { + responseChan <- response + } + }) + if err != nil { + errChan <- err + close(responseChan) + close(errChan) + } + return responseChan, errChan +} + +// DescribeStreamLocationBlockWithCallback invokes the live.DescribeStreamLocationBlock API asynchronously +func (client *Client) DescribeStreamLocationBlockWithCallback(request *DescribeStreamLocationBlockRequest, callback func(response *DescribeStreamLocationBlockResponse, err error)) <-chan int { + result := make(chan int, 1) + err := client.AddAsyncTask(func() { + var response *DescribeStreamLocationBlockResponse + var err error + defer close(result) + response, err = client.DescribeStreamLocationBlock(request) + callback(response, err) + result <- 1 + }) + if err != nil { + defer close(result) + callback(nil, err) + result <- 0 + } + return result +} + +// DescribeStreamLocationBlockRequest is the request struct for api DescribeStreamLocationBlock +type DescribeStreamLocationBlockRequest struct { + *requests.RpcRequest + BlockType string `position:"Query" name:"BlockType"` + PageNum requests.Integer `position:"Query" name:"PageNum"` + AppName string `position:"Query" name:"AppName"` + PageSize requests.Integer `position:"Query" name:"PageSize"` + StreamName string `position:"Query" name:"StreamName"` + DomainName string `position:"Query" name:"DomainName"` + OwnerId requests.Integer `position:"Query" name:"OwnerId"` +} + +// DescribeStreamLocationBlockResponse is the response struct for api DescribeStreamLocationBlock +type DescribeStreamLocationBlockResponse struct { + *responses.BaseResponse + TotalPage int `json:"TotalPage" xml:"TotalPage"` + PageNum int `json:"PageNum" xml:"PageNum"` + PageSize int `json:"PageSize" xml:"PageSize"` + RequestId string `json:"RequestId" xml:"RequestId"` + Count int `json:"Count" xml:"Count"` + StreamBlockList StreamBlockList `json:"StreamBlockList" xml:"StreamBlockList"` +} + +// CreateDescribeStreamLocationBlockRequest creates a request to invoke DescribeStreamLocationBlock API +func CreateDescribeStreamLocationBlockRequest() (request *DescribeStreamLocationBlockRequest) { + request = &DescribeStreamLocationBlockRequest{ + RpcRequest: &requests.RpcRequest{}, + } + request.InitWithApiInfo("live", "2016-11-01", "DescribeStreamLocationBlock", "live", "openAPI") + request.Method = requests.POST + return +} + +// CreateDescribeStreamLocationBlockResponse creates a response to parse from DescribeStreamLocationBlock response +func CreateDescribeStreamLocationBlockResponse() (response *DescribeStreamLocationBlockResponse) { + response = &DescribeStreamLocationBlockResponse{ + BaseResponse: &responses.BaseResponse{}, + } + return +} diff --git a/services/live/set_live_stream_block.go b/services/live/set_live_stream_block.go new file mode 100644 index 000000000..f815ab767 --- /dev/null +++ b/services/live/set_live_stream_block.go @@ -0,0 +1,107 @@ +package live + +//Licensed under the Apache License, Version 2.0 (the "License"); +//you may not use this file except in compliance with the License. +//You may obtain a copy of the License at +// +//http://www.apache.org/licenses/LICENSE-2.0 +// +//Unless required by applicable law or agreed to in writing, software +//distributed under the License is distributed on an "AS IS" BASIS, +//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +//See the License for the specific language governing permissions and +//limitations under the License. +// +// Code generated by Alibaba Cloud SDK Code Generator. +// Changes may cause incorrect behavior and will be lost if the code is regenerated. + +import ( + "github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests" + "github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses" +) + +// SetLiveStreamBlock invokes the live.SetLiveStreamBlock API synchronously +func (client *Client) SetLiveStreamBlock(request *SetLiveStreamBlockRequest) (response *SetLiveStreamBlockResponse, err error) { + response = CreateSetLiveStreamBlockResponse() + err = client.DoAction(request, response) + return +} + +// SetLiveStreamBlockWithChan invokes the live.SetLiveStreamBlock API asynchronously +func (client *Client) SetLiveStreamBlockWithChan(request *SetLiveStreamBlockRequest) (<-chan *SetLiveStreamBlockResponse, <-chan error) { + responseChan := make(chan *SetLiveStreamBlockResponse, 1) + errChan := make(chan error, 1) + err := client.AddAsyncTask(func() { + defer close(responseChan) + defer close(errChan) + response, err := client.SetLiveStreamBlock(request) + if err != nil { + errChan <- err + } else { + responseChan <- response + } + }) + if err != nil { + errChan <- err + close(responseChan) + close(errChan) + } + return responseChan, errChan +} + +// SetLiveStreamBlockWithCallback invokes the live.SetLiveStreamBlock API asynchronously +func (client *Client) SetLiveStreamBlockWithCallback(request *SetLiveStreamBlockRequest, callback func(response *SetLiveStreamBlockResponse, err error)) <-chan int { + result := make(chan int, 1) + err := client.AddAsyncTask(func() { + var response *SetLiveStreamBlockResponse + var err error + defer close(result) + response, err = client.SetLiveStreamBlock(request) + callback(response, err) + result <- 1 + }) + if err != nil { + defer close(result) + callback(nil, err) + result <- 0 + } + return result +} + +// SetLiveStreamBlockRequest is the request struct for api SetLiveStreamBlock +type SetLiveStreamBlockRequest struct { + *requests.RpcRequest + LocationList string `position:"Query" name:"LocationList"` + BlockType string `position:"Query" name:"BlockType"` + ReleaseTime string `position:"Query" name:"ReleaseTime"` + AppName string `position:"Query" name:"AppName"` + StreamName string `position:"Query" name:"StreamName"` + DomainName string `position:"Query" name:"DomainName"` + OwnerId requests.Integer `position:"Query" name:"OwnerId"` +} + +// SetLiveStreamBlockResponse is the response struct for api SetLiveStreamBlock +type SetLiveStreamBlockResponse struct { + *responses.BaseResponse + Status string `json:"Status" xml:"Status"` + RequestId string `json:"RequestId" xml:"RequestId"` + Description string `json:"Description" xml:"Description"` +} + +// CreateSetLiveStreamBlockRequest creates a request to invoke SetLiveStreamBlock API +func CreateSetLiveStreamBlockRequest() (request *SetLiveStreamBlockRequest) { + request = &SetLiveStreamBlockRequest{ + RpcRequest: &requests.RpcRequest{}, + } + request.InitWithApiInfo("live", "2016-11-01", "SetLiveStreamBlock", "live", "openAPI") + request.Method = requests.POST + return +} + +// CreateSetLiveStreamBlockResponse creates a response to parse from SetLiveStreamBlock response +func CreateSetLiveStreamBlockResponse() (response *SetLiveStreamBlockResponse) { + response = &SetLiveStreamBlockResponse{ + BaseResponse: &responses.BaseResponse{}, + } + return +} diff --git a/services/live/set_live_stream_preload_tasks.go b/services/live/set_live_stream_preload_tasks.go new file mode 100644 index 000000000..bbddf27bc --- /dev/null +++ b/services/live/set_live_stream_preload_tasks.go @@ -0,0 +1,109 @@ +package live + +//Licensed under the Apache License, Version 2.0 (the "License"); +//you may not use this file except in compliance with the License. +//You may obtain a copy of the License at +// +//http://www.apache.org/licenses/LICENSE-2.0 +// +//Unless required by applicable law or agreed to in writing, software +//distributed under the License is distributed on an "AS IS" BASIS, +//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +//See the License for the specific language governing permissions and +//limitations under the License. +// +// Code generated by Alibaba Cloud SDK Code Generator. +// Changes may cause incorrect behavior and will be lost if the code is regenerated. + +import ( + "github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests" + "github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses" +) + +// SetLiveStreamPreloadTasks invokes the live.SetLiveStreamPreloadTasks API synchronously +func (client *Client) SetLiveStreamPreloadTasks(request *SetLiveStreamPreloadTasksRequest) (response *SetLiveStreamPreloadTasksResponse, err error) { + response = CreateSetLiveStreamPreloadTasksResponse() + err = client.DoAction(request, response) + return +} + +// SetLiveStreamPreloadTasksWithChan invokes the live.SetLiveStreamPreloadTasks API asynchronously +func (client *Client) SetLiveStreamPreloadTasksWithChan(request *SetLiveStreamPreloadTasksRequest) (<-chan *SetLiveStreamPreloadTasksResponse, <-chan error) { + responseChan := make(chan *SetLiveStreamPreloadTasksResponse, 1) + errChan := make(chan error, 1) + err := client.AddAsyncTask(func() { + defer close(responseChan) + defer close(errChan) + response, err := client.SetLiveStreamPreloadTasks(request) + if err != nil { + errChan <- err + } else { + responseChan <- response + } + }) + if err != nil { + errChan <- err + close(responseChan) + close(errChan) + } + return responseChan, errChan +} + +// SetLiveStreamPreloadTasksWithCallback invokes the live.SetLiveStreamPreloadTasks API asynchronously +func (client *Client) SetLiveStreamPreloadTasksWithCallback(request *SetLiveStreamPreloadTasksRequest, callback func(response *SetLiveStreamPreloadTasksResponse, err error)) <-chan int { + result := make(chan int, 1) + err := client.AddAsyncTask(func() { + var response *SetLiveStreamPreloadTasksResponse + var err error + defer close(result) + response, err = client.SetLiveStreamPreloadTasks(request) + callback(response, err) + result <- 1 + }) + if err != nil { + defer close(result) + callback(nil, err) + result <- 0 + } + return result +} + +// SetLiveStreamPreloadTasksRequest is the request struct for api SetLiveStreamPreloadTasks +type SetLiveStreamPreloadTasksRequest struct { + *requests.RpcRequest + PreloadedStartTime string `position:"Query" name:"PreloadedStartTime"` + Area string `position:"Query" name:"Area"` + PreloadedEndTime string `position:"Query" name:"PreloadedEndTime"` + DomainName string `position:"Query" name:"DomainName"` + OwnerId requests.Integer `position:"Query" name:"OwnerId"` + PlayUrl string `position:"Query" name:"PlayUrl"` +} + +// SetLiveStreamPreloadTasksResponse is the response struct for api SetLiveStreamPreloadTasks +type SetLiveStreamPreloadTasksResponse struct { + *responses.BaseResponse + Status string `json:"Status" xml:"Status"` + FailedURL int `json:"FailedURL" xml:"FailedURL"` + TotalURL int `json:"TotalURL" xml:"TotalURL"` + RequestId string `json:"RequestId" xml:"RequestId"` + SuccessURL int `json:"SuccessURL" xml:"SuccessURL"` + PreloadTasksMessages PreloadTasksMessages `json:"PreloadTasksMessages" xml:"PreloadTasksMessages"` +} + +// CreateSetLiveStreamPreloadTasksRequest creates a request to invoke SetLiveStreamPreloadTasks API +func CreateSetLiveStreamPreloadTasksRequest() (request *SetLiveStreamPreloadTasksRequest) { + request = &SetLiveStreamPreloadTasksRequest{ + RpcRequest: &requests.RpcRequest{}, + } + request.InitWithApiInfo("live", "2016-11-01", "SetLiveStreamPreloadTasks", "live", "openAPI") + request.Method = requests.POST + return +} + +// CreateSetLiveStreamPreloadTasksResponse creates a response to parse from SetLiveStreamPreloadTasks response +func CreateSetLiveStreamPreloadTasksResponse() (response *SetLiveStreamPreloadTasksResponse) { + response = &SetLiveStreamPreloadTasksResponse{ + BaseResponse: &responses.BaseResponse{}, + } + return +} diff --git a/services/live/struct_custom_transcode_parameters.go b/services/live/struct_custom_transcode_parameters.go index 059ae4938..9c3bf3922 100644 --- a/services/live/struct_custom_transcode_parameters.go +++ b/services/live/struct_custom_transcode_parameters.go @@ -17,18 +17,22 @@ package live // CustomTranscodeParameters is a nested struct in live response type CustomTranscodeParameters struct { - VideoProfile string `json:"VideoProfile" xml:"VideoProfile"` - AudioBitrate int `json:"AudioBitrate" xml:"AudioBitrate"` - RtsFlag string `json:"RtsFlag" xml:"RtsFlag"` - Height int `json:"Height" xml:"Height"` - TemplateType string `json:"TemplateType" xml:"TemplateType"` - Bframes string `json:"Bframes" xml:"Bframes"` - AudioRate int `json:"AudioRate" xml:"AudioRate"` - FPS int `json:"FPS" xml:"FPS"` - AudioCodec string `json:"AudioCodec" xml:"AudioCodec"` - Gop string `json:"Gop" xml:"Gop"` - VideoBitrate int `json:"VideoBitrate" xml:"VideoBitrate"` - Width int `json:"Width" xml:"Width"` - AudioChannelNum int `json:"AudioChannelNum" xml:"AudioChannelNum"` - AudioProfile string `json:"AudioProfile" xml:"AudioProfile"` + BitrateWithSource map[string]interface{} `json:"BitrateWithSource" xml:"BitrateWithSource"` + VideoProfile string `json:"VideoProfile" xml:"VideoProfile"` + AudioBitrate int `json:"AudioBitrate" xml:"AudioBitrate"` + Height int `json:"Height" xml:"Height"` + RtsFlag string `json:"RtsFlag" xml:"RtsFlag"` + TemplateType string `json:"TemplateType" xml:"TemplateType"` + Bframes string `json:"Bframes" xml:"Bframes"` + ExtWithSource map[string]interface{} `json:"ExtWithSource" xml:"ExtWithSource"` + AudioRate int `json:"AudioRate" xml:"AudioRate"` + FpsWithSource map[string]interface{} `json:"FpsWithSource" xml:"FpsWithSource"` + AudioCodec string `json:"AudioCodec" xml:"AudioCodec"` + FPS int `json:"FPS" xml:"FPS"` + Gop string `json:"Gop" xml:"Gop"` + Width int `json:"Width" xml:"Width"` + VideoBitrate int `json:"VideoBitrate" xml:"VideoBitrate"` + AudioChannelNum int `json:"AudioChannelNum" xml:"AudioChannelNum"` + AudioProfile string `json:"AudioProfile" xml:"AudioProfile"` + ResWithSource map[string]interface{} `json:"ResWithSource" xml:"ResWithSource"` } diff --git a/services/live/struct_interactive_user_list.go b/services/live/struct_interactive_user_list.go new file mode 100644 index 000000000..821456f8b --- /dev/null +++ b/services/live/struct_interactive_user_list.go @@ -0,0 +1,21 @@ +package live + +//Licensed under the Apache License, Version 2.0 (the "License"); +//you may not use this file except in compliance with the License. +//You may obtain a copy of the License at +// +//http://www.apache.org/licenses/LICENSE-2.0 +// +//Unless required by applicable law or agreed to in writing, software +//distributed under the License is distributed on an "AS IS" BASIS, +//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +//See the License for the specific language governing permissions and +//limitations under the License. +// +// Code generated by Alibaba Cloud SDK Code Generator. +// Changes may cause incorrect behavior and will be lost if the code is regenerated. + +// InteractiveUserList is a nested struct in live response +type InteractiveUserList struct { + InteractiveUser []string `json:"InteractiveUser" xml:"InteractiveUser"` +} diff --git a/services/live/struct_live_app_record.go b/services/live/struct_live_app_record.go index cf48270c8..ac48397df 100644 --- a/services/live/struct_live_app_record.go +++ b/services/live/struct_live_app_record.go @@ -27,6 +27,7 @@ type LiveAppRecord struct { EndTime string `json:"EndTime" xml:"EndTime"` Always string `json:"Always" xml:"Always"` OnDemond int `json:"OnDemond" xml:"OnDemond"` + DelayTime int `json:"DelayTime" xml:"DelayTime"` OssEndpoint string `json:"OssEndpoint" xml:"OssEndpoint"` AppName string `json:"AppName" xml:"AppName"` TranscodeTemplates TranscodeTemplates `json:"TranscodeTemplates" xml:"TranscodeTemplates"` diff --git a/services/live/struct_live_record_vod_config.go b/services/live/struct_live_record_vod_config.go index f3d39054e..e90cdb96c 100644 --- a/services/live/struct_live_record_vod_config.go +++ b/services/live/struct_live_record_vod_config.go @@ -17,8 +17,10 @@ package live // LiveRecordVodConfig is a nested struct in live response type LiveRecordVodConfig struct { + StorageLocation string `json:"StorageLocation" xml:"StorageLocation"` AppName string `json:"AppName" xml:"AppName"` AutoCompose string `json:"AutoCompose" xml:"AutoCompose"` + OnDemand int `json:"OnDemand" xml:"OnDemand"` StreamName string `json:"StreamName" xml:"StreamName"` CreateTime string `json:"CreateTime" xml:"CreateTime"` VodTranscodeGroupId string `json:"VodTranscodeGroupId" xml:"VodTranscodeGroupId"` diff --git a/services/live/struct_live_user_list.go b/services/live/struct_live_user_list.go new file mode 100644 index 000000000..062f7a2f1 --- /dev/null +++ b/services/live/struct_live_user_list.go @@ -0,0 +1,21 @@ +package live + +//Licensed under the Apache License, Version 2.0 (the "License"); +//you may not use this file except in compliance with the License. +//You may obtain a copy of the License at +// +//http://www.apache.org/licenses/LICENSE-2.0 +// +//Unless required by applicable law or agreed to in writing, software +//distributed under the License is distributed on an "AS IS" BASIS, +//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +//See the License for the specific language governing permissions and +//limitations under the License. +// +// Code generated by Alibaba Cloud SDK Code Generator. +// Changes may cause incorrect behavior and will be lost if the code is regenerated. + +// LiveUserList is a nested struct in live response +type LiveUserList struct { + LiveUser []string `json:"LiveUser" xml:"LiveUser"` +} diff --git a/services/live/struct_preload_task.go b/services/live/struct_preload_task.go new file mode 100644 index 000000000..36d3e6230 --- /dev/null +++ b/services/live/struct_preload_task.go @@ -0,0 +1,30 @@ +package live + +//Licensed under the Apache License, Version 2.0 (the "License"); +//you may not use this file except in compliance with the License. +//You may obtain a copy of the License at +// +//http://www.apache.org/licenses/LICENSE-2.0 +// +//Unless required by applicable law or agreed to in writing, software +//distributed under the License is distributed on an "AS IS" BASIS, +//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +//See the License for the specific language governing permissions and +//limitations under the License. +// +// Code generated by Alibaba Cloud SDK Code Generator. +// Changes may cause incorrect behavior and will be lost if the code is regenerated. + +// PreloadTask is a nested struct in live response +type PreloadTask struct { + Status string `json:"Status" xml:"Status"` + Process string `json:"Process" xml:"Process"` + Description string `json:"Description" xml:"Description"` + CreateTime string `json:"CreateTime" xml:"CreateTime"` + PreloadedEndTime string `json:"PreloadedEndTime" xml:"PreloadedEndTime"` + PreloadedStartTime string `json:"PreloadedStartTime" xml:"PreloadedStartTime"` + PlayUrl string `json:"PlayUrl" xml:"PlayUrl"` + Area string `json:"Area" xml:"Area"` + TaskId string `json:"TaskId" xml:"TaskId"` + DomainName string `json:"DomainName" xml:"DomainName"` +} diff --git a/services/live/struct_preload_tasks.go b/services/live/struct_preload_tasks.go new file mode 100644 index 000000000..247562686 --- /dev/null +++ b/services/live/struct_preload_tasks.go @@ -0,0 +1,21 @@ +package live + +//Licensed under the Apache License, Version 2.0 (the "License"); +//you may not use this file except in compliance with the License. +//You may obtain a copy of the License at +// +//http://www.apache.org/licenses/LICENSE-2.0 +// +//Unless required by applicable law or agreed to in writing, software +//distributed under the License is distributed on an "AS IS" BASIS, +//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +//See the License for the specific language governing permissions and +//limitations under the License. +// +// Code generated by Alibaba Cloud SDK Code Generator. +// Changes may cause incorrect behavior and will be lost if the code is regenerated. + +// PreloadTasks is a nested struct in live response +type PreloadTasks struct { + PreloadTask []PreloadTask `json:"PreloadTask" xml:"PreloadTask"` +} diff --git a/services/live/struct_preload_tasks_message.go b/services/live/struct_preload_tasks_message.go new file mode 100644 index 000000000..96b0e4e20 --- /dev/null +++ b/services/live/struct_preload_tasks_message.go @@ -0,0 +1,23 @@ +package live + +//Licensed under the Apache License, Version 2.0 (the "License"); +//you may not use this file except in compliance with the License. +//You may obtain a copy of the License at +// +//http://www.apache.org/licenses/LICENSE-2.0 +// +//Unless required by applicable law or agreed to in writing, software +//distributed under the License is distributed on an "AS IS" BASIS, +//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +//See the License for the specific language governing permissions and +//limitations under the License. +// +// Code generated by Alibaba Cloud SDK Code Generator. +// Changes may cause incorrect behavior and will be lost if the code is regenerated. + +// PreloadTasksMessage is a nested struct in live response +type PreloadTasksMessage struct { + PlayUrl string `json:"PlayUrl" xml:"PlayUrl"` + Description string `json:"Description" xml:"Description"` + TaskId string `json:"TaskId" xml:"TaskId"` +} diff --git a/services/live/struct_preload_tasks_messages.go b/services/live/struct_preload_tasks_messages.go new file mode 100644 index 000000000..af20321d3 --- /dev/null +++ b/services/live/struct_preload_tasks_messages.go @@ -0,0 +1,21 @@ +package live + +//Licensed under the Apache License, Version 2.0 (the "License"); +//you may not use this file except in compliance with the License. +//You may obtain a copy of the License at +// +//http://www.apache.org/licenses/LICENSE-2.0 +// +//Unless required by applicable law or agreed to in writing, software +//distributed under the License is distributed on an "AS IS" BASIS, +//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +//See the License for the specific language governing permissions and +//limitations under the License. +// +// Code generated by Alibaba Cloud SDK Code Generator. +// Changes may cause incorrect behavior and will be lost if the code is regenerated. + +// PreloadTasksMessages is a nested struct in live response +type PreloadTasksMessages struct { + PreloadTasksMessage []PreloadTasksMessage `json:"PreloadTasksMessage" xml:"PreloadTasksMessage"` +} diff --git a/services/live/struct_stream_block.go b/services/live/struct_stream_block.go new file mode 100644 index 000000000..dd8191d2f --- /dev/null +++ b/services/live/struct_stream_block.go @@ -0,0 +1,28 @@ +package live + +//Licensed under the Apache License, Version 2.0 (the "License"); +//you may not use this file except in compliance with the License. +//You may obtain a copy of the License at +// +//http://www.apache.org/licenses/LICENSE-2.0 +// +//Unless required by applicable law or agreed to in writing, software +//distributed under the License is distributed on an "AS IS" BASIS, +//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +//See the License for the specific language governing permissions and +//limitations under the License. +// +// Code generated by Alibaba Cloud SDK Code Generator. +// Changes may cause incorrect behavior and will be lost if the code is regenerated. + +// StreamBlock is a nested struct in live response +type StreamBlock struct { + Status int `json:"Status" xml:"Status"` + BlockType string `json:"BlockType" xml:"BlockType"` + AppName string `json:"AppName" xml:"AppName"` + UpdateTime string `json:"UpdateTime" xml:"UpdateTime"` + StreamName string `json:"StreamName" xml:"StreamName"` + ReleaseTime string `json:"ReleaseTime" xml:"ReleaseTime"` + LocationList string `json:"LocationList" xml:"LocationList"` + DomainName string `json:"DomainName" xml:"DomainName"` +} diff --git a/services/live/struct_stream_block_list.go b/services/live/struct_stream_block_list.go new file mode 100644 index 000000000..b52e0db31 --- /dev/null +++ b/services/live/struct_stream_block_list.go @@ -0,0 +1,21 @@ +package live + +//Licensed under the Apache License, Version 2.0 (the "License"); +//you may not use this file except in compliance with the License. +//You may obtain a copy of the License at +// +//http://www.apache.org/licenses/LICENSE-2.0 +// +//Unless required by applicable law or agreed to in writing, software +//distributed under the License is distributed on an "AS IS" BASIS, +//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +//See the License for the specific language governing permissions and +//limitations under the License. +// +// Code generated by Alibaba Cloud SDK Code Generator. +// Changes may cause incorrect behavior and will be lost if the code is regenerated. + +// StreamBlockList is a nested struct in live response +type StreamBlockList struct { + StreamBlock []StreamBlock `json:"StreamBlock" xml:"StreamBlock"` +} diff --git a/services/live/update_live_app_record_config.go b/services/live/update_live_app_record_config.go new file mode 100644 index 000000000..bedb25fbf --- /dev/null +++ b/services/live/update_live_app_record_config.go @@ -0,0 +1,125 @@ +package live + +//Licensed under the Apache License, Version 2.0 (the "License"); +//you may not use this file except in compliance with the License. +//You may obtain a copy of the License at +// +//http://www.apache.org/licenses/LICENSE-2.0 +// +//Unless required by applicable law or agreed to in writing, software +//distributed under the License is distributed on an "AS IS" BASIS, +//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +//See the License for the specific language governing permissions and +//limitations under the License. +// +// Code generated by Alibaba Cloud SDK Code Generator. +// Changes may cause incorrect behavior and will be lost if the code is regenerated. + +import ( + "github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests" + "github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses" +) + +// UpdateLiveAppRecordConfig invokes the live.UpdateLiveAppRecordConfig API synchronously +func (client *Client) UpdateLiveAppRecordConfig(request *UpdateLiveAppRecordConfigRequest) (response *UpdateLiveAppRecordConfigResponse, err error) { + response = CreateUpdateLiveAppRecordConfigResponse() + err = client.DoAction(request, response) + return +} + +// UpdateLiveAppRecordConfigWithChan invokes the live.UpdateLiveAppRecordConfig API asynchronously +func (client *Client) UpdateLiveAppRecordConfigWithChan(request *UpdateLiveAppRecordConfigRequest) (<-chan *UpdateLiveAppRecordConfigResponse, <-chan error) { + responseChan := make(chan *UpdateLiveAppRecordConfigResponse, 1) + errChan := make(chan error, 1) + err := client.AddAsyncTask(func() { + defer close(responseChan) + defer close(errChan) + response, err := client.UpdateLiveAppRecordConfig(request) + if err != nil { + errChan <- err + } else { + responseChan <- response + } + }) + if err != nil { + errChan <- err + close(responseChan) + close(errChan) + } + return responseChan, errChan +} + +// UpdateLiveAppRecordConfigWithCallback invokes the live.UpdateLiveAppRecordConfig API asynchronously +func (client *Client) UpdateLiveAppRecordConfigWithCallback(request *UpdateLiveAppRecordConfigRequest, callback func(response *UpdateLiveAppRecordConfigResponse, err error)) <-chan int { + result := make(chan int, 1) + err := client.AddAsyncTask(func() { + var response *UpdateLiveAppRecordConfigResponse + var err error + defer close(result) + response, err = client.UpdateLiveAppRecordConfig(request) + callback(response, err) + result <- 1 + }) + if err != nil { + defer close(result) + callback(nil, err) + result <- 0 + } + return result +} + +// UpdateLiveAppRecordConfigRequest is the request struct for api UpdateLiveAppRecordConfig +type UpdateLiveAppRecordConfigRequest struct { + *requests.RpcRequest + OssEndpoint string `position:"Query" name:"OssEndpoint"` + DelayTime requests.Integer `position:"Query" name:"DelayTime"` + TranscodeTemplates *[]string `position:"Query" name:"TranscodeTemplates" type:"Repeated"` + StartTime string `position:"Query" name:"StartTime"` + AppName string `position:"Query" name:"AppName"` + SecurityToken string `position:"Query" name:"SecurityToken"` + TranscodeRecordFormat *[]UpdateLiveAppRecordConfigTranscodeRecordFormat `position:"Query" name:"TranscodeRecordFormat" type:"Repeated"` + OnDemand requests.Integer `position:"Query" name:"OnDemand"` + StreamName string `position:"Query" name:"StreamName"` + DomainName string `position:"Query" name:"DomainName"` + EndTime string `position:"Query" name:"EndTime"` + OwnerId requests.Integer `position:"Query" name:"OwnerId"` + RecordFormat *[]UpdateLiveAppRecordConfigRecordFormat `position:"Query" name:"RecordFormat" type:"Repeated"` +} + +// UpdateLiveAppRecordConfigTranscodeRecordFormat is a repeated param struct in UpdateLiveAppRecordConfigRequest +type UpdateLiveAppRecordConfigTranscodeRecordFormat struct { + SliceDuration string `name:"SliceDuration"` + Format string `name:"Format"` + CycleDuration string `name:"CycleDuration"` +} + +// UpdateLiveAppRecordConfigRecordFormat is a repeated param struct in UpdateLiveAppRecordConfigRequest +type UpdateLiveAppRecordConfigRecordFormat struct { + SliceDuration string `name:"SliceDuration"` + Format string `name:"Format"` + CycleDuration string `name:"CycleDuration"` +} + +// UpdateLiveAppRecordConfigResponse is the response struct for api UpdateLiveAppRecordConfig +type UpdateLiveAppRecordConfigResponse struct { + *responses.BaseResponse + RequestId string `json:"RequestId" xml:"RequestId"` +} + +// CreateUpdateLiveAppRecordConfigRequest creates a request to invoke UpdateLiveAppRecordConfig API +func CreateUpdateLiveAppRecordConfigRequest() (request *UpdateLiveAppRecordConfigRequest) { + request = &UpdateLiveAppRecordConfigRequest{ + RpcRequest: &requests.RpcRequest{}, + } + request.InitWithApiInfo("live", "2016-11-01", "UpdateLiveAppRecordConfig", "live", "openAPI") + request.Method = requests.POST + return +} + +// CreateUpdateLiveAppRecordConfigResponse creates a response to parse from UpdateLiveAppRecordConfig response +func CreateUpdateLiveAppRecordConfigResponse() (response *UpdateLiveAppRecordConfigResponse) { + response = &UpdateLiveAppRecordConfigResponse{ + BaseResponse: &responses.BaseResponse{}, + } + return +} diff --git a/services/live/update_live_record_vod_config.go b/services/live/update_live_record_vod_config.go new file mode 100644 index 000000000..a6e3d7a3b --- /dev/null +++ b/services/live/update_live_record_vod_config.go @@ -0,0 +1,108 @@ +package live + +//Licensed under the Apache License, Version 2.0 (the "License"); +//you may not use this file except in compliance with the License. +//You may obtain a copy of the License at +// +//http://www.apache.org/licenses/LICENSE-2.0 +// +//Unless required by applicable law or agreed to in writing, software +//distributed under the License is distributed on an "AS IS" BASIS, +//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +//See the License for the specific language governing permissions and +//limitations under the License. +// +// Code generated by Alibaba Cloud SDK Code Generator. +// Changes may cause incorrect behavior and will be lost if the code is regenerated. + +import ( + "github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests" + "github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses" +) + +// UpdateLiveRecordVodConfig invokes the live.UpdateLiveRecordVodConfig API synchronously +func (client *Client) UpdateLiveRecordVodConfig(request *UpdateLiveRecordVodConfigRequest) (response *UpdateLiveRecordVodConfigResponse, err error) { + response = CreateUpdateLiveRecordVodConfigResponse() + err = client.DoAction(request, response) + return +} + +// UpdateLiveRecordVodConfigWithChan invokes the live.UpdateLiveRecordVodConfig API asynchronously +func (client *Client) UpdateLiveRecordVodConfigWithChan(request *UpdateLiveRecordVodConfigRequest) (<-chan *UpdateLiveRecordVodConfigResponse, <-chan error) { + responseChan := make(chan *UpdateLiveRecordVodConfigResponse, 1) + errChan := make(chan error, 1) + err := client.AddAsyncTask(func() { + defer close(responseChan) + defer close(errChan) + response, err := client.UpdateLiveRecordVodConfig(request) + if err != nil { + errChan <- err + } else { + responseChan <- response + } + }) + if err != nil { + errChan <- err + close(responseChan) + close(errChan) + } + return responseChan, errChan +} + +// UpdateLiveRecordVodConfigWithCallback invokes the live.UpdateLiveRecordVodConfig API asynchronously +func (client *Client) UpdateLiveRecordVodConfigWithCallback(request *UpdateLiveRecordVodConfigRequest, callback func(response *UpdateLiveRecordVodConfigResponse, err error)) <-chan int { + result := make(chan int, 1) + err := client.AddAsyncTask(func() { + var response *UpdateLiveRecordVodConfigResponse + var err error + defer close(result) + response, err = client.UpdateLiveRecordVodConfig(request) + callback(response, err) + result <- 1 + }) + if err != nil { + defer close(result) + callback(nil, err) + result <- 0 + } + return result +} + +// UpdateLiveRecordVodConfigRequest is the request struct for api UpdateLiveRecordVodConfig +type UpdateLiveRecordVodConfigRequest struct { + *requests.RpcRequest + AutoCompose string `position:"Query" name:"AutoCompose"` + ComposeVodTranscodeGroupId string `position:"Query" name:"ComposeVodTranscodeGroupId"` + StorageLocation string `position:"Query" name:"StorageLocation"` + AppName string `position:"Query" name:"AppName"` + OnDemand requests.Integer `position:"Query" name:"OnDemand"` + StreamName string `position:"Query" name:"StreamName"` + VodTranscodeGroupId string `position:"Query" name:"VodTranscodeGroupId"` + DomainName string `position:"Query" name:"DomainName"` + CycleDuration requests.Integer `position:"Query" name:"CycleDuration"` + OwnerId requests.Integer `position:"Query" name:"OwnerId"` +} + +// UpdateLiveRecordVodConfigResponse is the response struct for api UpdateLiveRecordVodConfig +type UpdateLiveRecordVodConfigResponse struct { + *responses.BaseResponse + RequestId string `json:"RequestId" xml:"RequestId"` +} + +// CreateUpdateLiveRecordVodConfigRequest creates a request to invoke UpdateLiveRecordVodConfig API +func CreateUpdateLiveRecordVodConfigRequest() (request *UpdateLiveRecordVodConfigRequest) { + request = &UpdateLiveRecordVodConfigRequest{ + RpcRequest: &requests.RpcRequest{}, + } + request.InitWithApiInfo("live", "2016-11-01", "UpdateLiveRecordVodConfig", "live", "openAPI") + request.Method = requests.POST + return +} + +// CreateUpdateLiveRecordVodConfigResponse creates a response to parse from UpdateLiveRecordVodConfig response +func CreateUpdateLiveRecordVodConfigResponse() (response *UpdateLiveRecordVodConfigResponse) { + response = &UpdateLiveRecordVodConfigResponse{ + BaseResponse: &responses.BaseResponse{}, + } + return +}