123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461 |
- // Code generated by easyjson for marshaling/unmarshaling. DO NOT EDIT.
- package elastic
- import (
- json "encoding/json"
- easyjson "github.com/mailru/easyjson"
- jlexer "github.com/mailru/easyjson/jlexer"
- jwriter "github.com/mailru/easyjson/jwriter"
- )
- // suppress unused package warning
- var (
- _ *json.RawMessage
- _ *jlexer.Lexer
- _ *jwriter.Writer
- _ easyjson.Marshaler
- )
- func easyjson1ed00e60DecodeGopkgInOlivereElasticV5(in *jlexer.Lexer, out *bulkUpdateRequestCommandOp) {
- isTopLevel := in.IsStart()
- if in.IsNull() {
- if isTopLevel {
- in.Consumed()
- }
- in.Skip()
- return
- }
- in.Delim('{')
- for !in.IsDelim('}') {
- key := in.UnsafeString()
- in.WantColon()
- if in.IsNull() {
- in.Skip()
- in.WantComma()
- continue
- }
- switch key {
- case "_id":
- out.Id = string(in.String())
- case "_index":
- out.Index = string(in.String())
- case "_type":
- out.Type = string(in.String())
- case "_parent":
- out.Parent = string(in.String())
- case "_retry_on_conflict":
- if in.IsNull() {
- in.Skip()
- out.RetryOnConflict = nil
- } else {
- if out.RetryOnConflict == nil {
- out.RetryOnConflict = new(int)
- }
- *out.RetryOnConflict = int(in.Int())
- }
- case "_routing":
- out.Routing = string(in.String())
- case "_version":
- out.Version = int64(in.Int64())
- case "_version_type":
- out.VersionType = string(in.String())
- default:
- in.SkipRecursive()
- }
- in.WantComma()
- }
- in.Delim('}')
- if isTopLevel {
- in.Consumed()
- }
- }
- func easyjson1ed00e60EncodeGopkgInOlivereElasticV5(out *jwriter.Writer, in bulkUpdateRequestCommandOp) {
- out.RawByte('{')
- first := true
- _ = first
- if in.Id != "" {
- const prefix string = ",\"_id\":"
- if first {
- first = false
- out.RawString(prefix[1:])
- } else {
- out.RawString(prefix)
- }
- out.String(string(in.Id))
- }
- if in.Index != "" {
- const prefix string = ",\"_index\":"
- if first {
- first = false
- out.RawString(prefix[1:])
- } else {
- out.RawString(prefix)
- }
- out.String(string(in.Index))
- }
- if in.Type != "" {
- const prefix string = ",\"_type\":"
- if first {
- first = false
- out.RawString(prefix[1:])
- } else {
- out.RawString(prefix)
- }
- out.String(string(in.Type))
- }
- if in.Parent != "" {
- const prefix string = ",\"_parent\":"
- if first {
- first = false
- out.RawString(prefix[1:])
- } else {
- out.RawString(prefix)
- }
- out.String(string(in.Parent))
- }
- if in.RetryOnConflict != nil {
- const prefix string = ",\"_retry_on_conflict\":"
- if first {
- first = false
- out.RawString(prefix[1:])
- } else {
- out.RawString(prefix)
- }
- out.Int(int(*in.RetryOnConflict))
- }
- if in.Routing != "" {
- const prefix string = ",\"_routing\":"
- if first {
- first = false
- out.RawString(prefix[1:])
- } else {
- out.RawString(prefix)
- }
- out.String(string(in.Routing))
- }
- if in.Version != 0 {
- const prefix string = ",\"_version\":"
- if first {
- first = false
- out.RawString(prefix[1:])
- } else {
- out.RawString(prefix)
- }
- out.Int64(int64(in.Version))
- }
- if in.VersionType != "" {
- const prefix string = ",\"_version_type\":"
- if first {
- first = false
- out.RawString(prefix[1:])
- } else {
- out.RawString(prefix)
- }
- out.String(string(in.VersionType))
- }
- out.RawByte('}')
- }
- // MarshalJSON supports json.Marshaler interface
- func (v bulkUpdateRequestCommandOp) MarshalJSON() ([]byte, error) {
- w := jwriter.Writer{}
- easyjson1ed00e60EncodeGopkgInOlivereElasticV5(&w, v)
- return w.Buffer.BuildBytes(), w.Error
- }
- // MarshalEasyJSON supports easyjson.Marshaler interface
- func (v bulkUpdateRequestCommandOp) MarshalEasyJSON(w *jwriter.Writer) {
- easyjson1ed00e60EncodeGopkgInOlivereElasticV5(w, v)
- }
- // UnmarshalJSON supports json.Unmarshaler interface
- func (v *bulkUpdateRequestCommandOp) UnmarshalJSON(data []byte) error {
- r := jlexer.Lexer{Data: data}
- easyjson1ed00e60DecodeGopkgInOlivereElasticV5(&r, v)
- return r.Error()
- }
- // UnmarshalEasyJSON supports easyjson.Unmarshaler interface
- func (v *bulkUpdateRequestCommandOp) UnmarshalEasyJSON(l *jlexer.Lexer) {
- easyjson1ed00e60DecodeGopkgInOlivereElasticV5(l, v)
- }
- func easyjson1ed00e60DecodeGopkgInOlivereElasticV51(in *jlexer.Lexer, out *bulkUpdateRequestCommandData) {
- isTopLevel := in.IsStart()
- if in.IsNull() {
- if isTopLevel {
- in.Consumed()
- }
- in.Skip()
- return
- }
- in.Delim('{')
- for !in.IsDelim('}') {
- key := in.UnsafeString()
- in.WantColon()
- if in.IsNull() {
- in.Skip()
- in.WantComma()
- continue
- }
- switch key {
- case "detect_noop":
- if in.IsNull() {
- in.Skip()
- out.DetectNoop = nil
- } else {
- if out.DetectNoop == nil {
- out.DetectNoop = new(bool)
- }
- *out.DetectNoop = bool(in.Bool())
- }
- case "doc":
- if m, ok := out.Doc.(easyjson.Unmarshaler); ok {
- m.UnmarshalEasyJSON(in)
- } else if m, ok := out.Doc.(json.Unmarshaler); ok {
- _ = m.UnmarshalJSON(in.Raw())
- } else {
- out.Doc = in.Interface()
- }
- case "doc_as_upsert":
- if in.IsNull() {
- in.Skip()
- out.DocAsUpsert = nil
- } else {
- if out.DocAsUpsert == nil {
- out.DocAsUpsert = new(bool)
- }
- *out.DocAsUpsert = bool(in.Bool())
- }
- case "upsert":
- if m, ok := out.Upsert.(easyjson.Unmarshaler); ok {
- m.UnmarshalEasyJSON(in)
- } else if m, ok := out.Upsert.(json.Unmarshaler); ok {
- _ = m.UnmarshalJSON(in.Raw())
- } else {
- out.Upsert = in.Interface()
- }
- case "script":
- if m, ok := out.Script.(easyjson.Unmarshaler); ok {
- m.UnmarshalEasyJSON(in)
- } else if m, ok := out.Script.(json.Unmarshaler); ok {
- _ = m.UnmarshalJSON(in.Raw())
- } else {
- out.Script = in.Interface()
- }
- case "scripted_upsert":
- if in.IsNull() {
- in.Skip()
- out.ScriptedUpsert = nil
- } else {
- if out.ScriptedUpsert == nil {
- out.ScriptedUpsert = new(bool)
- }
- *out.ScriptedUpsert = bool(in.Bool())
- }
- case "_source":
- if in.IsNull() {
- in.Skip()
- out.Source = nil
- } else {
- if out.Source == nil {
- out.Source = new(bool)
- }
- *out.Source = bool(in.Bool())
- }
- default:
- in.SkipRecursive()
- }
- in.WantComma()
- }
- in.Delim('}')
- if isTopLevel {
- in.Consumed()
- }
- }
- func easyjson1ed00e60EncodeGopkgInOlivereElasticV51(out *jwriter.Writer, in bulkUpdateRequestCommandData) {
- out.RawByte('{')
- first := true
- _ = first
- if in.DetectNoop != nil {
- const prefix string = ",\"detect_noop\":"
- if first {
- first = false
- out.RawString(prefix[1:])
- } else {
- out.RawString(prefix)
- }
- out.Bool(bool(*in.DetectNoop))
- }
- if in.Doc != nil {
- const prefix string = ",\"doc\":"
- if first {
- first = false
- out.RawString(prefix[1:])
- } else {
- out.RawString(prefix)
- }
- if m, ok := in.Doc.(easyjson.Marshaler); ok {
- m.MarshalEasyJSON(out)
- } else if m, ok := in.Doc.(json.Marshaler); ok {
- out.Raw(m.MarshalJSON())
- } else {
- out.Raw(json.Marshal(in.Doc))
- }
- }
- if in.DocAsUpsert != nil {
- const prefix string = ",\"doc_as_upsert\":"
- if first {
- first = false
- out.RawString(prefix[1:])
- } else {
- out.RawString(prefix)
- }
- out.Bool(bool(*in.DocAsUpsert))
- }
- if in.Upsert != nil {
- const prefix string = ",\"upsert\":"
- if first {
- first = false
- out.RawString(prefix[1:])
- } else {
- out.RawString(prefix)
- }
- if m, ok := in.Upsert.(easyjson.Marshaler); ok {
- m.MarshalEasyJSON(out)
- } else if m, ok := in.Upsert.(json.Marshaler); ok {
- out.Raw(m.MarshalJSON())
- } else {
- out.Raw(json.Marshal(in.Upsert))
- }
- }
- if in.Script != nil {
- const prefix string = ",\"script\":"
- if first {
- first = false
- out.RawString(prefix[1:])
- } else {
- out.RawString(prefix)
- }
- if m, ok := in.Script.(easyjson.Marshaler); ok {
- m.MarshalEasyJSON(out)
- } else if m, ok := in.Script.(json.Marshaler); ok {
- out.Raw(m.MarshalJSON())
- } else {
- out.Raw(json.Marshal(in.Script))
- }
- }
- if in.ScriptedUpsert != nil {
- const prefix string = ",\"scripted_upsert\":"
- if first {
- first = false
- out.RawString(prefix[1:])
- } else {
- out.RawString(prefix)
- }
- out.Bool(bool(*in.ScriptedUpsert))
- }
- if in.Source != nil {
- const prefix string = ",\"_source\":"
- if first {
- first = false
- out.RawString(prefix[1:])
- } else {
- out.RawString(prefix)
- }
- out.Bool(bool(*in.Source))
- }
- out.RawByte('}')
- }
- // MarshalJSON supports json.Marshaler interface
- func (v bulkUpdateRequestCommandData) MarshalJSON() ([]byte, error) {
- w := jwriter.Writer{}
- easyjson1ed00e60EncodeGopkgInOlivereElasticV51(&w, v)
- return w.Buffer.BuildBytes(), w.Error
- }
- // MarshalEasyJSON supports easyjson.Marshaler interface
- func (v bulkUpdateRequestCommandData) MarshalEasyJSON(w *jwriter.Writer) {
- easyjson1ed00e60EncodeGopkgInOlivereElasticV51(w, v)
- }
- // UnmarshalJSON supports json.Unmarshaler interface
- func (v *bulkUpdateRequestCommandData) UnmarshalJSON(data []byte) error {
- r := jlexer.Lexer{Data: data}
- easyjson1ed00e60DecodeGopkgInOlivereElasticV51(&r, v)
- return r.Error()
- }
- // UnmarshalEasyJSON supports easyjson.Unmarshaler interface
- func (v *bulkUpdateRequestCommandData) UnmarshalEasyJSON(l *jlexer.Lexer) {
- easyjson1ed00e60DecodeGopkgInOlivereElasticV51(l, v)
- }
- func easyjson1ed00e60DecodeGopkgInOlivereElasticV52(in *jlexer.Lexer, out *bulkUpdateRequestCommand) {
- isTopLevel := in.IsStart()
- if in.IsNull() {
- in.Skip()
- } else {
- in.Delim('{')
- if !in.IsDelim('}') {
- *out = make(bulkUpdateRequestCommand)
- } else {
- *out = nil
- }
- for !in.IsDelim('}') {
- key := string(in.String())
- in.WantColon()
- var v1 bulkUpdateRequestCommandOp
- (v1).UnmarshalEasyJSON(in)
- (*out)[key] = v1
- in.WantComma()
- }
- in.Delim('}')
- }
- if isTopLevel {
- in.Consumed()
- }
- }
- func easyjson1ed00e60EncodeGopkgInOlivereElasticV52(out *jwriter.Writer, in bulkUpdateRequestCommand) {
- if in == nil && (out.Flags&jwriter.NilMapAsEmpty) == 0 {
- out.RawString(`null`)
- } else {
- out.RawByte('{')
- v2First := true
- for v2Name, v2Value := range in {
- if v2First {
- v2First = false
- } else {
- out.RawByte(',')
- }
- out.String(string(v2Name))
- out.RawByte(':')
- (v2Value).MarshalEasyJSON(out)
- }
- out.RawByte('}')
- }
- }
- // MarshalJSON supports json.Marshaler interface
- func (v bulkUpdateRequestCommand) MarshalJSON() ([]byte, error) {
- w := jwriter.Writer{}
- easyjson1ed00e60EncodeGopkgInOlivereElasticV52(&w, v)
- return w.Buffer.BuildBytes(), w.Error
- }
- // MarshalEasyJSON supports easyjson.Marshaler interface
- func (v bulkUpdateRequestCommand) MarshalEasyJSON(w *jwriter.Writer) {
- easyjson1ed00e60EncodeGopkgInOlivereElasticV52(w, v)
- }
- // UnmarshalJSON supports json.Unmarshaler interface
- func (v *bulkUpdateRequestCommand) UnmarshalJSON(data []byte) error {
- r := jlexer.Lexer{Data: data}
- easyjson1ed00e60DecodeGopkgInOlivereElasticV52(&r, v)
- return r.Error()
- }
- // UnmarshalEasyJSON supports easyjson.Unmarshaler interface
- func (v *bulkUpdateRequestCommand) UnmarshalEasyJSON(l *jlexer.Lexer) {
- easyjson1ed00e60DecodeGopkgInOlivereElasticV52(l, v)
- }
|