serializers.go 107 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492249324942495249624972498249925002501250225032504250525062507250825092510251125122513251425152516251725182519252025212522252325242525252625272528252925302531253225332534253525362537253825392540254125422543254425452546254725482549255025512552255325542555255625572558255925602561256225632564256525662567256825692570257125722573257425752576257725782579258025812582258325842585258625872588258925902591259225932594259525962597259825992600260126022603260426052606260726082609261026112612261326142615261626172618261926202621262226232624262526262627262826292630263126322633263426352636263726382639264026412642264326442645264626472648264926502651265226532654265526562657265826592660266126622663266426652666266726682669267026712672267326742675267626772678267926802681268226832684268526862687268826892690269126922693269426952696269726982699270027012702270327042705270627072708270927102711271227132714271527162717271827192720272127222723272427252726272727282729273027312732273327342735273627372738273927402741274227432744274527462747274827492750275127522753275427552756275727582759276027612762276327642765276627672768276927702771277227732774277527762777277827792780278127822783278427852786278727882789279027912792279327942795279627972798279928002801280228032804280528062807280828092810281128122813281428152816281728182819282028212822282328242825282628272828282928302831283228332834283528362837283828392840284128422843284428452846284728482849285028512852285328542855285628572858285928602861286228632864286528662867286828692870287128722873287428752876287728782879288028812882288328842885288628872888288928902891289228932894289528962897289828992900290129022903290429052906290729082909291029112912291329142915291629172918291929202921292229232924292529262927292829292930293129322933293429352936293729382939294029412942294329442945294629472948294929502951295229532954295529562957295829592960296129622963296429652966296729682969297029712972297329742975297629772978297929802981298229832984298529862987298829892990299129922993299429952996299729982999300030013002300330043005300630073008300930103011301230133014301530163017301830193020302130223023302430253026302730283029303030313032303330343035303630373038303930403041304230433044304530463047304830493050305130523053305430553056305730583059306030613062306330643065306630673068306930703071307230733074307530763077307830793080308130823083308430853086308730883089309030913092309330943095309630973098309931003101310231033104310531063107310831093110311131123113311431153116311731183119312031213122312331243125312631273128312931303131313231333134313531363137313831393140314131423143314431453146314731483149315031513152315331543155315631573158315931603161316231633164316531663167316831693170317131723173317431753176317731783179318031813182318331843185318631873188318931903191319231933194319531963197319831993200320132023203320432053206320732083209321032113212321332143215321632173218321932203221322232233224322532263227322832293230323132323233323432353236323732383239324032413242324332443245324632473248324932503251325232533254325532563257325832593260326132623263326432653266326732683269327032713272327332743275327632773278327932803281328232833284328532863287328832893290329132923293329432953296329732983299330033013302330333043305330633073308330933103311331233133314331533163317331833193320332133223323332433253326332733283329333033313332333333343335333633373338333933403341334233433344334533463347334833493350335133523353335433553356335733583359336033613362336333643365336633673368336933703371337233733374337533763377337833793380338133823383338433853386338733883389339033913392339333943395339633973398339934003401340234033404340534063407340834093410341134123413341434153416341734183419
  1. // Code generated by smithy-go-codegen DO NOT EDIT.
  2. package cloudwatchlogs
  3. import (
  4. "bytes"
  5. "context"
  6. "fmt"
  7. "github.com/aws/aws-sdk-go-v2/service/cloudwatchlogs/types"
  8. smithy "github.com/aws/smithy-go"
  9. "github.com/aws/smithy-go/encoding/httpbinding"
  10. smithyjson "github.com/aws/smithy-go/encoding/json"
  11. "github.com/aws/smithy-go/middleware"
  12. smithyhttp "github.com/aws/smithy-go/transport/http"
  13. "math"
  14. "path"
  15. )
  16. type awsAwsjson11_serializeOpAssociateKmsKey struct {
  17. }
  18. func (*awsAwsjson11_serializeOpAssociateKmsKey) ID() string {
  19. return "OperationSerializer"
  20. }
  21. func (m *awsAwsjson11_serializeOpAssociateKmsKey) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  22. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  23. ) {
  24. request, ok := in.Request.(*smithyhttp.Request)
  25. if !ok {
  26. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  27. }
  28. input, ok := in.Parameters.(*AssociateKmsKeyInput)
  29. _ = input
  30. if !ok {
  31. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  32. }
  33. operationPath := "/"
  34. if len(request.Request.URL.Path) == 0 {
  35. request.Request.URL.Path = operationPath
  36. } else {
  37. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  38. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  39. request.Request.URL.Path += "/"
  40. }
  41. }
  42. request.Request.Method = "POST"
  43. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  44. if err != nil {
  45. return out, metadata, &smithy.SerializationError{Err: err}
  46. }
  47. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  48. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.AssociateKmsKey")
  49. jsonEncoder := smithyjson.NewEncoder()
  50. if err := awsAwsjson11_serializeOpDocumentAssociateKmsKeyInput(input, jsonEncoder.Value); err != nil {
  51. return out, metadata, &smithy.SerializationError{Err: err}
  52. }
  53. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  54. return out, metadata, &smithy.SerializationError{Err: err}
  55. }
  56. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  57. return out, metadata, &smithy.SerializationError{Err: err}
  58. }
  59. in.Request = request
  60. return next.HandleSerialize(ctx, in)
  61. }
  62. type awsAwsjson11_serializeOpCancelExportTask struct {
  63. }
  64. func (*awsAwsjson11_serializeOpCancelExportTask) ID() string {
  65. return "OperationSerializer"
  66. }
  67. func (m *awsAwsjson11_serializeOpCancelExportTask) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  68. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  69. ) {
  70. request, ok := in.Request.(*smithyhttp.Request)
  71. if !ok {
  72. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  73. }
  74. input, ok := in.Parameters.(*CancelExportTaskInput)
  75. _ = input
  76. if !ok {
  77. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  78. }
  79. operationPath := "/"
  80. if len(request.Request.URL.Path) == 0 {
  81. request.Request.URL.Path = operationPath
  82. } else {
  83. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  84. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  85. request.Request.URL.Path += "/"
  86. }
  87. }
  88. request.Request.Method = "POST"
  89. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  90. if err != nil {
  91. return out, metadata, &smithy.SerializationError{Err: err}
  92. }
  93. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  94. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.CancelExportTask")
  95. jsonEncoder := smithyjson.NewEncoder()
  96. if err := awsAwsjson11_serializeOpDocumentCancelExportTaskInput(input, jsonEncoder.Value); err != nil {
  97. return out, metadata, &smithy.SerializationError{Err: err}
  98. }
  99. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  100. return out, metadata, &smithy.SerializationError{Err: err}
  101. }
  102. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  103. return out, metadata, &smithy.SerializationError{Err: err}
  104. }
  105. in.Request = request
  106. return next.HandleSerialize(ctx, in)
  107. }
  108. type awsAwsjson11_serializeOpCreateExportTask struct {
  109. }
  110. func (*awsAwsjson11_serializeOpCreateExportTask) ID() string {
  111. return "OperationSerializer"
  112. }
  113. func (m *awsAwsjson11_serializeOpCreateExportTask) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  114. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  115. ) {
  116. request, ok := in.Request.(*smithyhttp.Request)
  117. if !ok {
  118. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  119. }
  120. input, ok := in.Parameters.(*CreateExportTaskInput)
  121. _ = input
  122. if !ok {
  123. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  124. }
  125. operationPath := "/"
  126. if len(request.Request.URL.Path) == 0 {
  127. request.Request.URL.Path = operationPath
  128. } else {
  129. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  130. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  131. request.Request.URL.Path += "/"
  132. }
  133. }
  134. request.Request.Method = "POST"
  135. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  136. if err != nil {
  137. return out, metadata, &smithy.SerializationError{Err: err}
  138. }
  139. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  140. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.CreateExportTask")
  141. jsonEncoder := smithyjson.NewEncoder()
  142. if err := awsAwsjson11_serializeOpDocumentCreateExportTaskInput(input, jsonEncoder.Value); err != nil {
  143. return out, metadata, &smithy.SerializationError{Err: err}
  144. }
  145. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  146. return out, metadata, &smithy.SerializationError{Err: err}
  147. }
  148. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  149. return out, metadata, &smithy.SerializationError{Err: err}
  150. }
  151. in.Request = request
  152. return next.HandleSerialize(ctx, in)
  153. }
  154. type awsAwsjson11_serializeOpCreateLogGroup struct {
  155. }
  156. func (*awsAwsjson11_serializeOpCreateLogGroup) ID() string {
  157. return "OperationSerializer"
  158. }
  159. func (m *awsAwsjson11_serializeOpCreateLogGroup) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  160. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  161. ) {
  162. request, ok := in.Request.(*smithyhttp.Request)
  163. if !ok {
  164. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  165. }
  166. input, ok := in.Parameters.(*CreateLogGroupInput)
  167. _ = input
  168. if !ok {
  169. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  170. }
  171. operationPath := "/"
  172. if len(request.Request.URL.Path) == 0 {
  173. request.Request.URL.Path = operationPath
  174. } else {
  175. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  176. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  177. request.Request.URL.Path += "/"
  178. }
  179. }
  180. request.Request.Method = "POST"
  181. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  182. if err != nil {
  183. return out, metadata, &smithy.SerializationError{Err: err}
  184. }
  185. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  186. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.CreateLogGroup")
  187. jsonEncoder := smithyjson.NewEncoder()
  188. if err := awsAwsjson11_serializeOpDocumentCreateLogGroupInput(input, jsonEncoder.Value); err != nil {
  189. return out, metadata, &smithy.SerializationError{Err: err}
  190. }
  191. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  192. return out, metadata, &smithy.SerializationError{Err: err}
  193. }
  194. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  195. return out, metadata, &smithy.SerializationError{Err: err}
  196. }
  197. in.Request = request
  198. return next.HandleSerialize(ctx, in)
  199. }
  200. type awsAwsjson11_serializeOpCreateLogStream struct {
  201. }
  202. func (*awsAwsjson11_serializeOpCreateLogStream) ID() string {
  203. return "OperationSerializer"
  204. }
  205. func (m *awsAwsjson11_serializeOpCreateLogStream) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  206. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  207. ) {
  208. request, ok := in.Request.(*smithyhttp.Request)
  209. if !ok {
  210. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  211. }
  212. input, ok := in.Parameters.(*CreateLogStreamInput)
  213. _ = input
  214. if !ok {
  215. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  216. }
  217. operationPath := "/"
  218. if len(request.Request.URL.Path) == 0 {
  219. request.Request.URL.Path = operationPath
  220. } else {
  221. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  222. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  223. request.Request.URL.Path += "/"
  224. }
  225. }
  226. request.Request.Method = "POST"
  227. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  228. if err != nil {
  229. return out, metadata, &smithy.SerializationError{Err: err}
  230. }
  231. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  232. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.CreateLogStream")
  233. jsonEncoder := smithyjson.NewEncoder()
  234. if err := awsAwsjson11_serializeOpDocumentCreateLogStreamInput(input, jsonEncoder.Value); err != nil {
  235. return out, metadata, &smithy.SerializationError{Err: err}
  236. }
  237. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  238. return out, metadata, &smithy.SerializationError{Err: err}
  239. }
  240. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  241. return out, metadata, &smithy.SerializationError{Err: err}
  242. }
  243. in.Request = request
  244. return next.HandleSerialize(ctx, in)
  245. }
  246. type awsAwsjson11_serializeOpDeleteDestination struct {
  247. }
  248. func (*awsAwsjson11_serializeOpDeleteDestination) ID() string {
  249. return "OperationSerializer"
  250. }
  251. func (m *awsAwsjson11_serializeOpDeleteDestination) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  252. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  253. ) {
  254. request, ok := in.Request.(*smithyhttp.Request)
  255. if !ok {
  256. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  257. }
  258. input, ok := in.Parameters.(*DeleteDestinationInput)
  259. _ = input
  260. if !ok {
  261. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  262. }
  263. operationPath := "/"
  264. if len(request.Request.URL.Path) == 0 {
  265. request.Request.URL.Path = operationPath
  266. } else {
  267. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  268. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  269. request.Request.URL.Path += "/"
  270. }
  271. }
  272. request.Request.Method = "POST"
  273. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  274. if err != nil {
  275. return out, metadata, &smithy.SerializationError{Err: err}
  276. }
  277. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  278. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.DeleteDestination")
  279. jsonEncoder := smithyjson.NewEncoder()
  280. if err := awsAwsjson11_serializeOpDocumentDeleteDestinationInput(input, jsonEncoder.Value); err != nil {
  281. return out, metadata, &smithy.SerializationError{Err: err}
  282. }
  283. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  284. return out, metadata, &smithy.SerializationError{Err: err}
  285. }
  286. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  287. return out, metadata, &smithy.SerializationError{Err: err}
  288. }
  289. in.Request = request
  290. return next.HandleSerialize(ctx, in)
  291. }
  292. type awsAwsjson11_serializeOpDeleteLogGroup struct {
  293. }
  294. func (*awsAwsjson11_serializeOpDeleteLogGroup) ID() string {
  295. return "OperationSerializer"
  296. }
  297. func (m *awsAwsjson11_serializeOpDeleteLogGroup) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  298. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  299. ) {
  300. request, ok := in.Request.(*smithyhttp.Request)
  301. if !ok {
  302. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  303. }
  304. input, ok := in.Parameters.(*DeleteLogGroupInput)
  305. _ = input
  306. if !ok {
  307. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  308. }
  309. operationPath := "/"
  310. if len(request.Request.URL.Path) == 0 {
  311. request.Request.URL.Path = operationPath
  312. } else {
  313. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  314. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  315. request.Request.URL.Path += "/"
  316. }
  317. }
  318. request.Request.Method = "POST"
  319. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  320. if err != nil {
  321. return out, metadata, &smithy.SerializationError{Err: err}
  322. }
  323. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  324. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.DeleteLogGroup")
  325. jsonEncoder := smithyjson.NewEncoder()
  326. if err := awsAwsjson11_serializeOpDocumentDeleteLogGroupInput(input, jsonEncoder.Value); err != nil {
  327. return out, metadata, &smithy.SerializationError{Err: err}
  328. }
  329. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  330. return out, metadata, &smithy.SerializationError{Err: err}
  331. }
  332. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  333. return out, metadata, &smithy.SerializationError{Err: err}
  334. }
  335. in.Request = request
  336. return next.HandleSerialize(ctx, in)
  337. }
  338. type awsAwsjson11_serializeOpDeleteLogStream struct {
  339. }
  340. func (*awsAwsjson11_serializeOpDeleteLogStream) ID() string {
  341. return "OperationSerializer"
  342. }
  343. func (m *awsAwsjson11_serializeOpDeleteLogStream) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  344. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  345. ) {
  346. request, ok := in.Request.(*smithyhttp.Request)
  347. if !ok {
  348. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  349. }
  350. input, ok := in.Parameters.(*DeleteLogStreamInput)
  351. _ = input
  352. if !ok {
  353. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  354. }
  355. operationPath := "/"
  356. if len(request.Request.URL.Path) == 0 {
  357. request.Request.URL.Path = operationPath
  358. } else {
  359. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  360. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  361. request.Request.URL.Path += "/"
  362. }
  363. }
  364. request.Request.Method = "POST"
  365. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  366. if err != nil {
  367. return out, metadata, &smithy.SerializationError{Err: err}
  368. }
  369. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  370. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.DeleteLogStream")
  371. jsonEncoder := smithyjson.NewEncoder()
  372. if err := awsAwsjson11_serializeOpDocumentDeleteLogStreamInput(input, jsonEncoder.Value); err != nil {
  373. return out, metadata, &smithy.SerializationError{Err: err}
  374. }
  375. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  376. return out, metadata, &smithy.SerializationError{Err: err}
  377. }
  378. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  379. return out, metadata, &smithy.SerializationError{Err: err}
  380. }
  381. in.Request = request
  382. return next.HandleSerialize(ctx, in)
  383. }
  384. type awsAwsjson11_serializeOpDeleteMetricFilter struct {
  385. }
  386. func (*awsAwsjson11_serializeOpDeleteMetricFilter) ID() string {
  387. return "OperationSerializer"
  388. }
  389. func (m *awsAwsjson11_serializeOpDeleteMetricFilter) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  390. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  391. ) {
  392. request, ok := in.Request.(*smithyhttp.Request)
  393. if !ok {
  394. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  395. }
  396. input, ok := in.Parameters.(*DeleteMetricFilterInput)
  397. _ = input
  398. if !ok {
  399. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  400. }
  401. operationPath := "/"
  402. if len(request.Request.URL.Path) == 0 {
  403. request.Request.URL.Path = operationPath
  404. } else {
  405. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  406. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  407. request.Request.URL.Path += "/"
  408. }
  409. }
  410. request.Request.Method = "POST"
  411. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  412. if err != nil {
  413. return out, metadata, &smithy.SerializationError{Err: err}
  414. }
  415. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  416. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.DeleteMetricFilter")
  417. jsonEncoder := smithyjson.NewEncoder()
  418. if err := awsAwsjson11_serializeOpDocumentDeleteMetricFilterInput(input, jsonEncoder.Value); err != nil {
  419. return out, metadata, &smithy.SerializationError{Err: err}
  420. }
  421. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  422. return out, metadata, &smithy.SerializationError{Err: err}
  423. }
  424. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  425. return out, metadata, &smithy.SerializationError{Err: err}
  426. }
  427. in.Request = request
  428. return next.HandleSerialize(ctx, in)
  429. }
  430. type awsAwsjson11_serializeOpDeleteQueryDefinition struct {
  431. }
  432. func (*awsAwsjson11_serializeOpDeleteQueryDefinition) ID() string {
  433. return "OperationSerializer"
  434. }
  435. func (m *awsAwsjson11_serializeOpDeleteQueryDefinition) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  436. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  437. ) {
  438. request, ok := in.Request.(*smithyhttp.Request)
  439. if !ok {
  440. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  441. }
  442. input, ok := in.Parameters.(*DeleteQueryDefinitionInput)
  443. _ = input
  444. if !ok {
  445. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  446. }
  447. operationPath := "/"
  448. if len(request.Request.URL.Path) == 0 {
  449. request.Request.URL.Path = operationPath
  450. } else {
  451. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  452. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  453. request.Request.URL.Path += "/"
  454. }
  455. }
  456. request.Request.Method = "POST"
  457. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  458. if err != nil {
  459. return out, metadata, &smithy.SerializationError{Err: err}
  460. }
  461. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  462. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.DeleteQueryDefinition")
  463. jsonEncoder := smithyjson.NewEncoder()
  464. if err := awsAwsjson11_serializeOpDocumentDeleteQueryDefinitionInput(input, jsonEncoder.Value); err != nil {
  465. return out, metadata, &smithy.SerializationError{Err: err}
  466. }
  467. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  468. return out, metadata, &smithy.SerializationError{Err: err}
  469. }
  470. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  471. return out, metadata, &smithy.SerializationError{Err: err}
  472. }
  473. in.Request = request
  474. return next.HandleSerialize(ctx, in)
  475. }
  476. type awsAwsjson11_serializeOpDeleteResourcePolicy struct {
  477. }
  478. func (*awsAwsjson11_serializeOpDeleteResourcePolicy) ID() string {
  479. return "OperationSerializer"
  480. }
  481. func (m *awsAwsjson11_serializeOpDeleteResourcePolicy) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  482. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  483. ) {
  484. request, ok := in.Request.(*smithyhttp.Request)
  485. if !ok {
  486. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  487. }
  488. input, ok := in.Parameters.(*DeleteResourcePolicyInput)
  489. _ = input
  490. if !ok {
  491. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  492. }
  493. operationPath := "/"
  494. if len(request.Request.URL.Path) == 0 {
  495. request.Request.URL.Path = operationPath
  496. } else {
  497. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  498. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  499. request.Request.URL.Path += "/"
  500. }
  501. }
  502. request.Request.Method = "POST"
  503. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  504. if err != nil {
  505. return out, metadata, &smithy.SerializationError{Err: err}
  506. }
  507. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  508. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.DeleteResourcePolicy")
  509. jsonEncoder := smithyjson.NewEncoder()
  510. if err := awsAwsjson11_serializeOpDocumentDeleteResourcePolicyInput(input, jsonEncoder.Value); err != nil {
  511. return out, metadata, &smithy.SerializationError{Err: err}
  512. }
  513. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  514. return out, metadata, &smithy.SerializationError{Err: err}
  515. }
  516. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  517. return out, metadata, &smithy.SerializationError{Err: err}
  518. }
  519. in.Request = request
  520. return next.HandleSerialize(ctx, in)
  521. }
  522. type awsAwsjson11_serializeOpDeleteRetentionPolicy struct {
  523. }
  524. func (*awsAwsjson11_serializeOpDeleteRetentionPolicy) ID() string {
  525. return "OperationSerializer"
  526. }
  527. func (m *awsAwsjson11_serializeOpDeleteRetentionPolicy) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  528. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  529. ) {
  530. request, ok := in.Request.(*smithyhttp.Request)
  531. if !ok {
  532. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  533. }
  534. input, ok := in.Parameters.(*DeleteRetentionPolicyInput)
  535. _ = input
  536. if !ok {
  537. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  538. }
  539. operationPath := "/"
  540. if len(request.Request.URL.Path) == 0 {
  541. request.Request.URL.Path = operationPath
  542. } else {
  543. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  544. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  545. request.Request.URL.Path += "/"
  546. }
  547. }
  548. request.Request.Method = "POST"
  549. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  550. if err != nil {
  551. return out, metadata, &smithy.SerializationError{Err: err}
  552. }
  553. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  554. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.DeleteRetentionPolicy")
  555. jsonEncoder := smithyjson.NewEncoder()
  556. if err := awsAwsjson11_serializeOpDocumentDeleteRetentionPolicyInput(input, jsonEncoder.Value); err != nil {
  557. return out, metadata, &smithy.SerializationError{Err: err}
  558. }
  559. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  560. return out, metadata, &smithy.SerializationError{Err: err}
  561. }
  562. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  563. return out, metadata, &smithy.SerializationError{Err: err}
  564. }
  565. in.Request = request
  566. return next.HandleSerialize(ctx, in)
  567. }
  568. type awsAwsjson11_serializeOpDeleteSubscriptionFilter struct {
  569. }
  570. func (*awsAwsjson11_serializeOpDeleteSubscriptionFilter) ID() string {
  571. return "OperationSerializer"
  572. }
  573. func (m *awsAwsjson11_serializeOpDeleteSubscriptionFilter) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  574. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  575. ) {
  576. request, ok := in.Request.(*smithyhttp.Request)
  577. if !ok {
  578. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  579. }
  580. input, ok := in.Parameters.(*DeleteSubscriptionFilterInput)
  581. _ = input
  582. if !ok {
  583. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  584. }
  585. operationPath := "/"
  586. if len(request.Request.URL.Path) == 0 {
  587. request.Request.URL.Path = operationPath
  588. } else {
  589. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  590. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  591. request.Request.URL.Path += "/"
  592. }
  593. }
  594. request.Request.Method = "POST"
  595. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  596. if err != nil {
  597. return out, metadata, &smithy.SerializationError{Err: err}
  598. }
  599. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  600. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.DeleteSubscriptionFilter")
  601. jsonEncoder := smithyjson.NewEncoder()
  602. if err := awsAwsjson11_serializeOpDocumentDeleteSubscriptionFilterInput(input, jsonEncoder.Value); err != nil {
  603. return out, metadata, &smithy.SerializationError{Err: err}
  604. }
  605. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  606. return out, metadata, &smithy.SerializationError{Err: err}
  607. }
  608. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  609. return out, metadata, &smithy.SerializationError{Err: err}
  610. }
  611. in.Request = request
  612. return next.HandleSerialize(ctx, in)
  613. }
  614. type awsAwsjson11_serializeOpDescribeDestinations struct {
  615. }
  616. func (*awsAwsjson11_serializeOpDescribeDestinations) ID() string {
  617. return "OperationSerializer"
  618. }
  619. func (m *awsAwsjson11_serializeOpDescribeDestinations) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  620. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  621. ) {
  622. request, ok := in.Request.(*smithyhttp.Request)
  623. if !ok {
  624. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  625. }
  626. input, ok := in.Parameters.(*DescribeDestinationsInput)
  627. _ = input
  628. if !ok {
  629. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  630. }
  631. operationPath := "/"
  632. if len(request.Request.URL.Path) == 0 {
  633. request.Request.URL.Path = operationPath
  634. } else {
  635. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  636. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  637. request.Request.URL.Path += "/"
  638. }
  639. }
  640. request.Request.Method = "POST"
  641. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  642. if err != nil {
  643. return out, metadata, &smithy.SerializationError{Err: err}
  644. }
  645. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  646. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.DescribeDestinations")
  647. jsonEncoder := smithyjson.NewEncoder()
  648. if err := awsAwsjson11_serializeOpDocumentDescribeDestinationsInput(input, jsonEncoder.Value); err != nil {
  649. return out, metadata, &smithy.SerializationError{Err: err}
  650. }
  651. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  652. return out, metadata, &smithy.SerializationError{Err: err}
  653. }
  654. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  655. return out, metadata, &smithy.SerializationError{Err: err}
  656. }
  657. in.Request = request
  658. return next.HandleSerialize(ctx, in)
  659. }
  660. type awsAwsjson11_serializeOpDescribeExportTasks struct {
  661. }
  662. func (*awsAwsjson11_serializeOpDescribeExportTasks) ID() string {
  663. return "OperationSerializer"
  664. }
  665. func (m *awsAwsjson11_serializeOpDescribeExportTasks) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  666. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  667. ) {
  668. request, ok := in.Request.(*smithyhttp.Request)
  669. if !ok {
  670. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  671. }
  672. input, ok := in.Parameters.(*DescribeExportTasksInput)
  673. _ = input
  674. if !ok {
  675. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  676. }
  677. operationPath := "/"
  678. if len(request.Request.URL.Path) == 0 {
  679. request.Request.URL.Path = operationPath
  680. } else {
  681. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  682. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  683. request.Request.URL.Path += "/"
  684. }
  685. }
  686. request.Request.Method = "POST"
  687. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  688. if err != nil {
  689. return out, metadata, &smithy.SerializationError{Err: err}
  690. }
  691. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  692. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.DescribeExportTasks")
  693. jsonEncoder := smithyjson.NewEncoder()
  694. if err := awsAwsjson11_serializeOpDocumentDescribeExportTasksInput(input, jsonEncoder.Value); err != nil {
  695. return out, metadata, &smithy.SerializationError{Err: err}
  696. }
  697. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  698. return out, metadata, &smithy.SerializationError{Err: err}
  699. }
  700. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  701. return out, metadata, &smithy.SerializationError{Err: err}
  702. }
  703. in.Request = request
  704. return next.HandleSerialize(ctx, in)
  705. }
  706. type awsAwsjson11_serializeOpDescribeLogGroups struct {
  707. }
  708. func (*awsAwsjson11_serializeOpDescribeLogGroups) ID() string {
  709. return "OperationSerializer"
  710. }
  711. func (m *awsAwsjson11_serializeOpDescribeLogGroups) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  712. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  713. ) {
  714. request, ok := in.Request.(*smithyhttp.Request)
  715. if !ok {
  716. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  717. }
  718. input, ok := in.Parameters.(*DescribeLogGroupsInput)
  719. _ = input
  720. if !ok {
  721. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  722. }
  723. operationPath := "/"
  724. if len(request.Request.URL.Path) == 0 {
  725. request.Request.URL.Path = operationPath
  726. } else {
  727. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  728. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  729. request.Request.URL.Path += "/"
  730. }
  731. }
  732. request.Request.Method = "POST"
  733. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  734. if err != nil {
  735. return out, metadata, &smithy.SerializationError{Err: err}
  736. }
  737. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  738. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.DescribeLogGroups")
  739. jsonEncoder := smithyjson.NewEncoder()
  740. if err := awsAwsjson11_serializeOpDocumentDescribeLogGroupsInput(input, jsonEncoder.Value); err != nil {
  741. return out, metadata, &smithy.SerializationError{Err: err}
  742. }
  743. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  744. return out, metadata, &smithy.SerializationError{Err: err}
  745. }
  746. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  747. return out, metadata, &smithy.SerializationError{Err: err}
  748. }
  749. in.Request = request
  750. return next.HandleSerialize(ctx, in)
  751. }
  752. type awsAwsjson11_serializeOpDescribeLogStreams struct {
  753. }
  754. func (*awsAwsjson11_serializeOpDescribeLogStreams) ID() string {
  755. return "OperationSerializer"
  756. }
  757. func (m *awsAwsjson11_serializeOpDescribeLogStreams) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  758. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  759. ) {
  760. request, ok := in.Request.(*smithyhttp.Request)
  761. if !ok {
  762. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  763. }
  764. input, ok := in.Parameters.(*DescribeLogStreamsInput)
  765. _ = input
  766. if !ok {
  767. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  768. }
  769. operationPath := "/"
  770. if len(request.Request.URL.Path) == 0 {
  771. request.Request.URL.Path = operationPath
  772. } else {
  773. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  774. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  775. request.Request.URL.Path += "/"
  776. }
  777. }
  778. request.Request.Method = "POST"
  779. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  780. if err != nil {
  781. return out, metadata, &smithy.SerializationError{Err: err}
  782. }
  783. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  784. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.DescribeLogStreams")
  785. jsonEncoder := smithyjson.NewEncoder()
  786. if err := awsAwsjson11_serializeOpDocumentDescribeLogStreamsInput(input, jsonEncoder.Value); err != nil {
  787. return out, metadata, &smithy.SerializationError{Err: err}
  788. }
  789. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  790. return out, metadata, &smithy.SerializationError{Err: err}
  791. }
  792. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  793. return out, metadata, &smithy.SerializationError{Err: err}
  794. }
  795. in.Request = request
  796. return next.HandleSerialize(ctx, in)
  797. }
  798. type awsAwsjson11_serializeOpDescribeMetricFilters struct {
  799. }
  800. func (*awsAwsjson11_serializeOpDescribeMetricFilters) ID() string {
  801. return "OperationSerializer"
  802. }
  803. func (m *awsAwsjson11_serializeOpDescribeMetricFilters) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  804. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  805. ) {
  806. request, ok := in.Request.(*smithyhttp.Request)
  807. if !ok {
  808. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  809. }
  810. input, ok := in.Parameters.(*DescribeMetricFiltersInput)
  811. _ = input
  812. if !ok {
  813. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  814. }
  815. operationPath := "/"
  816. if len(request.Request.URL.Path) == 0 {
  817. request.Request.URL.Path = operationPath
  818. } else {
  819. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  820. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  821. request.Request.URL.Path += "/"
  822. }
  823. }
  824. request.Request.Method = "POST"
  825. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  826. if err != nil {
  827. return out, metadata, &smithy.SerializationError{Err: err}
  828. }
  829. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  830. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.DescribeMetricFilters")
  831. jsonEncoder := smithyjson.NewEncoder()
  832. if err := awsAwsjson11_serializeOpDocumentDescribeMetricFiltersInput(input, jsonEncoder.Value); err != nil {
  833. return out, metadata, &smithy.SerializationError{Err: err}
  834. }
  835. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  836. return out, metadata, &smithy.SerializationError{Err: err}
  837. }
  838. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  839. return out, metadata, &smithy.SerializationError{Err: err}
  840. }
  841. in.Request = request
  842. return next.HandleSerialize(ctx, in)
  843. }
  844. type awsAwsjson11_serializeOpDescribeQueries struct {
  845. }
  846. func (*awsAwsjson11_serializeOpDescribeQueries) ID() string {
  847. return "OperationSerializer"
  848. }
  849. func (m *awsAwsjson11_serializeOpDescribeQueries) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  850. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  851. ) {
  852. request, ok := in.Request.(*smithyhttp.Request)
  853. if !ok {
  854. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  855. }
  856. input, ok := in.Parameters.(*DescribeQueriesInput)
  857. _ = input
  858. if !ok {
  859. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  860. }
  861. operationPath := "/"
  862. if len(request.Request.URL.Path) == 0 {
  863. request.Request.URL.Path = operationPath
  864. } else {
  865. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  866. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  867. request.Request.URL.Path += "/"
  868. }
  869. }
  870. request.Request.Method = "POST"
  871. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  872. if err != nil {
  873. return out, metadata, &smithy.SerializationError{Err: err}
  874. }
  875. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  876. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.DescribeQueries")
  877. jsonEncoder := smithyjson.NewEncoder()
  878. if err := awsAwsjson11_serializeOpDocumentDescribeQueriesInput(input, jsonEncoder.Value); err != nil {
  879. return out, metadata, &smithy.SerializationError{Err: err}
  880. }
  881. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  882. return out, metadata, &smithy.SerializationError{Err: err}
  883. }
  884. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  885. return out, metadata, &smithy.SerializationError{Err: err}
  886. }
  887. in.Request = request
  888. return next.HandleSerialize(ctx, in)
  889. }
  890. type awsAwsjson11_serializeOpDescribeQueryDefinitions struct {
  891. }
  892. func (*awsAwsjson11_serializeOpDescribeQueryDefinitions) ID() string {
  893. return "OperationSerializer"
  894. }
  895. func (m *awsAwsjson11_serializeOpDescribeQueryDefinitions) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  896. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  897. ) {
  898. request, ok := in.Request.(*smithyhttp.Request)
  899. if !ok {
  900. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  901. }
  902. input, ok := in.Parameters.(*DescribeQueryDefinitionsInput)
  903. _ = input
  904. if !ok {
  905. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  906. }
  907. operationPath := "/"
  908. if len(request.Request.URL.Path) == 0 {
  909. request.Request.URL.Path = operationPath
  910. } else {
  911. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  912. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  913. request.Request.URL.Path += "/"
  914. }
  915. }
  916. request.Request.Method = "POST"
  917. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  918. if err != nil {
  919. return out, metadata, &smithy.SerializationError{Err: err}
  920. }
  921. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  922. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.DescribeQueryDefinitions")
  923. jsonEncoder := smithyjson.NewEncoder()
  924. if err := awsAwsjson11_serializeOpDocumentDescribeQueryDefinitionsInput(input, jsonEncoder.Value); err != nil {
  925. return out, metadata, &smithy.SerializationError{Err: err}
  926. }
  927. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  928. return out, metadata, &smithy.SerializationError{Err: err}
  929. }
  930. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  931. return out, metadata, &smithy.SerializationError{Err: err}
  932. }
  933. in.Request = request
  934. return next.HandleSerialize(ctx, in)
  935. }
  936. type awsAwsjson11_serializeOpDescribeResourcePolicies struct {
  937. }
  938. func (*awsAwsjson11_serializeOpDescribeResourcePolicies) ID() string {
  939. return "OperationSerializer"
  940. }
  941. func (m *awsAwsjson11_serializeOpDescribeResourcePolicies) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  942. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  943. ) {
  944. request, ok := in.Request.(*smithyhttp.Request)
  945. if !ok {
  946. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  947. }
  948. input, ok := in.Parameters.(*DescribeResourcePoliciesInput)
  949. _ = input
  950. if !ok {
  951. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  952. }
  953. operationPath := "/"
  954. if len(request.Request.URL.Path) == 0 {
  955. request.Request.URL.Path = operationPath
  956. } else {
  957. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  958. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  959. request.Request.URL.Path += "/"
  960. }
  961. }
  962. request.Request.Method = "POST"
  963. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  964. if err != nil {
  965. return out, metadata, &smithy.SerializationError{Err: err}
  966. }
  967. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  968. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.DescribeResourcePolicies")
  969. jsonEncoder := smithyjson.NewEncoder()
  970. if err := awsAwsjson11_serializeOpDocumentDescribeResourcePoliciesInput(input, jsonEncoder.Value); err != nil {
  971. return out, metadata, &smithy.SerializationError{Err: err}
  972. }
  973. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  974. return out, metadata, &smithy.SerializationError{Err: err}
  975. }
  976. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  977. return out, metadata, &smithy.SerializationError{Err: err}
  978. }
  979. in.Request = request
  980. return next.HandleSerialize(ctx, in)
  981. }
  982. type awsAwsjson11_serializeOpDescribeSubscriptionFilters struct {
  983. }
  984. func (*awsAwsjson11_serializeOpDescribeSubscriptionFilters) ID() string {
  985. return "OperationSerializer"
  986. }
  987. func (m *awsAwsjson11_serializeOpDescribeSubscriptionFilters) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  988. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  989. ) {
  990. request, ok := in.Request.(*smithyhttp.Request)
  991. if !ok {
  992. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  993. }
  994. input, ok := in.Parameters.(*DescribeSubscriptionFiltersInput)
  995. _ = input
  996. if !ok {
  997. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  998. }
  999. operationPath := "/"
  1000. if len(request.Request.URL.Path) == 0 {
  1001. request.Request.URL.Path = operationPath
  1002. } else {
  1003. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  1004. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  1005. request.Request.URL.Path += "/"
  1006. }
  1007. }
  1008. request.Request.Method = "POST"
  1009. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  1010. if err != nil {
  1011. return out, metadata, &smithy.SerializationError{Err: err}
  1012. }
  1013. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  1014. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.DescribeSubscriptionFilters")
  1015. jsonEncoder := smithyjson.NewEncoder()
  1016. if err := awsAwsjson11_serializeOpDocumentDescribeSubscriptionFiltersInput(input, jsonEncoder.Value); err != nil {
  1017. return out, metadata, &smithy.SerializationError{Err: err}
  1018. }
  1019. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  1020. return out, metadata, &smithy.SerializationError{Err: err}
  1021. }
  1022. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  1023. return out, metadata, &smithy.SerializationError{Err: err}
  1024. }
  1025. in.Request = request
  1026. return next.HandleSerialize(ctx, in)
  1027. }
  1028. type awsAwsjson11_serializeOpDisassociateKmsKey struct {
  1029. }
  1030. func (*awsAwsjson11_serializeOpDisassociateKmsKey) ID() string {
  1031. return "OperationSerializer"
  1032. }
  1033. func (m *awsAwsjson11_serializeOpDisassociateKmsKey) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  1034. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  1035. ) {
  1036. request, ok := in.Request.(*smithyhttp.Request)
  1037. if !ok {
  1038. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  1039. }
  1040. input, ok := in.Parameters.(*DisassociateKmsKeyInput)
  1041. _ = input
  1042. if !ok {
  1043. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  1044. }
  1045. operationPath := "/"
  1046. if len(request.Request.URL.Path) == 0 {
  1047. request.Request.URL.Path = operationPath
  1048. } else {
  1049. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  1050. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  1051. request.Request.URL.Path += "/"
  1052. }
  1053. }
  1054. request.Request.Method = "POST"
  1055. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  1056. if err != nil {
  1057. return out, metadata, &smithy.SerializationError{Err: err}
  1058. }
  1059. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  1060. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.DisassociateKmsKey")
  1061. jsonEncoder := smithyjson.NewEncoder()
  1062. if err := awsAwsjson11_serializeOpDocumentDisassociateKmsKeyInput(input, jsonEncoder.Value); err != nil {
  1063. return out, metadata, &smithy.SerializationError{Err: err}
  1064. }
  1065. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  1066. return out, metadata, &smithy.SerializationError{Err: err}
  1067. }
  1068. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  1069. return out, metadata, &smithy.SerializationError{Err: err}
  1070. }
  1071. in.Request = request
  1072. return next.HandleSerialize(ctx, in)
  1073. }
  1074. type awsAwsjson11_serializeOpFilterLogEvents struct {
  1075. }
  1076. func (*awsAwsjson11_serializeOpFilterLogEvents) ID() string {
  1077. return "OperationSerializer"
  1078. }
  1079. func (m *awsAwsjson11_serializeOpFilterLogEvents) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  1080. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  1081. ) {
  1082. request, ok := in.Request.(*smithyhttp.Request)
  1083. if !ok {
  1084. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  1085. }
  1086. input, ok := in.Parameters.(*FilterLogEventsInput)
  1087. _ = input
  1088. if !ok {
  1089. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  1090. }
  1091. operationPath := "/"
  1092. if len(request.Request.URL.Path) == 0 {
  1093. request.Request.URL.Path = operationPath
  1094. } else {
  1095. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  1096. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  1097. request.Request.URL.Path += "/"
  1098. }
  1099. }
  1100. request.Request.Method = "POST"
  1101. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  1102. if err != nil {
  1103. return out, metadata, &smithy.SerializationError{Err: err}
  1104. }
  1105. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  1106. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.FilterLogEvents")
  1107. jsonEncoder := smithyjson.NewEncoder()
  1108. if err := awsAwsjson11_serializeOpDocumentFilterLogEventsInput(input, jsonEncoder.Value); err != nil {
  1109. return out, metadata, &smithy.SerializationError{Err: err}
  1110. }
  1111. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  1112. return out, metadata, &smithy.SerializationError{Err: err}
  1113. }
  1114. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  1115. return out, metadata, &smithy.SerializationError{Err: err}
  1116. }
  1117. in.Request = request
  1118. return next.HandleSerialize(ctx, in)
  1119. }
  1120. type awsAwsjson11_serializeOpGetLogEvents struct {
  1121. }
  1122. func (*awsAwsjson11_serializeOpGetLogEvents) ID() string {
  1123. return "OperationSerializer"
  1124. }
  1125. func (m *awsAwsjson11_serializeOpGetLogEvents) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  1126. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  1127. ) {
  1128. request, ok := in.Request.(*smithyhttp.Request)
  1129. if !ok {
  1130. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  1131. }
  1132. input, ok := in.Parameters.(*GetLogEventsInput)
  1133. _ = input
  1134. if !ok {
  1135. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  1136. }
  1137. operationPath := "/"
  1138. if len(request.Request.URL.Path) == 0 {
  1139. request.Request.URL.Path = operationPath
  1140. } else {
  1141. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  1142. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  1143. request.Request.URL.Path += "/"
  1144. }
  1145. }
  1146. request.Request.Method = "POST"
  1147. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  1148. if err != nil {
  1149. return out, metadata, &smithy.SerializationError{Err: err}
  1150. }
  1151. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  1152. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.GetLogEvents")
  1153. jsonEncoder := smithyjson.NewEncoder()
  1154. if err := awsAwsjson11_serializeOpDocumentGetLogEventsInput(input, jsonEncoder.Value); err != nil {
  1155. return out, metadata, &smithy.SerializationError{Err: err}
  1156. }
  1157. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  1158. return out, metadata, &smithy.SerializationError{Err: err}
  1159. }
  1160. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  1161. return out, metadata, &smithy.SerializationError{Err: err}
  1162. }
  1163. in.Request = request
  1164. return next.HandleSerialize(ctx, in)
  1165. }
  1166. type awsAwsjson11_serializeOpGetLogGroupFields struct {
  1167. }
  1168. func (*awsAwsjson11_serializeOpGetLogGroupFields) ID() string {
  1169. return "OperationSerializer"
  1170. }
  1171. func (m *awsAwsjson11_serializeOpGetLogGroupFields) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  1172. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  1173. ) {
  1174. request, ok := in.Request.(*smithyhttp.Request)
  1175. if !ok {
  1176. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  1177. }
  1178. input, ok := in.Parameters.(*GetLogGroupFieldsInput)
  1179. _ = input
  1180. if !ok {
  1181. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  1182. }
  1183. operationPath := "/"
  1184. if len(request.Request.URL.Path) == 0 {
  1185. request.Request.URL.Path = operationPath
  1186. } else {
  1187. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  1188. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  1189. request.Request.URL.Path += "/"
  1190. }
  1191. }
  1192. request.Request.Method = "POST"
  1193. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  1194. if err != nil {
  1195. return out, metadata, &smithy.SerializationError{Err: err}
  1196. }
  1197. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  1198. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.GetLogGroupFields")
  1199. jsonEncoder := smithyjson.NewEncoder()
  1200. if err := awsAwsjson11_serializeOpDocumentGetLogGroupFieldsInput(input, jsonEncoder.Value); err != nil {
  1201. return out, metadata, &smithy.SerializationError{Err: err}
  1202. }
  1203. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  1204. return out, metadata, &smithy.SerializationError{Err: err}
  1205. }
  1206. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  1207. return out, metadata, &smithy.SerializationError{Err: err}
  1208. }
  1209. in.Request = request
  1210. return next.HandleSerialize(ctx, in)
  1211. }
  1212. type awsAwsjson11_serializeOpGetLogRecord struct {
  1213. }
  1214. func (*awsAwsjson11_serializeOpGetLogRecord) ID() string {
  1215. return "OperationSerializer"
  1216. }
  1217. func (m *awsAwsjson11_serializeOpGetLogRecord) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  1218. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  1219. ) {
  1220. request, ok := in.Request.(*smithyhttp.Request)
  1221. if !ok {
  1222. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  1223. }
  1224. input, ok := in.Parameters.(*GetLogRecordInput)
  1225. _ = input
  1226. if !ok {
  1227. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  1228. }
  1229. operationPath := "/"
  1230. if len(request.Request.URL.Path) == 0 {
  1231. request.Request.URL.Path = operationPath
  1232. } else {
  1233. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  1234. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  1235. request.Request.URL.Path += "/"
  1236. }
  1237. }
  1238. request.Request.Method = "POST"
  1239. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  1240. if err != nil {
  1241. return out, metadata, &smithy.SerializationError{Err: err}
  1242. }
  1243. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  1244. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.GetLogRecord")
  1245. jsonEncoder := smithyjson.NewEncoder()
  1246. if err := awsAwsjson11_serializeOpDocumentGetLogRecordInput(input, jsonEncoder.Value); err != nil {
  1247. return out, metadata, &smithy.SerializationError{Err: err}
  1248. }
  1249. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  1250. return out, metadata, &smithy.SerializationError{Err: err}
  1251. }
  1252. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  1253. return out, metadata, &smithy.SerializationError{Err: err}
  1254. }
  1255. in.Request = request
  1256. return next.HandleSerialize(ctx, in)
  1257. }
  1258. type awsAwsjson11_serializeOpGetQueryResults struct {
  1259. }
  1260. func (*awsAwsjson11_serializeOpGetQueryResults) ID() string {
  1261. return "OperationSerializer"
  1262. }
  1263. func (m *awsAwsjson11_serializeOpGetQueryResults) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  1264. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  1265. ) {
  1266. request, ok := in.Request.(*smithyhttp.Request)
  1267. if !ok {
  1268. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  1269. }
  1270. input, ok := in.Parameters.(*GetQueryResultsInput)
  1271. _ = input
  1272. if !ok {
  1273. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  1274. }
  1275. operationPath := "/"
  1276. if len(request.Request.URL.Path) == 0 {
  1277. request.Request.URL.Path = operationPath
  1278. } else {
  1279. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  1280. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  1281. request.Request.URL.Path += "/"
  1282. }
  1283. }
  1284. request.Request.Method = "POST"
  1285. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  1286. if err != nil {
  1287. return out, metadata, &smithy.SerializationError{Err: err}
  1288. }
  1289. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  1290. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.GetQueryResults")
  1291. jsonEncoder := smithyjson.NewEncoder()
  1292. if err := awsAwsjson11_serializeOpDocumentGetQueryResultsInput(input, jsonEncoder.Value); err != nil {
  1293. return out, metadata, &smithy.SerializationError{Err: err}
  1294. }
  1295. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  1296. return out, metadata, &smithy.SerializationError{Err: err}
  1297. }
  1298. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  1299. return out, metadata, &smithy.SerializationError{Err: err}
  1300. }
  1301. in.Request = request
  1302. return next.HandleSerialize(ctx, in)
  1303. }
  1304. type awsAwsjson11_serializeOpListTagsLogGroup struct {
  1305. }
  1306. func (*awsAwsjson11_serializeOpListTagsLogGroup) ID() string {
  1307. return "OperationSerializer"
  1308. }
  1309. func (m *awsAwsjson11_serializeOpListTagsLogGroup) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  1310. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  1311. ) {
  1312. request, ok := in.Request.(*smithyhttp.Request)
  1313. if !ok {
  1314. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  1315. }
  1316. input, ok := in.Parameters.(*ListTagsLogGroupInput)
  1317. _ = input
  1318. if !ok {
  1319. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  1320. }
  1321. operationPath := "/"
  1322. if len(request.Request.URL.Path) == 0 {
  1323. request.Request.URL.Path = operationPath
  1324. } else {
  1325. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  1326. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  1327. request.Request.URL.Path += "/"
  1328. }
  1329. }
  1330. request.Request.Method = "POST"
  1331. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  1332. if err != nil {
  1333. return out, metadata, &smithy.SerializationError{Err: err}
  1334. }
  1335. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  1336. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.ListTagsLogGroup")
  1337. jsonEncoder := smithyjson.NewEncoder()
  1338. if err := awsAwsjson11_serializeOpDocumentListTagsLogGroupInput(input, jsonEncoder.Value); err != nil {
  1339. return out, metadata, &smithy.SerializationError{Err: err}
  1340. }
  1341. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  1342. return out, metadata, &smithy.SerializationError{Err: err}
  1343. }
  1344. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  1345. return out, metadata, &smithy.SerializationError{Err: err}
  1346. }
  1347. in.Request = request
  1348. return next.HandleSerialize(ctx, in)
  1349. }
  1350. type awsAwsjson11_serializeOpPutDestination struct {
  1351. }
  1352. func (*awsAwsjson11_serializeOpPutDestination) ID() string {
  1353. return "OperationSerializer"
  1354. }
  1355. func (m *awsAwsjson11_serializeOpPutDestination) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  1356. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  1357. ) {
  1358. request, ok := in.Request.(*smithyhttp.Request)
  1359. if !ok {
  1360. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  1361. }
  1362. input, ok := in.Parameters.(*PutDestinationInput)
  1363. _ = input
  1364. if !ok {
  1365. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  1366. }
  1367. operationPath := "/"
  1368. if len(request.Request.URL.Path) == 0 {
  1369. request.Request.URL.Path = operationPath
  1370. } else {
  1371. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  1372. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  1373. request.Request.URL.Path += "/"
  1374. }
  1375. }
  1376. request.Request.Method = "POST"
  1377. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  1378. if err != nil {
  1379. return out, metadata, &smithy.SerializationError{Err: err}
  1380. }
  1381. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  1382. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.PutDestination")
  1383. jsonEncoder := smithyjson.NewEncoder()
  1384. if err := awsAwsjson11_serializeOpDocumentPutDestinationInput(input, jsonEncoder.Value); err != nil {
  1385. return out, metadata, &smithy.SerializationError{Err: err}
  1386. }
  1387. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  1388. return out, metadata, &smithy.SerializationError{Err: err}
  1389. }
  1390. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  1391. return out, metadata, &smithy.SerializationError{Err: err}
  1392. }
  1393. in.Request = request
  1394. return next.HandleSerialize(ctx, in)
  1395. }
  1396. type awsAwsjson11_serializeOpPutDestinationPolicy struct {
  1397. }
  1398. func (*awsAwsjson11_serializeOpPutDestinationPolicy) ID() string {
  1399. return "OperationSerializer"
  1400. }
  1401. func (m *awsAwsjson11_serializeOpPutDestinationPolicy) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  1402. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  1403. ) {
  1404. request, ok := in.Request.(*smithyhttp.Request)
  1405. if !ok {
  1406. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  1407. }
  1408. input, ok := in.Parameters.(*PutDestinationPolicyInput)
  1409. _ = input
  1410. if !ok {
  1411. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  1412. }
  1413. operationPath := "/"
  1414. if len(request.Request.URL.Path) == 0 {
  1415. request.Request.URL.Path = operationPath
  1416. } else {
  1417. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  1418. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  1419. request.Request.URL.Path += "/"
  1420. }
  1421. }
  1422. request.Request.Method = "POST"
  1423. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  1424. if err != nil {
  1425. return out, metadata, &smithy.SerializationError{Err: err}
  1426. }
  1427. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  1428. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.PutDestinationPolicy")
  1429. jsonEncoder := smithyjson.NewEncoder()
  1430. if err := awsAwsjson11_serializeOpDocumentPutDestinationPolicyInput(input, jsonEncoder.Value); err != nil {
  1431. return out, metadata, &smithy.SerializationError{Err: err}
  1432. }
  1433. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  1434. return out, metadata, &smithy.SerializationError{Err: err}
  1435. }
  1436. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  1437. return out, metadata, &smithy.SerializationError{Err: err}
  1438. }
  1439. in.Request = request
  1440. return next.HandleSerialize(ctx, in)
  1441. }
  1442. type awsAwsjson11_serializeOpPutLogEvents struct {
  1443. }
  1444. func (*awsAwsjson11_serializeOpPutLogEvents) ID() string {
  1445. return "OperationSerializer"
  1446. }
  1447. func (m *awsAwsjson11_serializeOpPutLogEvents) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  1448. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  1449. ) {
  1450. request, ok := in.Request.(*smithyhttp.Request)
  1451. if !ok {
  1452. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  1453. }
  1454. input, ok := in.Parameters.(*PutLogEventsInput)
  1455. _ = input
  1456. if !ok {
  1457. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  1458. }
  1459. operationPath := "/"
  1460. if len(request.Request.URL.Path) == 0 {
  1461. request.Request.URL.Path = operationPath
  1462. } else {
  1463. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  1464. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  1465. request.Request.URL.Path += "/"
  1466. }
  1467. }
  1468. request.Request.Method = "POST"
  1469. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  1470. if err != nil {
  1471. return out, metadata, &smithy.SerializationError{Err: err}
  1472. }
  1473. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  1474. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.PutLogEvents")
  1475. jsonEncoder := smithyjson.NewEncoder()
  1476. if err := awsAwsjson11_serializeOpDocumentPutLogEventsInput(input, jsonEncoder.Value); err != nil {
  1477. return out, metadata, &smithy.SerializationError{Err: err}
  1478. }
  1479. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  1480. return out, metadata, &smithy.SerializationError{Err: err}
  1481. }
  1482. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  1483. return out, metadata, &smithy.SerializationError{Err: err}
  1484. }
  1485. in.Request = request
  1486. return next.HandleSerialize(ctx, in)
  1487. }
  1488. type awsAwsjson11_serializeOpPutMetricFilter struct {
  1489. }
  1490. func (*awsAwsjson11_serializeOpPutMetricFilter) ID() string {
  1491. return "OperationSerializer"
  1492. }
  1493. func (m *awsAwsjson11_serializeOpPutMetricFilter) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  1494. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  1495. ) {
  1496. request, ok := in.Request.(*smithyhttp.Request)
  1497. if !ok {
  1498. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  1499. }
  1500. input, ok := in.Parameters.(*PutMetricFilterInput)
  1501. _ = input
  1502. if !ok {
  1503. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  1504. }
  1505. operationPath := "/"
  1506. if len(request.Request.URL.Path) == 0 {
  1507. request.Request.URL.Path = operationPath
  1508. } else {
  1509. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  1510. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  1511. request.Request.URL.Path += "/"
  1512. }
  1513. }
  1514. request.Request.Method = "POST"
  1515. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  1516. if err != nil {
  1517. return out, metadata, &smithy.SerializationError{Err: err}
  1518. }
  1519. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  1520. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.PutMetricFilter")
  1521. jsonEncoder := smithyjson.NewEncoder()
  1522. if err := awsAwsjson11_serializeOpDocumentPutMetricFilterInput(input, jsonEncoder.Value); err != nil {
  1523. return out, metadata, &smithy.SerializationError{Err: err}
  1524. }
  1525. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  1526. return out, metadata, &smithy.SerializationError{Err: err}
  1527. }
  1528. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  1529. return out, metadata, &smithy.SerializationError{Err: err}
  1530. }
  1531. in.Request = request
  1532. return next.HandleSerialize(ctx, in)
  1533. }
  1534. type awsAwsjson11_serializeOpPutQueryDefinition struct {
  1535. }
  1536. func (*awsAwsjson11_serializeOpPutQueryDefinition) ID() string {
  1537. return "OperationSerializer"
  1538. }
  1539. func (m *awsAwsjson11_serializeOpPutQueryDefinition) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  1540. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  1541. ) {
  1542. request, ok := in.Request.(*smithyhttp.Request)
  1543. if !ok {
  1544. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  1545. }
  1546. input, ok := in.Parameters.(*PutQueryDefinitionInput)
  1547. _ = input
  1548. if !ok {
  1549. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  1550. }
  1551. operationPath := "/"
  1552. if len(request.Request.URL.Path) == 0 {
  1553. request.Request.URL.Path = operationPath
  1554. } else {
  1555. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  1556. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  1557. request.Request.URL.Path += "/"
  1558. }
  1559. }
  1560. request.Request.Method = "POST"
  1561. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  1562. if err != nil {
  1563. return out, metadata, &smithy.SerializationError{Err: err}
  1564. }
  1565. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  1566. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.PutQueryDefinition")
  1567. jsonEncoder := smithyjson.NewEncoder()
  1568. if err := awsAwsjson11_serializeOpDocumentPutQueryDefinitionInput(input, jsonEncoder.Value); err != nil {
  1569. return out, metadata, &smithy.SerializationError{Err: err}
  1570. }
  1571. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  1572. return out, metadata, &smithy.SerializationError{Err: err}
  1573. }
  1574. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  1575. return out, metadata, &smithy.SerializationError{Err: err}
  1576. }
  1577. in.Request = request
  1578. return next.HandleSerialize(ctx, in)
  1579. }
  1580. type awsAwsjson11_serializeOpPutResourcePolicy struct {
  1581. }
  1582. func (*awsAwsjson11_serializeOpPutResourcePolicy) ID() string {
  1583. return "OperationSerializer"
  1584. }
  1585. func (m *awsAwsjson11_serializeOpPutResourcePolicy) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  1586. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  1587. ) {
  1588. request, ok := in.Request.(*smithyhttp.Request)
  1589. if !ok {
  1590. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  1591. }
  1592. input, ok := in.Parameters.(*PutResourcePolicyInput)
  1593. _ = input
  1594. if !ok {
  1595. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  1596. }
  1597. operationPath := "/"
  1598. if len(request.Request.URL.Path) == 0 {
  1599. request.Request.URL.Path = operationPath
  1600. } else {
  1601. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  1602. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  1603. request.Request.URL.Path += "/"
  1604. }
  1605. }
  1606. request.Request.Method = "POST"
  1607. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  1608. if err != nil {
  1609. return out, metadata, &smithy.SerializationError{Err: err}
  1610. }
  1611. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  1612. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.PutResourcePolicy")
  1613. jsonEncoder := smithyjson.NewEncoder()
  1614. if err := awsAwsjson11_serializeOpDocumentPutResourcePolicyInput(input, jsonEncoder.Value); err != nil {
  1615. return out, metadata, &smithy.SerializationError{Err: err}
  1616. }
  1617. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  1618. return out, metadata, &smithy.SerializationError{Err: err}
  1619. }
  1620. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  1621. return out, metadata, &smithy.SerializationError{Err: err}
  1622. }
  1623. in.Request = request
  1624. return next.HandleSerialize(ctx, in)
  1625. }
  1626. type awsAwsjson11_serializeOpPutRetentionPolicy struct {
  1627. }
  1628. func (*awsAwsjson11_serializeOpPutRetentionPolicy) ID() string {
  1629. return "OperationSerializer"
  1630. }
  1631. func (m *awsAwsjson11_serializeOpPutRetentionPolicy) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  1632. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  1633. ) {
  1634. request, ok := in.Request.(*smithyhttp.Request)
  1635. if !ok {
  1636. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  1637. }
  1638. input, ok := in.Parameters.(*PutRetentionPolicyInput)
  1639. _ = input
  1640. if !ok {
  1641. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  1642. }
  1643. operationPath := "/"
  1644. if len(request.Request.URL.Path) == 0 {
  1645. request.Request.URL.Path = operationPath
  1646. } else {
  1647. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  1648. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  1649. request.Request.URL.Path += "/"
  1650. }
  1651. }
  1652. request.Request.Method = "POST"
  1653. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  1654. if err != nil {
  1655. return out, metadata, &smithy.SerializationError{Err: err}
  1656. }
  1657. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  1658. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.PutRetentionPolicy")
  1659. jsonEncoder := smithyjson.NewEncoder()
  1660. if err := awsAwsjson11_serializeOpDocumentPutRetentionPolicyInput(input, jsonEncoder.Value); err != nil {
  1661. return out, metadata, &smithy.SerializationError{Err: err}
  1662. }
  1663. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  1664. return out, metadata, &smithy.SerializationError{Err: err}
  1665. }
  1666. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  1667. return out, metadata, &smithy.SerializationError{Err: err}
  1668. }
  1669. in.Request = request
  1670. return next.HandleSerialize(ctx, in)
  1671. }
  1672. type awsAwsjson11_serializeOpPutSubscriptionFilter struct {
  1673. }
  1674. func (*awsAwsjson11_serializeOpPutSubscriptionFilter) ID() string {
  1675. return "OperationSerializer"
  1676. }
  1677. func (m *awsAwsjson11_serializeOpPutSubscriptionFilter) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  1678. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  1679. ) {
  1680. request, ok := in.Request.(*smithyhttp.Request)
  1681. if !ok {
  1682. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  1683. }
  1684. input, ok := in.Parameters.(*PutSubscriptionFilterInput)
  1685. _ = input
  1686. if !ok {
  1687. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  1688. }
  1689. operationPath := "/"
  1690. if len(request.Request.URL.Path) == 0 {
  1691. request.Request.URL.Path = operationPath
  1692. } else {
  1693. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  1694. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  1695. request.Request.URL.Path += "/"
  1696. }
  1697. }
  1698. request.Request.Method = "POST"
  1699. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  1700. if err != nil {
  1701. return out, metadata, &smithy.SerializationError{Err: err}
  1702. }
  1703. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  1704. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.PutSubscriptionFilter")
  1705. jsonEncoder := smithyjson.NewEncoder()
  1706. if err := awsAwsjson11_serializeOpDocumentPutSubscriptionFilterInput(input, jsonEncoder.Value); err != nil {
  1707. return out, metadata, &smithy.SerializationError{Err: err}
  1708. }
  1709. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  1710. return out, metadata, &smithy.SerializationError{Err: err}
  1711. }
  1712. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  1713. return out, metadata, &smithy.SerializationError{Err: err}
  1714. }
  1715. in.Request = request
  1716. return next.HandleSerialize(ctx, in)
  1717. }
  1718. type awsAwsjson11_serializeOpStartQuery struct {
  1719. }
  1720. func (*awsAwsjson11_serializeOpStartQuery) ID() string {
  1721. return "OperationSerializer"
  1722. }
  1723. func (m *awsAwsjson11_serializeOpStartQuery) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  1724. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  1725. ) {
  1726. request, ok := in.Request.(*smithyhttp.Request)
  1727. if !ok {
  1728. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  1729. }
  1730. input, ok := in.Parameters.(*StartQueryInput)
  1731. _ = input
  1732. if !ok {
  1733. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  1734. }
  1735. operationPath := "/"
  1736. if len(request.Request.URL.Path) == 0 {
  1737. request.Request.URL.Path = operationPath
  1738. } else {
  1739. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  1740. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  1741. request.Request.URL.Path += "/"
  1742. }
  1743. }
  1744. request.Request.Method = "POST"
  1745. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  1746. if err != nil {
  1747. return out, metadata, &smithy.SerializationError{Err: err}
  1748. }
  1749. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  1750. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.StartQuery")
  1751. jsonEncoder := smithyjson.NewEncoder()
  1752. if err := awsAwsjson11_serializeOpDocumentStartQueryInput(input, jsonEncoder.Value); err != nil {
  1753. return out, metadata, &smithy.SerializationError{Err: err}
  1754. }
  1755. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  1756. return out, metadata, &smithy.SerializationError{Err: err}
  1757. }
  1758. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  1759. return out, metadata, &smithy.SerializationError{Err: err}
  1760. }
  1761. in.Request = request
  1762. return next.HandleSerialize(ctx, in)
  1763. }
  1764. type awsAwsjson11_serializeOpStopQuery struct {
  1765. }
  1766. func (*awsAwsjson11_serializeOpStopQuery) ID() string {
  1767. return "OperationSerializer"
  1768. }
  1769. func (m *awsAwsjson11_serializeOpStopQuery) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  1770. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  1771. ) {
  1772. request, ok := in.Request.(*smithyhttp.Request)
  1773. if !ok {
  1774. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  1775. }
  1776. input, ok := in.Parameters.(*StopQueryInput)
  1777. _ = input
  1778. if !ok {
  1779. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  1780. }
  1781. operationPath := "/"
  1782. if len(request.Request.URL.Path) == 0 {
  1783. request.Request.URL.Path = operationPath
  1784. } else {
  1785. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  1786. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  1787. request.Request.URL.Path += "/"
  1788. }
  1789. }
  1790. request.Request.Method = "POST"
  1791. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  1792. if err != nil {
  1793. return out, metadata, &smithy.SerializationError{Err: err}
  1794. }
  1795. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  1796. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.StopQuery")
  1797. jsonEncoder := smithyjson.NewEncoder()
  1798. if err := awsAwsjson11_serializeOpDocumentStopQueryInput(input, jsonEncoder.Value); err != nil {
  1799. return out, metadata, &smithy.SerializationError{Err: err}
  1800. }
  1801. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  1802. return out, metadata, &smithy.SerializationError{Err: err}
  1803. }
  1804. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  1805. return out, metadata, &smithy.SerializationError{Err: err}
  1806. }
  1807. in.Request = request
  1808. return next.HandleSerialize(ctx, in)
  1809. }
  1810. type awsAwsjson11_serializeOpTagLogGroup struct {
  1811. }
  1812. func (*awsAwsjson11_serializeOpTagLogGroup) ID() string {
  1813. return "OperationSerializer"
  1814. }
  1815. func (m *awsAwsjson11_serializeOpTagLogGroup) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  1816. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  1817. ) {
  1818. request, ok := in.Request.(*smithyhttp.Request)
  1819. if !ok {
  1820. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  1821. }
  1822. input, ok := in.Parameters.(*TagLogGroupInput)
  1823. _ = input
  1824. if !ok {
  1825. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  1826. }
  1827. operationPath := "/"
  1828. if len(request.Request.URL.Path) == 0 {
  1829. request.Request.URL.Path = operationPath
  1830. } else {
  1831. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  1832. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  1833. request.Request.URL.Path += "/"
  1834. }
  1835. }
  1836. request.Request.Method = "POST"
  1837. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  1838. if err != nil {
  1839. return out, metadata, &smithy.SerializationError{Err: err}
  1840. }
  1841. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  1842. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.TagLogGroup")
  1843. jsonEncoder := smithyjson.NewEncoder()
  1844. if err := awsAwsjson11_serializeOpDocumentTagLogGroupInput(input, jsonEncoder.Value); err != nil {
  1845. return out, metadata, &smithy.SerializationError{Err: err}
  1846. }
  1847. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  1848. return out, metadata, &smithy.SerializationError{Err: err}
  1849. }
  1850. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  1851. return out, metadata, &smithy.SerializationError{Err: err}
  1852. }
  1853. in.Request = request
  1854. return next.HandleSerialize(ctx, in)
  1855. }
  1856. type awsAwsjson11_serializeOpTestMetricFilter struct {
  1857. }
  1858. func (*awsAwsjson11_serializeOpTestMetricFilter) ID() string {
  1859. return "OperationSerializer"
  1860. }
  1861. func (m *awsAwsjson11_serializeOpTestMetricFilter) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  1862. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  1863. ) {
  1864. request, ok := in.Request.(*smithyhttp.Request)
  1865. if !ok {
  1866. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  1867. }
  1868. input, ok := in.Parameters.(*TestMetricFilterInput)
  1869. _ = input
  1870. if !ok {
  1871. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  1872. }
  1873. operationPath := "/"
  1874. if len(request.Request.URL.Path) == 0 {
  1875. request.Request.URL.Path = operationPath
  1876. } else {
  1877. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  1878. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  1879. request.Request.URL.Path += "/"
  1880. }
  1881. }
  1882. request.Request.Method = "POST"
  1883. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  1884. if err != nil {
  1885. return out, metadata, &smithy.SerializationError{Err: err}
  1886. }
  1887. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  1888. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.TestMetricFilter")
  1889. jsonEncoder := smithyjson.NewEncoder()
  1890. if err := awsAwsjson11_serializeOpDocumentTestMetricFilterInput(input, jsonEncoder.Value); err != nil {
  1891. return out, metadata, &smithy.SerializationError{Err: err}
  1892. }
  1893. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  1894. return out, metadata, &smithy.SerializationError{Err: err}
  1895. }
  1896. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  1897. return out, metadata, &smithy.SerializationError{Err: err}
  1898. }
  1899. in.Request = request
  1900. return next.HandleSerialize(ctx, in)
  1901. }
  1902. type awsAwsjson11_serializeOpUntagLogGroup struct {
  1903. }
  1904. func (*awsAwsjson11_serializeOpUntagLogGroup) ID() string {
  1905. return "OperationSerializer"
  1906. }
  1907. func (m *awsAwsjson11_serializeOpUntagLogGroup) HandleSerialize(ctx context.Context, in middleware.SerializeInput, next middleware.SerializeHandler) (
  1908. out middleware.SerializeOutput, metadata middleware.Metadata, err error,
  1909. ) {
  1910. request, ok := in.Request.(*smithyhttp.Request)
  1911. if !ok {
  1912. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown transport type %T", in.Request)}
  1913. }
  1914. input, ok := in.Parameters.(*UntagLogGroupInput)
  1915. _ = input
  1916. if !ok {
  1917. return out, metadata, &smithy.SerializationError{Err: fmt.Errorf("unknown input parameters type %T", in.Parameters)}
  1918. }
  1919. operationPath := "/"
  1920. if len(request.Request.URL.Path) == 0 {
  1921. request.Request.URL.Path = operationPath
  1922. } else {
  1923. request.Request.URL.Path = path.Join(request.Request.URL.Path, operationPath)
  1924. if request.Request.URL.Path != "/" && operationPath[len(operationPath)-1] == '/' {
  1925. request.Request.URL.Path += "/"
  1926. }
  1927. }
  1928. request.Request.Method = "POST"
  1929. httpBindingEncoder, err := httpbinding.NewEncoder(request.URL.Path, request.URL.RawQuery, request.Header)
  1930. if err != nil {
  1931. return out, metadata, &smithy.SerializationError{Err: err}
  1932. }
  1933. httpBindingEncoder.SetHeader("Content-Type").String("application/x-amz-json-1.1")
  1934. httpBindingEncoder.SetHeader("X-Amz-Target").String("Logs_20140328.UntagLogGroup")
  1935. jsonEncoder := smithyjson.NewEncoder()
  1936. if err := awsAwsjson11_serializeOpDocumentUntagLogGroupInput(input, jsonEncoder.Value); err != nil {
  1937. return out, metadata, &smithy.SerializationError{Err: err}
  1938. }
  1939. if request, err = request.SetStream(bytes.NewReader(jsonEncoder.Bytes())); err != nil {
  1940. return out, metadata, &smithy.SerializationError{Err: err}
  1941. }
  1942. if request.Request, err = httpBindingEncoder.Encode(request.Request); err != nil {
  1943. return out, metadata, &smithy.SerializationError{Err: err}
  1944. }
  1945. in.Request = request
  1946. return next.HandleSerialize(ctx, in)
  1947. }
  1948. func awsAwsjson11_serializeDocumentDimensions(v map[string]string, value smithyjson.Value) error {
  1949. object := value.Object()
  1950. defer object.Close()
  1951. for key := range v {
  1952. om := object.Key(key)
  1953. om.String(v[key])
  1954. }
  1955. return nil
  1956. }
  1957. func awsAwsjson11_serializeDocumentInputLogEvent(v *types.InputLogEvent, value smithyjson.Value) error {
  1958. object := value.Object()
  1959. defer object.Close()
  1960. if v.Message != nil {
  1961. ok := object.Key("message")
  1962. ok.String(*v.Message)
  1963. }
  1964. if v.Timestamp != nil {
  1965. ok := object.Key("timestamp")
  1966. ok.Long(*v.Timestamp)
  1967. }
  1968. return nil
  1969. }
  1970. func awsAwsjson11_serializeDocumentInputLogEvents(v []types.InputLogEvent, value smithyjson.Value) error {
  1971. array := value.Array()
  1972. defer array.Close()
  1973. for i := range v {
  1974. av := array.Value()
  1975. if err := awsAwsjson11_serializeDocumentInputLogEvent(&v[i], av); err != nil {
  1976. return err
  1977. }
  1978. }
  1979. return nil
  1980. }
  1981. func awsAwsjson11_serializeDocumentInputLogStreamNames(v []string, value smithyjson.Value) error {
  1982. array := value.Array()
  1983. defer array.Close()
  1984. for i := range v {
  1985. av := array.Value()
  1986. av.String(v[i])
  1987. }
  1988. return nil
  1989. }
  1990. func awsAwsjson11_serializeDocumentLogGroupNames(v []string, value smithyjson.Value) error {
  1991. array := value.Array()
  1992. defer array.Close()
  1993. for i := range v {
  1994. av := array.Value()
  1995. av.String(v[i])
  1996. }
  1997. return nil
  1998. }
  1999. func awsAwsjson11_serializeDocumentMetricTransformation(v *types.MetricTransformation, value smithyjson.Value) error {
  2000. object := value.Object()
  2001. defer object.Close()
  2002. if v.DefaultValue != nil {
  2003. ok := object.Key("defaultValue")
  2004. switch {
  2005. case math.IsNaN(*v.DefaultValue):
  2006. ok.String("NaN")
  2007. case math.IsInf(*v.DefaultValue, 1):
  2008. ok.String("Infinity")
  2009. case math.IsInf(*v.DefaultValue, -1):
  2010. ok.String("-Infinity")
  2011. default:
  2012. ok.Double(*v.DefaultValue)
  2013. }
  2014. }
  2015. if v.Dimensions != nil {
  2016. ok := object.Key("dimensions")
  2017. if err := awsAwsjson11_serializeDocumentDimensions(v.Dimensions, ok); err != nil {
  2018. return err
  2019. }
  2020. }
  2021. if v.MetricName != nil {
  2022. ok := object.Key("metricName")
  2023. ok.String(*v.MetricName)
  2024. }
  2025. if v.MetricNamespace != nil {
  2026. ok := object.Key("metricNamespace")
  2027. ok.String(*v.MetricNamespace)
  2028. }
  2029. if v.MetricValue != nil {
  2030. ok := object.Key("metricValue")
  2031. ok.String(*v.MetricValue)
  2032. }
  2033. if len(v.Unit) > 0 {
  2034. ok := object.Key("unit")
  2035. ok.String(string(v.Unit))
  2036. }
  2037. return nil
  2038. }
  2039. func awsAwsjson11_serializeDocumentMetricTransformations(v []types.MetricTransformation, value smithyjson.Value) error {
  2040. array := value.Array()
  2041. defer array.Close()
  2042. for i := range v {
  2043. av := array.Value()
  2044. if err := awsAwsjson11_serializeDocumentMetricTransformation(&v[i], av); err != nil {
  2045. return err
  2046. }
  2047. }
  2048. return nil
  2049. }
  2050. func awsAwsjson11_serializeDocumentTagList(v []string, value smithyjson.Value) error {
  2051. array := value.Array()
  2052. defer array.Close()
  2053. for i := range v {
  2054. av := array.Value()
  2055. av.String(v[i])
  2056. }
  2057. return nil
  2058. }
  2059. func awsAwsjson11_serializeDocumentTags(v map[string]string, value smithyjson.Value) error {
  2060. object := value.Object()
  2061. defer object.Close()
  2062. for key := range v {
  2063. om := object.Key(key)
  2064. om.String(v[key])
  2065. }
  2066. return nil
  2067. }
  2068. func awsAwsjson11_serializeDocumentTestEventMessages(v []string, value smithyjson.Value) error {
  2069. array := value.Array()
  2070. defer array.Close()
  2071. for i := range v {
  2072. av := array.Value()
  2073. av.String(v[i])
  2074. }
  2075. return nil
  2076. }
  2077. func awsAwsjson11_serializeOpDocumentAssociateKmsKeyInput(v *AssociateKmsKeyInput, value smithyjson.Value) error {
  2078. object := value.Object()
  2079. defer object.Close()
  2080. if v.KmsKeyId != nil {
  2081. ok := object.Key("kmsKeyId")
  2082. ok.String(*v.KmsKeyId)
  2083. }
  2084. if v.LogGroupName != nil {
  2085. ok := object.Key("logGroupName")
  2086. ok.String(*v.LogGroupName)
  2087. }
  2088. return nil
  2089. }
  2090. func awsAwsjson11_serializeOpDocumentCancelExportTaskInput(v *CancelExportTaskInput, value smithyjson.Value) error {
  2091. object := value.Object()
  2092. defer object.Close()
  2093. if v.TaskId != nil {
  2094. ok := object.Key("taskId")
  2095. ok.String(*v.TaskId)
  2096. }
  2097. return nil
  2098. }
  2099. func awsAwsjson11_serializeOpDocumentCreateExportTaskInput(v *CreateExportTaskInput, value smithyjson.Value) error {
  2100. object := value.Object()
  2101. defer object.Close()
  2102. if v.Destination != nil {
  2103. ok := object.Key("destination")
  2104. ok.String(*v.Destination)
  2105. }
  2106. if v.DestinationPrefix != nil {
  2107. ok := object.Key("destinationPrefix")
  2108. ok.String(*v.DestinationPrefix)
  2109. }
  2110. if v.From != nil {
  2111. ok := object.Key("from")
  2112. ok.Long(*v.From)
  2113. }
  2114. if v.LogGroupName != nil {
  2115. ok := object.Key("logGroupName")
  2116. ok.String(*v.LogGroupName)
  2117. }
  2118. if v.LogStreamNamePrefix != nil {
  2119. ok := object.Key("logStreamNamePrefix")
  2120. ok.String(*v.LogStreamNamePrefix)
  2121. }
  2122. if v.TaskName != nil {
  2123. ok := object.Key("taskName")
  2124. ok.String(*v.TaskName)
  2125. }
  2126. if v.To != nil {
  2127. ok := object.Key("to")
  2128. ok.Long(*v.To)
  2129. }
  2130. return nil
  2131. }
  2132. func awsAwsjson11_serializeOpDocumentCreateLogGroupInput(v *CreateLogGroupInput, value smithyjson.Value) error {
  2133. object := value.Object()
  2134. defer object.Close()
  2135. if v.KmsKeyId != nil {
  2136. ok := object.Key("kmsKeyId")
  2137. ok.String(*v.KmsKeyId)
  2138. }
  2139. if v.LogGroupName != nil {
  2140. ok := object.Key("logGroupName")
  2141. ok.String(*v.LogGroupName)
  2142. }
  2143. if v.Tags != nil {
  2144. ok := object.Key("tags")
  2145. if err := awsAwsjson11_serializeDocumentTags(v.Tags, ok); err != nil {
  2146. return err
  2147. }
  2148. }
  2149. return nil
  2150. }
  2151. func awsAwsjson11_serializeOpDocumentCreateLogStreamInput(v *CreateLogStreamInput, value smithyjson.Value) error {
  2152. object := value.Object()
  2153. defer object.Close()
  2154. if v.LogGroupName != nil {
  2155. ok := object.Key("logGroupName")
  2156. ok.String(*v.LogGroupName)
  2157. }
  2158. if v.LogStreamName != nil {
  2159. ok := object.Key("logStreamName")
  2160. ok.String(*v.LogStreamName)
  2161. }
  2162. return nil
  2163. }
  2164. func awsAwsjson11_serializeOpDocumentDeleteDestinationInput(v *DeleteDestinationInput, value smithyjson.Value) error {
  2165. object := value.Object()
  2166. defer object.Close()
  2167. if v.DestinationName != nil {
  2168. ok := object.Key("destinationName")
  2169. ok.String(*v.DestinationName)
  2170. }
  2171. return nil
  2172. }
  2173. func awsAwsjson11_serializeOpDocumentDeleteLogGroupInput(v *DeleteLogGroupInput, value smithyjson.Value) error {
  2174. object := value.Object()
  2175. defer object.Close()
  2176. if v.LogGroupName != nil {
  2177. ok := object.Key("logGroupName")
  2178. ok.String(*v.LogGroupName)
  2179. }
  2180. return nil
  2181. }
  2182. func awsAwsjson11_serializeOpDocumentDeleteLogStreamInput(v *DeleteLogStreamInput, value smithyjson.Value) error {
  2183. object := value.Object()
  2184. defer object.Close()
  2185. if v.LogGroupName != nil {
  2186. ok := object.Key("logGroupName")
  2187. ok.String(*v.LogGroupName)
  2188. }
  2189. if v.LogStreamName != nil {
  2190. ok := object.Key("logStreamName")
  2191. ok.String(*v.LogStreamName)
  2192. }
  2193. return nil
  2194. }
  2195. func awsAwsjson11_serializeOpDocumentDeleteMetricFilterInput(v *DeleteMetricFilterInput, value smithyjson.Value) error {
  2196. object := value.Object()
  2197. defer object.Close()
  2198. if v.FilterName != nil {
  2199. ok := object.Key("filterName")
  2200. ok.String(*v.FilterName)
  2201. }
  2202. if v.LogGroupName != nil {
  2203. ok := object.Key("logGroupName")
  2204. ok.String(*v.LogGroupName)
  2205. }
  2206. return nil
  2207. }
  2208. func awsAwsjson11_serializeOpDocumentDeleteQueryDefinitionInput(v *DeleteQueryDefinitionInput, value smithyjson.Value) error {
  2209. object := value.Object()
  2210. defer object.Close()
  2211. if v.QueryDefinitionId != nil {
  2212. ok := object.Key("queryDefinitionId")
  2213. ok.String(*v.QueryDefinitionId)
  2214. }
  2215. return nil
  2216. }
  2217. func awsAwsjson11_serializeOpDocumentDeleteResourcePolicyInput(v *DeleteResourcePolicyInput, value smithyjson.Value) error {
  2218. object := value.Object()
  2219. defer object.Close()
  2220. if v.PolicyName != nil {
  2221. ok := object.Key("policyName")
  2222. ok.String(*v.PolicyName)
  2223. }
  2224. return nil
  2225. }
  2226. func awsAwsjson11_serializeOpDocumentDeleteRetentionPolicyInput(v *DeleteRetentionPolicyInput, value smithyjson.Value) error {
  2227. object := value.Object()
  2228. defer object.Close()
  2229. if v.LogGroupName != nil {
  2230. ok := object.Key("logGroupName")
  2231. ok.String(*v.LogGroupName)
  2232. }
  2233. return nil
  2234. }
  2235. func awsAwsjson11_serializeOpDocumentDeleteSubscriptionFilterInput(v *DeleteSubscriptionFilterInput, value smithyjson.Value) error {
  2236. object := value.Object()
  2237. defer object.Close()
  2238. if v.FilterName != nil {
  2239. ok := object.Key("filterName")
  2240. ok.String(*v.FilterName)
  2241. }
  2242. if v.LogGroupName != nil {
  2243. ok := object.Key("logGroupName")
  2244. ok.String(*v.LogGroupName)
  2245. }
  2246. return nil
  2247. }
  2248. func awsAwsjson11_serializeOpDocumentDescribeDestinationsInput(v *DescribeDestinationsInput, value smithyjson.Value) error {
  2249. object := value.Object()
  2250. defer object.Close()
  2251. if v.DestinationNamePrefix != nil {
  2252. ok := object.Key("DestinationNamePrefix")
  2253. ok.String(*v.DestinationNamePrefix)
  2254. }
  2255. if v.Limit != nil {
  2256. ok := object.Key("limit")
  2257. ok.Integer(*v.Limit)
  2258. }
  2259. if v.NextToken != nil {
  2260. ok := object.Key("nextToken")
  2261. ok.String(*v.NextToken)
  2262. }
  2263. return nil
  2264. }
  2265. func awsAwsjson11_serializeOpDocumentDescribeExportTasksInput(v *DescribeExportTasksInput, value smithyjson.Value) error {
  2266. object := value.Object()
  2267. defer object.Close()
  2268. if v.Limit != nil {
  2269. ok := object.Key("limit")
  2270. ok.Integer(*v.Limit)
  2271. }
  2272. if v.NextToken != nil {
  2273. ok := object.Key("nextToken")
  2274. ok.String(*v.NextToken)
  2275. }
  2276. if len(v.StatusCode) > 0 {
  2277. ok := object.Key("statusCode")
  2278. ok.String(string(v.StatusCode))
  2279. }
  2280. if v.TaskId != nil {
  2281. ok := object.Key("taskId")
  2282. ok.String(*v.TaskId)
  2283. }
  2284. return nil
  2285. }
  2286. func awsAwsjson11_serializeOpDocumentDescribeLogGroupsInput(v *DescribeLogGroupsInput, value smithyjson.Value) error {
  2287. object := value.Object()
  2288. defer object.Close()
  2289. if v.Limit != nil {
  2290. ok := object.Key("limit")
  2291. ok.Integer(*v.Limit)
  2292. }
  2293. if v.LogGroupNamePrefix != nil {
  2294. ok := object.Key("logGroupNamePrefix")
  2295. ok.String(*v.LogGroupNamePrefix)
  2296. }
  2297. if v.NextToken != nil {
  2298. ok := object.Key("nextToken")
  2299. ok.String(*v.NextToken)
  2300. }
  2301. return nil
  2302. }
  2303. func awsAwsjson11_serializeOpDocumentDescribeLogStreamsInput(v *DescribeLogStreamsInput, value smithyjson.Value) error {
  2304. object := value.Object()
  2305. defer object.Close()
  2306. if v.Descending != nil {
  2307. ok := object.Key("descending")
  2308. ok.Boolean(*v.Descending)
  2309. }
  2310. if v.Limit != nil {
  2311. ok := object.Key("limit")
  2312. ok.Integer(*v.Limit)
  2313. }
  2314. if v.LogGroupName != nil {
  2315. ok := object.Key("logGroupName")
  2316. ok.String(*v.LogGroupName)
  2317. }
  2318. if v.LogStreamNamePrefix != nil {
  2319. ok := object.Key("logStreamNamePrefix")
  2320. ok.String(*v.LogStreamNamePrefix)
  2321. }
  2322. if v.NextToken != nil {
  2323. ok := object.Key("nextToken")
  2324. ok.String(*v.NextToken)
  2325. }
  2326. if len(v.OrderBy) > 0 {
  2327. ok := object.Key("orderBy")
  2328. ok.String(string(v.OrderBy))
  2329. }
  2330. return nil
  2331. }
  2332. func awsAwsjson11_serializeOpDocumentDescribeMetricFiltersInput(v *DescribeMetricFiltersInput, value smithyjson.Value) error {
  2333. object := value.Object()
  2334. defer object.Close()
  2335. if v.FilterNamePrefix != nil {
  2336. ok := object.Key("filterNamePrefix")
  2337. ok.String(*v.FilterNamePrefix)
  2338. }
  2339. if v.Limit != nil {
  2340. ok := object.Key("limit")
  2341. ok.Integer(*v.Limit)
  2342. }
  2343. if v.LogGroupName != nil {
  2344. ok := object.Key("logGroupName")
  2345. ok.String(*v.LogGroupName)
  2346. }
  2347. if v.MetricName != nil {
  2348. ok := object.Key("metricName")
  2349. ok.String(*v.MetricName)
  2350. }
  2351. if v.MetricNamespace != nil {
  2352. ok := object.Key("metricNamespace")
  2353. ok.String(*v.MetricNamespace)
  2354. }
  2355. if v.NextToken != nil {
  2356. ok := object.Key("nextToken")
  2357. ok.String(*v.NextToken)
  2358. }
  2359. return nil
  2360. }
  2361. func awsAwsjson11_serializeOpDocumentDescribeQueriesInput(v *DescribeQueriesInput, value smithyjson.Value) error {
  2362. object := value.Object()
  2363. defer object.Close()
  2364. if v.LogGroupName != nil {
  2365. ok := object.Key("logGroupName")
  2366. ok.String(*v.LogGroupName)
  2367. }
  2368. if v.MaxResults != nil {
  2369. ok := object.Key("maxResults")
  2370. ok.Integer(*v.MaxResults)
  2371. }
  2372. if v.NextToken != nil {
  2373. ok := object.Key("nextToken")
  2374. ok.String(*v.NextToken)
  2375. }
  2376. if len(v.Status) > 0 {
  2377. ok := object.Key("status")
  2378. ok.String(string(v.Status))
  2379. }
  2380. return nil
  2381. }
  2382. func awsAwsjson11_serializeOpDocumentDescribeQueryDefinitionsInput(v *DescribeQueryDefinitionsInput, value smithyjson.Value) error {
  2383. object := value.Object()
  2384. defer object.Close()
  2385. if v.MaxResults != nil {
  2386. ok := object.Key("maxResults")
  2387. ok.Integer(*v.MaxResults)
  2388. }
  2389. if v.NextToken != nil {
  2390. ok := object.Key("nextToken")
  2391. ok.String(*v.NextToken)
  2392. }
  2393. if v.QueryDefinitionNamePrefix != nil {
  2394. ok := object.Key("queryDefinitionNamePrefix")
  2395. ok.String(*v.QueryDefinitionNamePrefix)
  2396. }
  2397. return nil
  2398. }
  2399. func awsAwsjson11_serializeOpDocumentDescribeResourcePoliciesInput(v *DescribeResourcePoliciesInput, value smithyjson.Value) error {
  2400. object := value.Object()
  2401. defer object.Close()
  2402. if v.Limit != nil {
  2403. ok := object.Key("limit")
  2404. ok.Integer(*v.Limit)
  2405. }
  2406. if v.NextToken != nil {
  2407. ok := object.Key("nextToken")
  2408. ok.String(*v.NextToken)
  2409. }
  2410. return nil
  2411. }
  2412. func awsAwsjson11_serializeOpDocumentDescribeSubscriptionFiltersInput(v *DescribeSubscriptionFiltersInput, value smithyjson.Value) error {
  2413. object := value.Object()
  2414. defer object.Close()
  2415. if v.FilterNamePrefix != nil {
  2416. ok := object.Key("filterNamePrefix")
  2417. ok.String(*v.FilterNamePrefix)
  2418. }
  2419. if v.Limit != nil {
  2420. ok := object.Key("limit")
  2421. ok.Integer(*v.Limit)
  2422. }
  2423. if v.LogGroupName != nil {
  2424. ok := object.Key("logGroupName")
  2425. ok.String(*v.LogGroupName)
  2426. }
  2427. if v.NextToken != nil {
  2428. ok := object.Key("nextToken")
  2429. ok.String(*v.NextToken)
  2430. }
  2431. return nil
  2432. }
  2433. func awsAwsjson11_serializeOpDocumentDisassociateKmsKeyInput(v *DisassociateKmsKeyInput, value smithyjson.Value) error {
  2434. object := value.Object()
  2435. defer object.Close()
  2436. if v.LogGroupName != nil {
  2437. ok := object.Key("logGroupName")
  2438. ok.String(*v.LogGroupName)
  2439. }
  2440. return nil
  2441. }
  2442. func awsAwsjson11_serializeOpDocumentFilterLogEventsInput(v *FilterLogEventsInput, value smithyjson.Value) error {
  2443. object := value.Object()
  2444. defer object.Close()
  2445. if v.EndTime != nil {
  2446. ok := object.Key("endTime")
  2447. ok.Long(*v.EndTime)
  2448. }
  2449. if v.FilterPattern != nil {
  2450. ok := object.Key("filterPattern")
  2451. ok.String(*v.FilterPattern)
  2452. }
  2453. if v.Interleaved != nil {
  2454. ok := object.Key("interleaved")
  2455. ok.Boolean(*v.Interleaved)
  2456. }
  2457. if v.Limit != nil {
  2458. ok := object.Key("limit")
  2459. ok.Integer(*v.Limit)
  2460. }
  2461. if v.LogGroupName != nil {
  2462. ok := object.Key("logGroupName")
  2463. ok.String(*v.LogGroupName)
  2464. }
  2465. if v.LogStreamNamePrefix != nil {
  2466. ok := object.Key("logStreamNamePrefix")
  2467. ok.String(*v.LogStreamNamePrefix)
  2468. }
  2469. if v.LogStreamNames != nil {
  2470. ok := object.Key("logStreamNames")
  2471. if err := awsAwsjson11_serializeDocumentInputLogStreamNames(v.LogStreamNames, ok); err != nil {
  2472. return err
  2473. }
  2474. }
  2475. if v.NextToken != nil {
  2476. ok := object.Key("nextToken")
  2477. ok.String(*v.NextToken)
  2478. }
  2479. if v.StartTime != nil {
  2480. ok := object.Key("startTime")
  2481. ok.Long(*v.StartTime)
  2482. }
  2483. return nil
  2484. }
  2485. func awsAwsjson11_serializeOpDocumentGetLogEventsInput(v *GetLogEventsInput, value smithyjson.Value) error {
  2486. object := value.Object()
  2487. defer object.Close()
  2488. if v.EndTime != nil {
  2489. ok := object.Key("endTime")
  2490. ok.Long(*v.EndTime)
  2491. }
  2492. if v.Limit != nil {
  2493. ok := object.Key("limit")
  2494. ok.Integer(*v.Limit)
  2495. }
  2496. if v.LogGroupName != nil {
  2497. ok := object.Key("logGroupName")
  2498. ok.String(*v.LogGroupName)
  2499. }
  2500. if v.LogStreamName != nil {
  2501. ok := object.Key("logStreamName")
  2502. ok.String(*v.LogStreamName)
  2503. }
  2504. if v.NextToken != nil {
  2505. ok := object.Key("nextToken")
  2506. ok.String(*v.NextToken)
  2507. }
  2508. if v.StartFromHead != nil {
  2509. ok := object.Key("startFromHead")
  2510. ok.Boolean(*v.StartFromHead)
  2511. }
  2512. if v.StartTime != nil {
  2513. ok := object.Key("startTime")
  2514. ok.Long(*v.StartTime)
  2515. }
  2516. return nil
  2517. }
  2518. func awsAwsjson11_serializeOpDocumentGetLogGroupFieldsInput(v *GetLogGroupFieldsInput, value smithyjson.Value) error {
  2519. object := value.Object()
  2520. defer object.Close()
  2521. if v.LogGroupName != nil {
  2522. ok := object.Key("logGroupName")
  2523. ok.String(*v.LogGroupName)
  2524. }
  2525. if v.Time != nil {
  2526. ok := object.Key("time")
  2527. ok.Long(*v.Time)
  2528. }
  2529. return nil
  2530. }
  2531. func awsAwsjson11_serializeOpDocumentGetLogRecordInput(v *GetLogRecordInput, value smithyjson.Value) error {
  2532. object := value.Object()
  2533. defer object.Close()
  2534. if v.LogRecordPointer != nil {
  2535. ok := object.Key("logRecordPointer")
  2536. ok.String(*v.LogRecordPointer)
  2537. }
  2538. return nil
  2539. }
  2540. func awsAwsjson11_serializeOpDocumentGetQueryResultsInput(v *GetQueryResultsInput, value smithyjson.Value) error {
  2541. object := value.Object()
  2542. defer object.Close()
  2543. if v.QueryId != nil {
  2544. ok := object.Key("queryId")
  2545. ok.String(*v.QueryId)
  2546. }
  2547. return nil
  2548. }
  2549. func awsAwsjson11_serializeOpDocumentListTagsLogGroupInput(v *ListTagsLogGroupInput, value smithyjson.Value) error {
  2550. object := value.Object()
  2551. defer object.Close()
  2552. if v.LogGroupName != nil {
  2553. ok := object.Key("logGroupName")
  2554. ok.String(*v.LogGroupName)
  2555. }
  2556. return nil
  2557. }
  2558. func awsAwsjson11_serializeOpDocumentPutDestinationInput(v *PutDestinationInput, value smithyjson.Value) error {
  2559. object := value.Object()
  2560. defer object.Close()
  2561. if v.DestinationName != nil {
  2562. ok := object.Key("destinationName")
  2563. ok.String(*v.DestinationName)
  2564. }
  2565. if v.RoleArn != nil {
  2566. ok := object.Key("roleArn")
  2567. ok.String(*v.RoleArn)
  2568. }
  2569. if v.TargetArn != nil {
  2570. ok := object.Key("targetArn")
  2571. ok.String(*v.TargetArn)
  2572. }
  2573. return nil
  2574. }
  2575. func awsAwsjson11_serializeOpDocumentPutDestinationPolicyInput(v *PutDestinationPolicyInput, value smithyjson.Value) error {
  2576. object := value.Object()
  2577. defer object.Close()
  2578. if v.AccessPolicy != nil {
  2579. ok := object.Key("accessPolicy")
  2580. ok.String(*v.AccessPolicy)
  2581. }
  2582. if v.DestinationName != nil {
  2583. ok := object.Key("destinationName")
  2584. ok.String(*v.DestinationName)
  2585. }
  2586. if v.ForceUpdate != nil {
  2587. ok := object.Key("forceUpdate")
  2588. ok.Boolean(*v.ForceUpdate)
  2589. }
  2590. return nil
  2591. }
  2592. func awsAwsjson11_serializeOpDocumentPutLogEventsInput(v *PutLogEventsInput, value smithyjson.Value) error {
  2593. object := value.Object()
  2594. defer object.Close()
  2595. if v.LogEvents != nil {
  2596. ok := object.Key("logEvents")
  2597. if err := awsAwsjson11_serializeDocumentInputLogEvents(v.LogEvents, ok); err != nil {
  2598. return err
  2599. }
  2600. }
  2601. if v.LogGroupName != nil {
  2602. ok := object.Key("logGroupName")
  2603. ok.String(*v.LogGroupName)
  2604. }
  2605. if v.LogStreamName != nil {
  2606. ok := object.Key("logStreamName")
  2607. ok.String(*v.LogStreamName)
  2608. }
  2609. if v.SequenceToken != nil {
  2610. ok := object.Key("sequenceToken")
  2611. ok.String(*v.SequenceToken)
  2612. }
  2613. return nil
  2614. }
  2615. func awsAwsjson11_serializeOpDocumentPutMetricFilterInput(v *PutMetricFilterInput, value smithyjson.Value) error {
  2616. object := value.Object()
  2617. defer object.Close()
  2618. if v.FilterName != nil {
  2619. ok := object.Key("filterName")
  2620. ok.String(*v.FilterName)
  2621. }
  2622. if v.FilterPattern != nil {
  2623. ok := object.Key("filterPattern")
  2624. ok.String(*v.FilterPattern)
  2625. }
  2626. if v.LogGroupName != nil {
  2627. ok := object.Key("logGroupName")
  2628. ok.String(*v.LogGroupName)
  2629. }
  2630. if v.MetricTransformations != nil {
  2631. ok := object.Key("metricTransformations")
  2632. if err := awsAwsjson11_serializeDocumentMetricTransformations(v.MetricTransformations, ok); err != nil {
  2633. return err
  2634. }
  2635. }
  2636. return nil
  2637. }
  2638. func awsAwsjson11_serializeOpDocumentPutQueryDefinitionInput(v *PutQueryDefinitionInput, value smithyjson.Value) error {
  2639. object := value.Object()
  2640. defer object.Close()
  2641. if v.LogGroupNames != nil {
  2642. ok := object.Key("logGroupNames")
  2643. if err := awsAwsjson11_serializeDocumentLogGroupNames(v.LogGroupNames, ok); err != nil {
  2644. return err
  2645. }
  2646. }
  2647. if v.Name != nil {
  2648. ok := object.Key("name")
  2649. ok.String(*v.Name)
  2650. }
  2651. if v.QueryDefinitionId != nil {
  2652. ok := object.Key("queryDefinitionId")
  2653. ok.String(*v.QueryDefinitionId)
  2654. }
  2655. if v.QueryString != nil {
  2656. ok := object.Key("queryString")
  2657. ok.String(*v.QueryString)
  2658. }
  2659. return nil
  2660. }
  2661. func awsAwsjson11_serializeOpDocumentPutResourcePolicyInput(v *PutResourcePolicyInput, value smithyjson.Value) error {
  2662. object := value.Object()
  2663. defer object.Close()
  2664. if v.PolicyDocument != nil {
  2665. ok := object.Key("policyDocument")
  2666. ok.String(*v.PolicyDocument)
  2667. }
  2668. if v.PolicyName != nil {
  2669. ok := object.Key("policyName")
  2670. ok.String(*v.PolicyName)
  2671. }
  2672. return nil
  2673. }
  2674. func awsAwsjson11_serializeOpDocumentPutRetentionPolicyInput(v *PutRetentionPolicyInput, value smithyjson.Value) error {
  2675. object := value.Object()
  2676. defer object.Close()
  2677. if v.LogGroupName != nil {
  2678. ok := object.Key("logGroupName")
  2679. ok.String(*v.LogGroupName)
  2680. }
  2681. if v.RetentionInDays != nil {
  2682. ok := object.Key("retentionInDays")
  2683. ok.Integer(*v.RetentionInDays)
  2684. }
  2685. return nil
  2686. }
  2687. func awsAwsjson11_serializeOpDocumentPutSubscriptionFilterInput(v *PutSubscriptionFilterInput, value smithyjson.Value) error {
  2688. object := value.Object()
  2689. defer object.Close()
  2690. if v.DestinationArn != nil {
  2691. ok := object.Key("destinationArn")
  2692. ok.String(*v.DestinationArn)
  2693. }
  2694. if len(v.Distribution) > 0 {
  2695. ok := object.Key("distribution")
  2696. ok.String(string(v.Distribution))
  2697. }
  2698. if v.FilterName != nil {
  2699. ok := object.Key("filterName")
  2700. ok.String(*v.FilterName)
  2701. }
  2702. if v.FilterPattern != nil {
  2703. ok := object.Key("filterPattern")
  2704. ok.String(*v.FilterPattern)
  2705. }
  2706. if v.LogGroupName != nil {
  2707. ok := object.Key("logGroupName")
  2708. ok.String(*v.LogGroupName)
  2709. }
  2710. if v.RoleArn != nil {
  2711. ok := object.Key("roleArn")
  2712. ok.String(*v.RoleArn)
  2713. }
  2714. return nil
  2715. }
  2716. func awsAwsjson11_serializeOpDocumentStartQueryInput(v *StartQueryInput, value smithyjson.Value) error {
  2717. object := value.Object()
  2718. defer object.Close()
  2719. if v.EndTime != nil {
  2720. ok := object.Key("endTime")
  2721. ok.Long(*v.EndTime)
  2722. }
  2723. if v.Limit != nil {
  2724. ok := object.Key("limit")
  2725. ok.Integer(*v.Limit)
  2726. }
  2727. if v.LogGroupName != nil {
  2728. ok := object.Key("logGroupName")
  2729. ok.String(*v.LogGroupName)
  2730. }
  2731. if v.LogGroupNames != nil {
  2732. ok := object.Key("logGroupNames")
  2733. if err := awsAwsjson11_serializeDocumentLogGroupNames(v.LogGroupNames, ok); err != nil {
  2734. return err
  2735. }
  2736. }
  2737. if v.QueryString != nil {
  2738. ok := object.Key("queryString")
  2739. ok.String(*v.QueryString)
  2740. }
  2741. if v.StartTime != nil {
  2742. ok := object.Key("startTime")
  2743. ok.Long(*v.StartTime)
  2744. }
  2745. return nil
  2746. }
  2747. func awsAwsjson11_serializeOpDocumentStopQueryInput(v *StopQueryInput, value smithyjson.Value) error {
  2748. object := value.Object()
  2749. defer object.Close()
  2750. if v.QueryId != nil {
  2751. ok := object.Key("queryId")
  2752. ok.String(*v.QueryId)
  2753. }
  2754. return nil
  2755. }
  2756. func awsAwsjson11_serializeOpDocumentTagLogGroupInput(v *TagLogGroupInput, value smithyjson.Value) error {
  2757. object := value.Object()
  2758. defer object.Close()
  2759. if v.LogGroupName != nil {
  2760. ok := object.Key("logGroupName")
  2761. ok.String(*v.LogGroupName)
  2762. }
  2763. if v.Tags != nil {
  2764. ok := object.Key("tags")
  2765. if err := awsAwsjson11_serializeDocumentTags(v.Tags, ok); err != nil {
  2766. return err
  2767. }
  2768. }
  2769. return nil
  2770. }
  2771. func awsAwsjson11_serializeOpDocumentTestMetricFilterInput(v *TestMetricFilterInput, value smithyjson.Value) error {
  2772. object := value.Object()
  2773. defer object.Close()
  2774. if v.FilterPattern != nil {
  2775. ok := object.Key("filterPattern")
  2776. ok.String(*v.FilterPattern)
  2777. }
  2778. if v.LogEventMessages != nil {
  2779. ok := object.Key("logEventMessages")
  2780. if err := awsAwsjson11_serializeDocumentTestEventMessages(v.LogEventMessages, ok); err != nil {
  2781. return err
  2782. }
  2783. }
  2784. return nil
  2785. }
  2786. func awsAwsjson11_serializeOpDocumentUntagLogGroupInput(v *UntagLogGroupInput, value smithyjson.Value) error {
  2787. object := value.Object()
  2788. defer object.Close()
  2789. if v.LogGroupName != nil {
  2790. ok := object.Key("logGroupName")
  2791. ok.String(*v.LogGroupName)
  2792. }
  2793. if v.Tags != nil {
  2794. ok := object.Key("tags")
  2795. if err := awsAwsjson11_serializeDocumentTagList(v.Tags, ok); err != nil {
  2796. return err
  2797. }
  2798. }
  2799. return nil
  2800. }