@@ -101,67 +101,6 @@ func (me *CssService) DeleteCssWatermarkById(ctx context.Context, watermarkId *i
101101 return
102102}
103103
104- func (me * CssService ) DescribeCssWatermarkRuleAttachment (ctx context.Context , domainName , appName , streamName , watermarkId string ) (watermarkRuleAttachment * css.RuleInfo , errRet error ) {
105- var (
106- logId = getLogId (ctx )
107- request = css .NewDescribeLiveWatermarkRulesRequest ()
108- )
109-
110- defer func () {
111- if errRet != nil {
112- log .Printf ("[CRITICAL]%s api[%s] fail, request body [%s], reason[%s]\n " ,
113- logId , "query object" , request .ToJsonString (), errRet .Error ())
114- }
115- }()
116- // request.DomainName = &domainName
117- // request.AppName = &appName
118- // request.StreamName = &streamName
119- // request.WatermarkId = &watermarkId
120-
121- response , err := me .client .UseCssClient ().DescribeLiveWatermarkRules (request )
122- if err != nil {
123- log .Printf ("[CRITICAL]%s api[%s] fail, request body [%s], reason[%s]\n " ,
124- logId , request .GetAction (), request .ToJsonString (), err .Error ())
125- errRet = err
126- return
127- }
128- log .Printf ("[DEBUG]%s api[%s] success, request body [%s], response body [%s]\n " ,
129- logId , request .GetAction (), request .ToJsonString (), response .ToJsonString ())
130- if len (response .Response .Rules ) < 1 {
131- return
132- }
133- watermarkRuleAttachment = response .Response .Rules [0 ]
134- return
135- }
136-
137- func (me * CssService ) DetachCssWatermarkRuleAttachment (ctx context.Context , domainName , appName , streamName string ) (errRet error ) {
138- logId := getLogId (ctx )
139-
140- request := css .NewDeleteLiveWatermarkRuleRequest ()
141-
142- request .DomainName = helper .String (domainName )
143- request .AppName = helper .String (appName )
144- request .StreamName = helper .String (streamName )
145-
146- defer func () {
147- if errRet != nil {
148- log .Printf ("[CRITICAL]%s api[%s] fail, request body [%s], reason[%s]\n " ,
149- logId , "delete object" , request .ToJsonString (), errRet .Error ())
150- }
151- }()
152-
153- ratelimit .Check (request .GetAction ())
154- response , err := me .client .UseCssClient ().DeleteLiveWatermarkRule (request )
155- if err != nil {
156- errRet = err
157- return err
158- }
159- log .Printf ("[DEBUG]%s api[%s] success, request body [%s], response body [%s]\n " ,
160- logId , request .GetAction (), request .ToJsonString (), response .ToJsonString ())
161-
162- return
163- }
164-
165104func (me * CssService ) DescribeCssPullStreamTask (ctx context.Context , taskId string ) (tasks []* css.PullStreamTaskInfo , errRet error ) {
166105 var (
167106 logId = getLogId (ctx )
0 commit comments