validators.go 42 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460
  1. // Code generated by smithy-go-codegen DO NOT EDIT.
  2. package cloudwatchlogs
  3. import (
  4. "context"
  5. "fmt"
  6. "github.com/aws/aws-sdk-go-v2/service/cloudwatchlogs/types"
  7. smithy "github.com/aws/smithy-go"
  8. "github.com/aws/smithy-go/middleware"
  9. )
  10. type validateOpAssociateKmsKey struct {
  11. }
  12. func (*validateOpAssociateKmsKey) ID() string {
  13. return "OperationInputValidation"
  14. }
  15. func (m *validateOpAssociateKmsKey) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
  16. out middleware.InitializeOutput, metadata middleware.Metadata, err error,
  17. ) {
  18. input, ok := in.Parameters.(*AssociateKmsKeyInput)
  19. if !ok {
  20. return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
  21. }
  22. if err := validateOpAssociateKmsKeyInput(input); err != nil {
  23. return out, metadata, err
  24. }
  25. return next.HandleInitialize(ctx, in)
  26. }
  27. type validateOpCancelExportTask struct {
  28. }
  29. func (*validateOpCancelExportTask) ID() string {
  30. return "OperationInputValidation"
  31. }
  32. func (m *validateOpCancelExportTask) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
  33. out middleware.InitializeOutput, metadata middleware.Metadata, err error,
  34. ) {
  35. input, ok := in.Parameters.(*CancelExportTaskInput)
  36. if !ok {
  37. return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
  38. }
  39. if err := validateOpCancelExportTaskInput(input); err != nil {
  40. return out, metadata, err
  41. }
  42. return next.HandleInitialize(ctx, in)
  43. }
  44. type validateOpCreateExportTask struct {
  45. }
  46. func (*validateOpCreateExportTask) ID() string {
  47. return "OperationInputValidation"
  48. }
  49. func (m *validateOpCreateExportTask) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
  50. out middleware.InitializeOutput, metadata middleware.Metadata, err error,
  51. ) {
  52. input, ok := in.Parameters.(*CreateExportTaskInput)
  53. if !ok {
  54. return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
  55. }
  56. if err := validateOpCreateExportTaskInput(input); err != nil {
  57. return out, metadata, err
  58. }
  59. return next.HandleInitialize(ctx, in)
  60. }
  61. type validateOpCreateLogGroup struct {
  62. }
  63. func (*validateOpCreateLogGroup) ID() string {
  64. return "OperationInputValidation"
  65. }
  66. func (m *validateOpCreateLogGroup) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
  67. out middleware.InitializeOutput, metadata middleware.Metadata, err error,
  68. ) {
  69. input, ok := in.Parameters.(*CreateLogGroupInput)
  70. if !ok {
  71. return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
  72. }
  73. if err := validateOpCreateLogGroupInput(input); err != nil {
  74. return out, metadata, err
  75. }
  76. return next.HandleInitialize(ctx, in)
  77. }
  78. type validateOpCreateLogStream struct {
  79. }
  80. func (*validateOpCreateLogStream) ID() string {
  81. return "OperationInputValidation"
  82. }
  83. func (m *validateOpCreateLogStream) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
  84. out middleware.InitializeOutput, metadata middleware.Metadata, err error,
  85. ) {
  86. input, ok := in.Parameters.(*CreateLogStreamInput)
  87. if !ok {
  88. return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
  89. }
  90. if err := validateOpCreateLogStreamInput(input); err != nil {
  91. return out, metadata, err
  92. }
  93. return next.HandleInitialize(ctx, in)
  94. }
  95. type validateOpDeleteDestination struct {
  96. }
  97. func (*validateOpDeleteDestination) ID() string {
  98. return "OperationInputValidation"
  99. }
  100. func (m *validateOpDeleteDestination) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
  101. out middleware.InitializeOutput, metadata middleware.Metadata, err error,
  102. ) {
  103. input, ok := in.Parameters.(*DeleteDestinationInput)
  104. if !ok {
  105. return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
  106. }
  107. if err := validateOpDeleteDestinationInput(input); err != nil {
  108. return out, metadata, err
  109. }
  110. return next.HandleInitialize(ctx, in)
  111. }
  112. type validateOpDeleteLogGroup struct {
  113. }
  114. func (*validateOpDeleteLogGroup) ID() string {
  115. return "OperationInputValidation"
  116. }
  117. func (m *validateOpDeleteLogGroup) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
  118. out middleware.InitializeOutput, metadata middleware.Metadata, err error,
  119. ) {
  120. input, ok := in.Parameters.(*DeleteLogGroupInput)
  121. if !ok {
  122. return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
  123. }
  124. if err := validateOpDeleteLogGroupInput(input); err != nil {
  125. return out, metadata, err
  126. }
  127. return next.HandleInitialize(ctx, in)
  128. }
  129. type validateOpDeleteLogStream struct {
  130. }
  131. func (*validateOpDeleteLogStream) ID() string {
  132. return "OperationInputValidation"
  133. }
  134. func (m *validateOpDeleteLogStream) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
  135. out middleware.InitializeOutput, metadata middleware.Metadata, err error,
  136. ) {
  137. input, ok := in.Parameters.(*DeleteLogStreamInput)
  138. if !ok {
  139. return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
  140. }
  141. if err := validateOpDeleteLogStreamInput(input); err != nil {
  142. return out, metadata, err
  143. }
  144. return next.HandleInitialize(ctx, in)
  145. }
  146. type validateOpDeleteMetricFilter struct {
  147. }
  148. func (*validateOpDeleteMetricFilter) ID() string {
  149. return "OperationInputValidation"
  150. }
  151. func (m *validateOpDeleteMetricFilter) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
  152. out middleware.InitializeOutput, metadata middleware.Metadata, err error,
  153. ) {
  154. input, ok := in.Parameters.(*DeleteMetricFilterInput)
  155. if !ok {
  156. return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
  157. }
  158. if err := validateOpDeleteMetricFilterInput(input); err != nil {
  159. return out, metadata, err
  160. }
  161. return next.HandleInitialize(ctx, in)
  162. }
  163. type validateOpDeleteQueryDefinition struct {
  164. }
  165. func (*validateOpDeleteQueryDefinition) ID() string {
  166. return "OperationInputValidation"
  167. }
  168. func (m *validateOpDeleteQueryDefinition) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
  169. out middleware.InitializeOutput, metadata middleware.Metadata, err error,
  170. ) {
  171. input, ok := in.Parameters.(*DeleteQueryDefinitionInput)
  172. if !ok {
  173. return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
  174. }
  175. if err := validateOpDeleteQueryDefinitionInput(input); err != nil {
  176. return out, metadata, err
  177. }
  178. return next.HandleInitialize(ctx, in)
  179. }
  180. type validateOpDeleteRetentionPolicy struct {
  181. }
  182. func (*validateOpDeleteRetentionPolicy) ID() string {
  183. return "OperationInputValidation"
  184. }
  185. func (m *validateOpDeleteRetentionPolicy) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
  186. out middleware.InitializeOutput, metadata middleware.Metadata, err error,
  187. ) {
  188. input, ok := in.Parameters.(*DeleteRetentionPolicyInput)
  189. if !ok {
  190. return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
  191. }
  192. if err := validateOpDeleteRetentionPolicyInput(input); err != nil {
  193. return out, metadata, err
  194. }
  195. return next.HandleInitialize(ctx, in)
  196. }
  197. type validateOpDeleteSubscriptionFilter struct {
  198. }
  199. func (*validateOpDeleteSubscriptionFilter) ID() string {
  200. return "OperationInputValidation"
  201. }
  202. func (m *validateOpDeleteSubscriptionFilter) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
  203. out middleware.InitializeOutput, metadata middleware.Metadata, err error,
  204. ) {
  205. input, ok := in.Parameters.(*DeleteSubscriptionFilterInput)
  206. if !ok {
  207. return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
  208. }
  209. if err := validateOpDeleteSubscriptionFilterInput(input); err != nil {
  210. return out, metadata, err
  211. }
  212. return next.HandleInitialize(ctx, in)
  213. }
  214. type validateOpDescribeLogStreams struct {
  215. }
  216. func (*validateOpDescribeLogStreams) ID() string {
  217. return "OperationInputValidation"
  218. }
  219. func (m *validateOpDescribeLogStreams) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
  220. out middleware.InitializeOutput, metadata middleware.Metadata, err error,
  221. ) {
  222. input, ok := in.Parameters.(*DescribeLogStreamsInput)
  223. if !ok {
  224. return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
  225. }
  226. if err := validateOpDescribeLogStreamsInput(input); err != nil {
  227. return out, metadata, err
  228. }
  229. return next.HandleInitialize(ctx, in)
  230. }
  231. type validateOpDescribeSubscriptionFilters struct {
  232. }
  233. func (*validateOpDescribeSubscriptionFilters) ID() string {
  234. return "OperationInputValidation"
  235. }
  236. func (m *validateOpDescribeSubscriptionFilters) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
  237. out middleware.InitializeOutput, metadata middleware.Metadata, err error,
  238. ) {
  239. input, ok := in.Parameters.(*DescribeSubscriptionFiltersInput)
  240. if !ok {
  241. return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
  242. }
  243. if err := validateOpDescribeSubscriptionFiltersInput(input); err != nil {
  244. return out, metadata, err
  245. }
  246. return next.HandleInitialize(ctx, in)
  247. }
  248. type validateOpDisassociateKmsKey struct {
  249. }
  250. func (*validateOpDisassociateKmsKey) ID() string {
  251. return "OperationInputValidation"
  252. }
  253. func (m *validateOpDisassociateKmsKey) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
  254. out middleware.InitializeOutput, metadata middleware.Metadata, err error,
  255. ) {
  256. input, ok := in.Parameters.(*DisassociateKmsKeyInput)
  257. if !ok {
  258. return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
  259. }
  260. if err := validateOpDisassociateKmsKeyInput(input); err != nil {
  261. return out, metadata, err
  262. }
  263. return next.HandleInitialize(ctx, in)
  264. }
  265. type validateOpFilterLogEvents struct {
  266. }
  267. func (*validateOpFilterLogEvents) ID() string {
  268. return "OperationInputValidation"
  269. }
  270. func (m *validateOpFilterLogEvents) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
  271. out middleware.InitializeOutput, metadata middleware.Metadata, err error,
  272. ) {
  273. input, ok := in.Parameters.(*FilterLogEventsInput)
  274. if !ok {
  275. return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
  276. }
  277. if err := validateOpFilterLogEventsInput(input); err != nil {
  278. return out, metadata, err
  279. }
  280. return next.HandleInitialize(ctx, in)
  281. }
  282. type validateOpGetLogEvents struct {
  283. }
  284. func (*validateOpGetLogEvents) ID() string {
  285. return "OperationInputValidation"
  286. }
  287. func (m *validateOpGetLogEvents) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
  288. out middleware.InitializeOutput, metadata middleware.Metadata, err error,
  289. ) {
  290. input, ok := in.Parameters.(*GetLogEventsInput)
  291. if !ok {
  292. return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
  293. }
  294. if err := validateOpGetLogEventsInput(input); err != nil {
  295. return out, metadata, err
  296. }
  297. return next.HandleInitialize(ctx, in)
  298. }
  299. type validateOpGetLogGroupFields struct {
  300. }
  301. func (*validateOpGetLogGroupFields) ID() string {
  302. return "OperationInputValidation"
  303. }
  304. func (m *validateOpGetLogGroupFields) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
  305. out middleware.InitializeOutput, metadata middleware.Metadata, err error,
  306. ) {
  307. input, ok := in.Parameters.(*GetLogGroupFieldsInput)
  308. if !ok {
  309. return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
  310. }
  311. if err := validateOpGetLogGroupFieldsInput(input); err != nil {
  312. return out, metadata, err
  313. }
  314. return next.HandleInitialize(ctx, in)
  315. }
  316. type validateOpGetLogRecord struct {
  317. }
  318. func (*validateOpGetLogRecord) ID() string {
  319. return "OperationInputValidation"
  320. }
  321. func (m *validateOpGetLogRecord) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
  322. out middleware.InitializeOutput, metadata middleware.Metadata, err error,
  323. ) {
  324. input, ok := in.Parameters.(*GetLogRecordInput)
  325. if !ok {
  326. return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
  327. }
  328. if err := validateOpGetLogRecordInput(input); err != nil {
  329. return out, metadata, err
  330. }
  331. return next.HandleInitialize(ctx, in)
  332. }
  333. type validateOpGetQueryResults struct {
  334. }
  335. func (*validateOpGetQueryResults) ID() string {
  336. return "OperationInputValidation"
  337. }
  338. func (m *validateOpGetQueryResults) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
  339. out middleware.InitializeOutput, metadata middleware.Metadata, err error,
  340. ) {
  341. input, ok := in.Parameters.(*GetQueryResultsInput)
  342. if !ok {
  343. return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
  344. }
  345. if err := validateOpGetQueryResultsInput(input); err != nil {
  346. return out, metadata, err
  347. }
  348. return next.HandleInitialize(ctx, in)
  349. }
  350. type validateOpListTagsLogGroup struct {
  351. }
  352. func (*validateOpListTagsLogGroup) ID() string {
  353. return "OperationInputValidation"
  354. }
  355. func (m *validateOpListTagsLogGroup) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
  356. out middleware.InitializeOutput, metadata middleware.Metadata, err error,
  357. ) {
  358. input, ok := in.Parameters.(*ListTagsLogGroupInput)
  359. if !ok {
  360. return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
  361. }
  362. if err := validateOpListTagsLogGroupInput(input); err != nil {
  363. return out, metadata, err
  364. }
  365. return next.HandleInitialize(ctx, in)
  366. }
  367. type validateOpPutDestination struct {
  368. }
  369. func (*validateOpPutDestination) ID() string {
  370. return "OperationInputValidation"
  371. }
  372. func (m *validateOpPutDestination) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
  373. out middleware.InitializeOutput, metadata middleware.Metadata, err error,
  374. ) {
  375. input, ok := in.Parameters.(*PutDestinationInput)
  376. if !ok {
  377. return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
  378. }
  379. if err := validateOpPutDestinationInput(input); err != nil {
  380. return out, metadata, err
  381. }
  382. return next.HandleInitialize(ctx, in)
  383. }
  384. type validateOpPutDestinationPolicy struct {
  385. }
  386. func (*validateOpPutDestinationPolicy) ID() string {
  387. return "OperationInputValidation"
  388. }
  389. func (m *validateOpPutDestinationPolicy) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
  390. out middleware.InitializeOutput, metadata middleware.Metadata, err error,
  391. ) {
  392. input, ok := in.Parameters.(*PutDestinationPolicyInput)
  393. if !ok {
  394. return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
  395. }
  396. if err := validateOpPutDestinationPolicyInput(input); err != nil {
  397. return out, metadata, err
  398. }
  399. return next.HandleInitialize(ctx, in)
  400. }
  401. type validateOpPutLogEvents struct {
  402. }
  403. func (*validateOpPutLogEvents) ID() string {
  404. return "OperationInputValidation"
  405. }
  406. func (m *validateOpPutLogEvents) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
  407. out middleware.InitializeOutput, metadata middleware.Metadata, err error,
  408. ) {
  409. input, ok := in.Parameters.(*PutLogEventsInput)
  410. if !ok {
  411. return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
  412. }
  413. if err := validateOpPutLogEventsInput(input); err != nil {
  414. return out, metadata, err
  415. }
  416. return next.HandleInitialize(ctx, in)
  417. }
  418. type validateOpPutMetricFilter struct {
  419. }
  420. func (*validateOpPutMetricFilter) ID() string {
  421. return "OperationInputValidation"
  422. }
  423. func (m *validateOpPutMetricFilter) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
  424. out middleware.InitializeOutput, metadata middleware.Metadata, err error,
  425. ) {
  426. input, ok := in.Parameters.(*PutMetricFilterInput)
  427. if !ok {
  428. return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
  429. }
  430. if err := validateOpPutMetricFilterInput(input); err != nil {
  431. return out, metadata, err
  432. }
  433. return next.HandleInitialize(ctx, in)
  434. }
  435. type validateOpPutQueryDefinition struct {
  436. }
  437. func (*validateOpPutQueryDefinition) ID() string {
  438. return "OperationInputValidation"
  439. }
  440. func (m *validateOpPutQueryDefinition) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
  441. out middleware.InitializeOutput, metadata middleware.Metadata, err error,
  442. ) {
  443. input, ok := in.Parameters.(*PutQueryDefinitionInput)
  444. if !ok {
  445. return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
  446. }
  447. if err := validateOpPutQueryDefinitionInput(input); err != nil {
  448. return out, metadata, err
  449. }
  450. return next.HandleInitialize(ctx, in)
  451. }
  452. type validateOpPutRetentionPolicy struct {
  453. }
  454. func (*validateOpPutRetentionPolicy) ID() string {
  455. return "OperationInputValidation"
  456. }
  457. func (m *validateOpPutRetentionPolicy) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
  458. out middleware.InitializeOutput, metadata middleware.Metadata, err error,
  459. ) {
  460. input, ok := in.Parameters.(*PutRetentionPolicyInput)
  461. if !ok {
  462. return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
  463. }
  464. if err := validateOpPutRetentionPolicyInput(input); err != nil {
  465. return out, metadata, err
  466. }
  467. return next.HandleInitialize(ctx, in)
  468. }
  469. type validateOpPutSubscriptionFilter struct {
  470. }
  471. func (*validateOpPutSubscriptionFilter) ID() string {
  472. return "OperationInputValidation"
  473. }
  474. func (m *validateOpPutSubscriptionFilter) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
  475. out middleware.InitializeOutput, metadata middleware.Metadata, err error,
  476. ) {
  477. input, ok := in.Parameters.(*PutSubscriptionFilterInput)
  478. if !ok {
  479. return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
  480. }
  481. if err := validateOpPutSubscriptionFilterInput(input); err != nil {
  482. return out, metadata, err
  483. }
  484. return next.HandleInitialize(ctx, in)
  485. }
  486. type validateOpStartQuery struct {
  487. }
  488. func (*validateOpStartQuery) ID() string {
  489. return "OperationInputValidation"
  490. }
  491. func (m *validateOpStartQuery) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
  492. out middleware.InitializeOutput, metadata middleware.Metadata, err error,
  493. ) {
  494. input, ok := in.Parameters.(*StartQueryInput)
  495. if !ok {
  496. return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
  497. }
  498. if err := validateOpStartQueryInput(input); err != nil {
  499. return out, metadata, err
  500. }
  501. return next.HandleInitialize(ctx, in)
  502. }
  503. type validateOpStopQuery struct {
  504. }
  505. func (*validateOpStopQuery) ID() string {
  506. return "OperationInputValidation"
  507. }
  508. func (m *validateOpStopQuery) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
  509. out middleware.InitializeOutput, metadata middleware.Metadata, err error,
  510. ) {
  511. input, ok := in.Parameters.(*StopQueryInput)
  512. if !ok {
  513. return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
  514. }
  515. if err := validateOpStopQueryInput(input); err != nil {
  516. return out, metadata, err
  517. }
  518. return next.HandleInitialize(ctx, in)
  519. }
  520. type validateOpTagLogGroup struct {
  521. }
  522. func (*validateOpTagLogGroup) ID() string {
  523. return "OperationInputValidation"
  524. }
  525. func (m *validateOpTagLogGroup) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
  526. out middleware.InitializeOutput, metadata middleware.Metadata, err error,
  527. ) {
  528. input, ok := in.Parameters.(*TagLogGroupInput)
  529. if !ok {
  530. return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
  531. }
  532. if err := validateOpTagLogGroupInput(input); err != nil {
  533. return out, metadata, err
  534. }
  535. return next.HandleInitialize(ctx, in)
  536. }
  537. type validateOpTestMetricFilter struct {
  538. }
  539. func (*validateOpTestMetricFilter) ID() string {
  540. return "OperationInputValidation"
  541. }
  542. func (m *validateOpTestMetricFilter) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
  543. out middleware.InitializeOutput, metadata middleware.Metadata, err error,
  544. ) {
  545. input, ok := in.Parameters.(*TestMetricFilterInput)
  546. if !ok {
  547. return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
  548. }
  549. if err := validateOpTestMetricFilterInput(input); err != nil {
  550. return out, metadata, err
  551. }
  552. return next.HandleInitialize(ctx, in)
  553. }
  554. type validateOpUntagLogGroup struct {
  555. }
  556. func (*validateOpUntagLogGroup) ID() string {
  557. return "OperationInputValidation"
  558. }
  559. func (m *validateOpUntagLogGroup) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) (
  560. out middleware.InitializeOutput, metadata middleware.Metadata, err error,
  561. ) {
  562. input, ok := in.Parameters.(*UntagLogGroupInput)
  563. if !ok {
  564. return out, metadata, fmt.Errorf("unknown input parameters type %T", in.Parameters)
  565. }
  566. if err := validateOpUntagLogGroupInput(input); err != nil {
  567. return out, metadata, err
  568. }
  569. return next.HandleInitialize(ctx, in)
  570. }
  571. func addOpAssociateKmsKeyValidationMiddleware(stack *middleware.Stack) error {
  572. return stack.Initialize.Add(&validateOpAssociateKmsKey{}, middleware.After)
  573. }
  574. func addOpCancelExportTaskValidationMiddleware(stack *middleware.Stack) error {
  575. return stack.Initialize.Add(&validateOpCancelExportTask{}, middleware.After)
  576. }
  577. func addOpCreateExportTaskValidationMiddleware(stack *middleware.Stack) error {
  578. return stack.Initialize.Add(&validateOpCreateExportTask{}, middleware.After)
  579. }
  580. func addOpCreateLogGroupValidationMiddleware(stack *middleware.Stack) error {
  581. return stack.Initialize.Add(&validateOpCreateLogGroup{}, middleware.After)
  582. }
  583. func addOpCreateLogStreamValidationMiddleware(stack *middleware.Stack) error {
  584. return stack.Initialize.Add(&validateOpCreateLogStream{}, middleware.After)
  585. }
  586. func addOpDeleteDestinationValidationMiddleware(stack *middleware.Stack) error {
  587. return stack.Initialize.Add(&validateOpDeleteDestination{}, middleware.After)
  588. }
  589. func addOpDeleteLogGroupValidationMiddleware(stack *middleware.Stack) error {
  590. return stack.Initialize.Add(&validateOpDeleteLogGroup{}, middleware.After)
  591. }
  592. func addOpDeleteLogStreamValidationMiddleware(stack *middleware.Stack) error {
  593. return stack.Initialize.Add(&validateOpDeleteLogStream{}, middleware.After)
  594. }
  595. func addOpDeleteMetricFilterValidationMiddleware(stack *middleware.Stack) error {
  596. return stack.Initialize.Add(&validateOpDeleteMetricFilter{}, middleware.After)
  597. }
  598. func addOpDeleteQueryDefinitionValidationMiddleware(stack *middleware.Stack) error {
  599. return stack.Initialize.Add(&validateOpDeleteQueryDefinition{}, middleware.After)
  600. }
  601. func addOpDeleteRetentionPolicyValidationMiddleware(stack *middleware.Stack) error {
  602. return stack.Initialize.Add(&validateOpDeleteRetentionPolicy{}, middleware.After)
  603. }
  604. func addOpDeleteSubscriptionFilterValidationMiddleware(stack *middleware.Stack) error {
  605. return stack.Initialize.Add(&validateOpDeleteSubscriptionFilter{}, middleware.After)
  606. }
  607. func addOpDescribeLogStreamsValidationMiddleware(stack *middleware.Stack) error {
  608. return stack.Initialize.Add(&validateOpDescribeLogStreams{}, middleware.After)
  609. }
  610. func addOpDescribeSubscriptionFiltersValidationMiddleware(stack *middleware.Stack) error {
  611. return stack.Initialize.Add(&validateOpDescribeSubscriptionFilters{}, middleware.After)
  612. }
  613. func addOpDisassociateKmsKeyValidationMiddleware(stack *middleware.Stack) error {
  614. return stack.Initialize.Add(&validateOpDisassociateKmsKey{}, middleware.After)
  615. }
  616. func addOpFilterLogEventsValidationMiddleware(stack *middleware.Stack) error {
  617. return stack.Initialize.Add(&validateOpFilterLogEvents{}, middleware.After)
  618. }
  619. func addOpGetLogEventsValidationMiddleware(stack *middleware.Stack) error {
  620. return stack.Initialize.Add(&validateOpGetLogEvents{}, middleware.After)
  621. }
  622. func addOpGetLogGroupFieldsValidationMiddleware(stack *middleware.Stack) error {
  623. return stack.Initialize.Add(&validateOpGetLogGroupFields{}, middleware.After)
  624. }
  625. func addOpGetLogRecordValidationMiddleware(stack *middleware.Stack) error {
  626. return stack.Initialize.Add(&validateOpGetLogRecord{}, middleware.After)
  627. }
  628. func addOpGetQueryResultsValidationMiddleware(stack *middleware.Stack) error {
  629. return stack.Initialize.Add(&validateOpGetQueryResults{}, middleware.After)
  630. }
  631. func addOpListTagsLogGroupValidationMiddleware(stack *middleware.Stack) error {
  632. return stack.Initialize.Add(&validateOpListTagsLogGroup{}, middleware.After)
  633. }
  634. func addOpPutDestinationValidationMiddleware(stack *middleware.Stack) error {
  635. return stack.Initialize.Add(&validateOpPutDestination{}, middleware.After)
  636. }
  637. func addOpPutDestinationPolicyValidationMiddleware(stack *middleware.Stack) error {
  638. return stack.Initialize.Add(&validateOpPutDestinationPolicy{}, middleware.After)
  639. }
  640. func addOpPutLogEventsValidationMiddleware(stack *middleware.Stack) error {
  641. return stack.Initialize.Add(&validateOpPutLogEvents{}, middleware.After)
  642. }
  643. func addOpPutMetricFilterValidationMiddleware(stack *middleware.Stack) error {
  644. return stack.Initialize.Add(&validateOpPutMetricFilter{}, middleware.After)
  645. }
  646. func addOpPutQueryDefinitionValidationMiddleware(stack *middleware.Stack) error {
  647. return stack.Initialize.Add(&validateOpPutQueryDefinition{}, middleware.After)
  648. }
  649. func addOpPutRetentionPolicyValidationMiddleware(stack *middleware.Stack) error {
  650. return stack.Initialize.Add(&validateOpPutRetentionPolicy{}, middleware.After)
  651. }
  652. func addOpPutSubscriptionFilterValidationMiddleware(stack *middleware.Stack) error {
  653. return stack.Initialize.Add(&validateOpPutSubscriptionFilter{}, middleware.After)
  654. }
  655. func addOpStartQueryValidationMiddleware(stack *middleware.Stack) error {
  656. return stack.Initialize.Add(&validateOpStartQuery{}, middleware.After)
  657. }
  658. func addOpStopQueryValidationMiddleware(stack *middleware.Stack) error {
  659. return stack.Initialize.Add(&validateOpStopQuery{}, middleware.After)
  660. }
  661. func addOpTagLogGroupValidationMiddleware(stack *middleware.Stack) error {
  662. return stack.Initialize.Add(&validateOpTagLogGroup{}, middleware.After)
  663. }
  664. func addOpTestMetricFilterValidationMiddleware(stack *middleware.Stack) error {
  665. return stack.Initialize.Add(&validateOpTestMetricFilter{}, middleware.After)
  666. }
  667. func addOpUntagLogGroupValidationMiddleware(stack *middleware.Stack) error {
  668. return stack.Initialize.Add(&validateOpUntagLogGroup{}, middleware.After)
  669. }
  670. func validateInputLogEvent(v *types.InputLogEvent) error {
  671. if v == nil {
  672. return nil
  673. }
  674. invalidParams := smithy.InvalidParamsError{Context: "InputLogEvent"}
  675. if v.Timestamp == nil {
  676. invalidParams.Add(smithy.NewErrParamRequired("Timestamp"))
  677. }
  678. if v.Message == nil {
  679. invalidParams.Add(smithy.NewErrParamRequired("Message"))
  680. }
  681. if invalidParams.Len() > 0 {
  682. return invalidParams
  683. } else {
  684. return nil
  685. }
  686. }
  687. func validateInputLogEvents(v []types.InputLogEvent) error {
  688. if v == nil {
  689. return nil
  690. }
  691. invalidParams := smithy.InvalidParamsError{Context: "InputLogEvents"}
  692. for i := range v {
  693. if err := validateInputLogEvent(&v[i]); err != nil {
  694. invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError))
  695. }
  696. }
  697. if invalidParams.Len() > 0 {
  698. return invalidParams
  699. } else {
  700. return nil
  701. }
  702. }
  703. func validateMetricTransformation(v *types.MetricTransformation) error {
  704. if v == nil {
  705. return nil
  706. }
  707. invalidParams := smithy.InvalidParamsError{Context: "MetricTransformation"}
  708. if v.MetricName == nil {
  709. invalidParams.Add(smithy.NewErrParamRequired("MetricName"))
  710. }
  711. if v.MetricNamespace == nil {
  712. invalidParams.Add(smithy.NewErrParamRequired("MetricNamespace"))
  713. }
  714. if v.MetricValue == nil {
  715. invalidParams.Add(smithy.NewErrParamRequired("MetricValue"))
  716. }
  717. if invalidParams.Len() > 0 {
  718. return invalidParams
  719. } else {
  720. return nil
  721. }
  722. }
  723. func validateMetricTransformations(v []types.MetricTransformation) error {
  724. if v == nil {
  725. return nil
  726. }
  727. invalidParams := smithy.InvalidParamsError{Context: "MetricTransformations"}
  728. for i := range v {
  729. if err := validateMetricTransformation(&v[i]); err != nil {
  730. invalidParams.AddNested(fmt.Sprintf("[%d]", i), err.(smithy.InvalidParamsError))
  731. }
  732. }
  733. if invalidParams.Len() > 0 {
  734. return invalidParams
  735. } else {
  736. return nil
  737. }
  738. }
  739. func validateOpAssociateKmsKeyInput(v *AssociateKmsKeyInput) error {
  740. if v == nil {
  741. return nil
  742. }
  743. invalidParams := smithy.InvalidParamsError{Context: "AssociateKmsKeyInput"}
  744. if v.LogGroupName == nil {
  745. invalidParams.Add(smithy.NewErrParamRequired("LogGroupName"))
  746. }
  747. if v.KmsKeyId == nil {
  748. invalidParams.Add(smithy.NewErrParamRequired("KmsKeyId"))
  749. }
  750. if invalidParams.Len() > 0 {
  751. return invalidParams
  752. } else {
  753. return nil
  754. }
  755. }
  756. func validateOpCancelExportTaskInput(v *CancelExportTaskInput) error {
  757. if v == nil {
  758. return nil
  759. }
  760. invalidParams := smithy.InvalidParamsError{Context: "CancelExportTaskInput"}
  761. if v.TaskId == nil {
  762. invalidParams.Add(smithy.NewErrParamRequired("TaskId"))
  763. }
  764. if invalidParams.Len() > 0 {
  765. return invalidParams
  766. } else {
  767. return nil
  768. }
  769. }
  770. func validateOpCreateExportTaskInput(v *CreateExportTaskInput) error {
  771. if v == nil {
  772. return nil
  773. }
  774. invalidParams := smithy.InvalidParamsError{Context: "CreateExportTaskInput"}
  775. if v.LogGroupName == nil {
  776. invalidParams.Add(smithy.NewErrParamRequired("LogGroupName"))
  777. }
  778. if v.From == nil {
  779. invalidParams.Add(smithy.NewErrParamRequired("From"))
  780. }
  781. if v.To == nil {
  782. invalidParams.Add(smithy.NewErrParamRequired("To"))
  783. }
  784. if v.Destination == nil {
  785. invalidParams.Add(smithy.NewErrParamRequired("Destination"))
  786. }
  787. if invalidParams.Len() > 0 {
  788. return invalidParams
  789. } else {
  790. return nil
  791. }
  792. }
  793. func validateOpCreateLogGroupInput(v *CreateLogGroupInput) error {
  794. if v == nil {
  795. return nil
  796. }
  797. invalidParams := smithy.InvalidParamsError{Context: "CreateLogGroupInput"}
  798. if v.LogGroupName == nil {
  799. invalidParams.Add(smithy.NewErrParamRequired("LogGroupName"))
  800. }
  801. if invalidParams.Len() > 0 {
  802. return invalidParams
  803. } else {
  804. return nil
  805. }
  806. }
  807. func validateOpCreateLogStreamInput(v *CreateLogStreamInput) error {
  808. if v == nil {
  809. return nil
  810. }
  811. invalidParams := smithy.InvalidParamsError{Context: "CreateLogStreamInput"}
  812. if v.LogGroupName == nil {
  813. invalidParams.Add(smithy.NewErrParamRequired("LogGroupName"))
  814. }
  815. if v.LogStreamName == nil {
  816. invalidParams.Add(smithy.NewErrParamRequired("LogStreamName"))
  817. }
  818. if invalidParams.Len() > 0 {
  819. return invalidParams
  820. } else {
  821. return nil
  822. }
  823. }
  824. func validateOpDeleteDestinationInput(v *DeleteDestinationInput) error {
  825. if v == nil {
  826. return nil
  827. }
  828. invalidParams := smithy.InvalidParamsError{Context: "DeleteDestinationInput"}
  829. if v.DestinationName == nil {
  830. invalidParams.Add(smithy.NewErrParamRequired("DestinationName"))
  831. }
  832. if invalidParams.Len() > 0 {
  833. return invalidParams
  834. } else {
  835. return nil
  836. }
  837. }
  838. func validateOpDeleteLogGroupInput(v *DeleteLogGroupInput) error {
  839. if v == nil {
  840. return nil
  841. }
  842. invalidParams := smithy.InvalidParamsError{Context: "DeleteLogGroupInput"}
  843. if v.LogGroupName == nil {
  844. invalidParams.Add(smithy.NewErrParamRequired("LogGroupName"))
  845. }
  846. if invalidParams.Len() > 0 {
  847. return invalidParams
  848. } else {
  849. return nil
  850. }
  851. }
  852. func validateOpDeleteLogStreamInput(v *DeleteLogStreamInput) error {
  853. if v == nil {
  854. return nil
  855. }
  856. invalidParams := smithy.InvalidParamsError{Context: "DeleteLogStreamInput"}
  857. if v.LogGroupName == nil {
  858. invalidParams.Add(smithy.NewErrParamRequired("LogGroupName"))
  859. }
  860. if v.LogStreamName == nil {
  861. invalidParams.Add(smithy.NewErrParamRequired("LogStreamName"))
  862. }
  863. if invalidParams.Len() > 0 {
  864. return invalidParams
  865. } else {
  866. return nil
  867. }
  868. }
  869. func validateOpDeleteMetricFilterInput(v *DeleteMetricFilterInput) error {
  870. if v == nil {
  871. return nil
  872. }
  873. invalidParams := smithy.InvalidParamsError{Context: "DeleteMetricFilterInput"}
  874. if v.LogGroupName == nil {
  875. invalidParams.Add(smithy.NewErrParamRequired("LogGroupName"))
  876. }
  877. if v.FilterName == nil {
  878. invalidParams.Add(smithy.NewErrParamRequired("FilterName"))
  879. }
  880. if invalidParams.Len() > 0 {
  881. return invalidParams
  882. } else {
  883. return nil
  884. }
  885. }
  886. func validateOpDeleteQueryDefinitionInput(v *DeleteQueryDefinitionInput) error {
  887. if v == nil {
  888. return nil
  889. }
  890. invalidParams := smithy.InvalidParamsError{Context: "DeleteQueryDefinitionInput"}
  891. if v.QueryDefinitionId == nil {
  892. invalidParams.Add(smithy.NewErrParamRequired("QueryDefinitionId"))
  893. }
  894. if invalidParams.Len() > 0 {
  895. return invalidParams
  896. } else {
  897. return nil
  898. }
  899. }
  900. func validateOpDeleteRetentionPolicyInput(v *DeleteRetentionPolicyInput) error {
  901. if v == nil {
  902. return nil
  903. }
  904. invalidParams := smithy.InvalidParamsError{Context: "DeleteRetentionPolicyInput"}
  905. if v.LogGroupName == nil {
  906. invalidParams.Add(smithy.NewErrParamRequired("LogGroupName"))
  907. }
  908. if invalidParams.Len() > 0 {
  909. return invalidParams
  910. } else {
  911. return nil
  912. }
  913. }
  914. func validateOpDeleteSubscriptionFilterInput(v *DeleteSubscriptionFilterInput) error {
  915. if v == nil {
  916. return nil
  917. }
  918. invalidParams := smithy.InvalidParamsError{Context: "DeleteSubscriptionFilterInput"}
  919. if v.LogGroupName == nil {
  920. invalidParams.Add(smithy.NewErrParamRequired("LogGroupName"))
  921. }
  922. if v.FilterName == nil {
  923. invalidParams.Add(smithy.NewErrParamRequired("FilterName"))
  924. }
  925. if invalidParams.Len() > 0 {
  926. return invalidParams
  927. } else {
  928. return nil
  929. }
  930. }
  931. func validateOpDescribeLogStreamsInput(v *DescribeLogStreamsInput) error {
  932. if v == nil {
  933. return nil
  934. }
  935. invalidParams := smithy.InvalidParamsError{Context: "DescribeLogStreamsInput"}
  936. if v.LogGroupName == nil {
  937. invalidParams.Add(smithy.NewErrParamRequired("LogGroupName"))
  938. }
  939. if invalidParams.Len() > 0 {
  940. return invalidParams
  941. } else {
  942. return nil
  943. }
  944. }
  945. func validateOpDescribeSubscriptionFiltersInput(v *DescribeSubscriptionFiltersInput) error {
  946. if v == nil {
  947. return nil
  948. }
  949. invalidParams := smithy.InvalidParamsError{Context: "DescribeSubscriptionFiltersInput"}
  950. if v.LogGroupName == nil {
  951. invalidParams.Add(smithy.NewErrParamRequired("LogGroupName"))
  952. }
  953. if invalidParams.Len() > 0 {
  954. return invalidParams
  955. } else {
  956. return nil
  957. }
  958. }
  959. func validateOpDisassociateKmsKeyInput(v *DisassociateKmsKeyInput) error {
  960. if v == nil {
  961. return nil
  962. }
  963. invalidParams := smithy.InvalidParamsError{Context: "DisassociateKmsKeyInput"}
  964. if v.LogGroupName == nil {
  965. invalidParams.Add(smithy.NewErrParamRequired("LogGroupName"))
  966. }
  967. if invalidParams.Len() > 0 {
  968. return invalidParams
  969. } else {
  970. return nil
  971. }
  972. }
  973. func validateOpFilterLogEventsInput(v *FilterLogEventsInput) error {
  974. if v == nil {
  975. return nil
  976. }
  977. invalidParams := smithy.InvalidParamsError{Context: "FilterLogEventsInput"}
  978. if v.LogGroupName == nil {
  979. invalidParams.Add(smithy.NewErrParamRequired("LogGroupName"))
  980. }
  981. if invalidParams.Len() > 0 {
  982. return invalidParams
  983. } else {
  984. return nil
  985. }
  986. }
  987. func validateOpGetLogEventsInput(v *GetLogEventsInput) error {
  988. if v == nil {
  989. return nil
  990. }
  991. invalidParams := smithy.InvalidParamsError{Context: "GetLogEventsInput"}
  992. if v.LogGroupName == nil {
  993. invalidParams.Add(smithy.NewErrParamRequired("LogGroupName"))
  994. }
  995. if v.LogStreamName == nil {
  996. invalidParams.Add(smithy.NewErrParamRequired("LogStreamName"))
  997. }
  998. if invalidParams.Len() > 0 {
  999. return invalidParams
  1000. } else {
  1001. return nil
  1002. }
  1003. }
  1004. func validateOpGetLogGroupFieldsInput(v *GetLogGroupFieldsInput) error {
  1005. if v == nil {
  1006. return nil
  1007. }
  1008. invalidParams := smithy.InvalidParamsError{Context: "GetLogGroupFieldsInput"}
  1009. if v.LogGroupName == nil {
  1010. invalidParams.Add(smithy.NewErrParamRequired("LogGroupName"))
  1011. }
  1012. if invalidParams.Len() > 0 {
  1013. return invalidParams
  1014. } else {
  1015. return nil
  1016. }
  1017. }
  1018. func validateOpGetLogRecordInput(v *GetLogRecordInput) error {
  1019. if v == nil {
  1020. return nil
  1021. }
  1022. invalidParams := smithy.InvalidParamsError{Context: "GetLogRecordInput"}
  1023. if v.LogRecordPointer == nil {
  1024. invalidParams.Add(smithy.NewErrParamRequired("LogRecordPointer"))
  1025. }
  1026. if invalidParams.Len() > 0 {
  1027. return invalidParams
  1028. } else {
  1029. return nil
  1030. }
  1031. }
  1032. func validateOpGetQueryResultsInput(v *GetQueryResultsInput) error {
  1033. if v == nil {
  1034. return nil
  1035. }
  1036. invalidParams := smithy.InvalidParamsError{Context: "GetQueryResultsInput"}
  1037. if v.QueryId == nil {
  1038. invalidParams.Add(smithy.NewErrParamRequired("QueryId"))
  1039. }
  1040. if invalidParams.Len() > 0 {
  1041. return invalidParams
  1042. } else {
  1043. return nil
  1044. }
  1045. }
  1046. func validateOpListTagsLogGroupInput(v *ListTagsLogGroupInput) error {
  1047. if v == nil {
  1048. return nil
  1049. }
  1050. invalidParams := smithy.InvalidParamsError{Context: "ListTagsLogGroupInput"}
  1051. if v.LogGroupName == nil {
  1052. invalidParams.Add(smithy.NewErrParamRequired("LogGroupName"))
  1053. }
  1054. if invalidParams.Len() > 0 {
  1055. return invalidParams
  1056. } else {
  1057. return nil
  1058. }
  1059. }
  1060. func validateOpPutDestinationInput(v *PutDestinationInput) error {
  1061. if v == nil {
  1062. return nil
  1063. }
  1064. invalidParams := smithy.InvalidParamsError{Context: "PutDestinationInput"}
  1065. if v.DestinationName == nil {
  1066. invalidParams.Add(smithy.NewErrParamRequired("DestinationName"))
  1067. }
  1068. if v.TargetArn == nil {
  1069. invalidParams.Add(smithy.NewErrParamRequired("TargetArn"))
  1070. }
  1071. if v.RoleArn == nil {
  1072. invalidParams.Add(smithy.NewErrParamRequired("RoleArn"))
  1073. }
  1074. if invalidParams.Len() > 0 {
  1075. return invalidParams
  1076. } else {
  1077. return nil
  1078. }
  1079. }
  1080. func validateOpPutDestinationPolicyInput(v *PutDestinationPolicyInput) error {
  1081. if v == nil {
  1082. return nil
  1083. }
  1084. invalidParams := smithy.InvalidParamsError{Context: "PutDestinationPolicyInput"}
  1085. if v.DestinationName == nil {
  1086. invalidParams.Add(smithy.NewErrParamRequired("DestinationName"))
  1087. }
  1088. if v.AccessPolicy == nil {
  1089. invalidParams.Add(smithy.NewErrParamRequired("AccessPolicy"))
  1090. }
  1091. if invalidParams.Len() > 0 {
  1092. return invalidParams
  1093. } else {
  1094. return nil
  1095. }
  1096. }
  1097. func validateOpPutLogEventsInput(v *PutLogEventsInput) error {
  1098. if v == nil {
  1099. return nil
  1100. }
  1101. invalidParams := smithy.InvalidParamsError{Context: "PutLogEventsInput"}
  1102. if v.LogGroupName == nil {
  1103. invalidParams.Add(smithy.NewErrParamRequired("LogGroupName"))
  1104. }
  1105. if v.LogStreamName == nil {
  1106. invalidParams.Add(smithy.NewErrParamRequired("LogStreamName"))
  1107. }
  1108. if v.LogEvents == nil {
  1109. invalidParams.Add(smithy.NewErrParamRequired("LogEvents"))
  1110. } else if v.LogEvents != nil {
  1111. if err := validateInputLogEvents(v.LogEvents); err != nil {
  1112. invalidParams.AddNested("LogEvents", err.(smithy.InvalidParamsError))
  1113. }
  1114. }
  1115. if invalidParams.Len() > 0 {
  1116. return invalidParams
  1117. } else {
  1118. return nil
  1119. }
  1120. }
  1121. func validateOpPutMetricFilterInput(v *PutMetricFilterInput) error {
  1122. if v == nil {
  1123. return nil
  1124. }
  1125. invalidParams := smithy.InvalidParamsError{Context: "PutMetricFilterInput"}
  1126. if v.LogGroupName == nil {
  1127. invalidParams.Add(smithy.NewErrParamRequired("LogGroupName"))
  1128. }
  1129. if v.FilterName == nil {
  1130. invalidParams.Add(smithy.NewErrParamRequired("FilterName"))
  1131. }
  1132. if v.FilterPattern == nil {
  1133. invalidParams.Add(smithy.NewErrParamRequired("FilterPattern"))
  1134. }
  1135. if v.MetricTransformations == nil {
  1136. invalidParams.Add(smithy.NewErrParamRequired("MetricTransformations"))
  1137. } else if v.MetricTransformations != nil {
  1138. if err := validateMetricTransformations(v.MetricTransformations); err != nil {
  1139. invalidParams.AddNested("MetricTransformations", err.(smithy.InvalidParamsError))
  1140. }
  1141. }
  1142. if invalidParams.Len() > 0 {
  1143. return invalidParams
  1144. } else {
  1145. return nil
  1146. }
  1147. }
  1148. func validateOpPutQueryDefinitionInput(v *PutQueryDefinitionInput) error {
  1149. if v == nil {
  1150. return nil
  1151. }
  1152. invalidParams := smithy.InvalidParamsError{Context: "PutQueryDefinitionInput"}
  1153. if v.Name == nil {
  1154. invalidParams.Add(smithy.NewErrParamRequired("Name"))
  1155. }
  1156. if v.QueryString == nil {
  1157. invalidParams.Add(smithy.NewErrParamRequired("QueryString"))
  1158. }
  1159. if invalidParams.Len() > 0 {
  1160. return invalidParams
  1161. } else {
  1162. return nil
  1163. }
  1164. }
  1165. func validateOpPutRetentionPolicyInput(v *PutRetentionPolicyInput) error {
  1166. if v == nil {
  1167. return nil
  1168. }
  1169. invalidParams := smithy.InvalidParamsError{Context: "PutRetentionPolicyInput"}
  1170. if v.LogGroupName == nil {
  1171. invalidParams.Add(smithy.NewErrParamRequired("LogGroupName"))
  1172. }
  1173. if v.RetentionInDays == nil {
  1174. invalidParams.Add(smithy.NewErrParamRequired("RetentionInDays"))
  1175. }
  1176. if invalidParams.Len() > 0 {
  1177. return invalidParams
  1178. } else {
  1179. return nil
  1180. }
  1181. }
  1182. func validateOpPutSubscriptionFilterInput(v *PutSubscriptionFilterInput) error {
  1183. if v == nil {
  1184. return nil
  1185. }
  1186. invalidParams := smithy.InvalidParamsError{Context: "PutSubscriptionFilterInput"}
  1187. if v.LogGroupName == nil {
  1188. invalidParams.Add(smithy.NewErrParamRequired("LogGroupName"))
  1189. }
  1190. if v.FilterName == nil {
  1191. invalidParams.Add(smithy.NewErrParamRequired("FilterName"))
  1192. }
  1193. if v.FilterPattern == nil {
  1194. invalidParams.Add(smithy.NewErrParamRequired("FilterPattern"))
  1195. }
  1196. if v.DestinationArn == nil {
  1197. invalidParams.Add(smithy.NewErrParamRequired("DestinationArn"))
  1198. }
  1199. if invalidParams.Len() > 0 {
  1200. return invalidParams
  1201. } else {
  1202. return nil
  1203. }
  1204. }
  1205. func validateOpStartQueryInput(v *StartQueryInput) error {
  1206. if v == nil {
  1207. return nil
  1208. }
  1209. invalidParams := smithy.InvalidParamsError{Context: "StartQueryInput"}
  1210. if v.StartTime == nil {
  1211. invalidParams.Add(smithy.NewErrParamRequired("StartTime"))
  1212. }
  1213. if v.EndTime == nil {
  1214. invalidParams.Add(smithy.NewErrParamRequired("EndTime"))
  1215. }
  1216. if v.QueryString == nil {
  1217. invalidParams.Add(smithy.NewErrParamRequired("QueryString"))
  1218. }
  1219. if invalidParams.Len() > 0 {
  1220. return invalidParams
  1221. } else {
  1222. return nil
  1223. }
  1224. }
  1225. func validateOpStopQueryInput(v *StopQueryInput) error {
  1226. if v == nil {
  1227. return nil
  1228. }
  1229. invalidParams := smithy.InvalidParamsError{Context: "StopQueryInput"}
  1230. if v.QueryId == nil {
  1231. invalidParams.Add(smithy.NewErrParamRequired("QueryId"))
  1232. }
  1233. if invalidParams.Len() > 0 {
  1234. return invalidParams
  1235. } else {
  1236. return nil
  1237. }
  1238. }
  1239. func validateOpTagLogGroupInput(v *TagLogGroupInput) error {
  1240. if v == nil {
  1241. return nil
  1242. }
  1243. invalidParams := smithy.InvalidParamsError{Context: "TagLogGroupInput"}
  1244. if v.LogGroupName == nil {
  1245. invalidParams.Add(smithy.NewErrParamRequired("LogGroupName"))
  1246. }
  1247. if v.Tags == nil {
  1248. invalidParams.Add(smithy.NewErrParamRequired("Tags"))
  1249. }
  1250. if invalidParams.Len() > 0 {
  1251. return invalidParams
  1252. } else {
  1253. return nil
  1254. }
  1255. }
  1256. func validateOpTestMetricFilterInput(v *TestMetricFilterInput) error {
  1257. if v == nil {
  1258. return nil
  1259. }
  1260. invalidParams := smithy.InvalidParamsError{Context: "TestMetricFilterInput"}
  1261. if v.FilterPattern == nil {
  1262. invalidParams.Add(smithy.NewErrParamRequired("FilterPattern"))
  1263. }
  1264. if v.LogEventMessages == nil {
  1265. invalidParams.Add(smithy.NewErrParamRequired("LogEventMessages"))
  1266. }
  1267. if invalidParams.Len() > 0 {
  1268. return invalidParams
  1269. } else {
  1270. return nil
  1271. }
  1272. }
  1273. func validateOpUntagLogGroupInput(v *UntagLogGroupInput) error {
  1274. if v == nil {
  1275. return nil
  1276. }
  1277. invalidParams := smithy.InvalidParamsError{Context: "UntagLogGroupInput"}
  1278. if v.LogGroupName == nil {
  1279. invalidParams.Add(smithy.NewErrParamRequired("LogGroupName"))
  1280. }
  1281. if v.Tags == nil {
  1282. invalidParams.Add(smithy.NewErrParamRequired("Tags"))
  1283. }
  1284. if invalidParams.Len() > 0 {
  1285. return invalidParams
  1286. } else {
  1287. return nil
  1288. }
  1289. }