package cmd // Code generated by github.com/tinylib/msgp DO NOT EDIT. import ( "github.com/minio/minio/internal/bucket/replication" "github.com/tinylib/msgp/msgp" ) // DecodeMsg implements msgp.Decodable func (z *ReplicateDecision) DecodeMsg(dc *msgp.Reader) (err error) { var field []byte _ = field var zb0001 uint32 zb0001, err = dc.ReadMapHeader() if err != nil { err = msgp.WrapError(err) return } for zb0001 > 0 { zb0001-- field, err = dc.ReadMapKeyPtr() if err != nil { err = msgp.WrapError(err) return } switch msgp.UnsafeString(field) { default: err = dc.Skip() if err != nil { err = msgp.WrapError(err) return } } } return } // EncodeMsg implements msgp.Encodable func (z ReplicateDecision) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 0 err = en.Append(0x80) if err != nil { return } return } // MarshalMsg implements msgp.Marshaler func (z ReplicateDecision) MarshalMsg(b []byte) (o []byte, err error) { o = msgp.Require(b, z.Msgsize()) // map header, size 0 o = append(o, 0x80) return } // UnmarshalMsg implements msgp.Unmarshaler func (z *ReplicateDecision) UnmarshalMsg(bts []byte) (o []byte, err error) { var field []byte _ = field var zb0001 uint32 zb0001, bts, err = msgp.ReadMapHeaderBytes(bts) if err != nil { err = msgp.WrapError(err) return } for zb0001 > 0 { zb0001-- field, bts, err = msgp.ReadMapKeyZC(bts) if err != nil { err = msgp.WrapError(err) return } switch msgp.UnsafeString(field) { default: bts, err = msgp.Skip(bts) if err != nil { err = msgp.WrapError(err) return } } } o = bts return } // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message func (z ReplicateDecision) Msgsize() (s int) { s = 1 return } // DecodeMsg implements msgp.Decodable func (z *ReplicationState) DecodeMsg(dc *msgp.Reader) (err error) { var field []byte _ = field var zb0001 uint32 zb0001, err = dc.ReadMapHeader() if err != nil { err = msgp.WrapError(err) return } for zb0001 > 0 { zb0001-- field, err = dc.ReadMapKeyPtr() if err != nil { err = msgp.WrapError(err) return } switch msgp.UnsafeString(field) { case "ReplicaTimeStamp": z.ReplicaTimeStamp, err = dc.ReadTime() if err != nil { err = msgp.WrapError(err, "ReplicaTimeStamp") return } case "ReplicaStatus": err = z.ReplicaStatus.DecodeMsg(dc) if err != nil { err = msgp.WrapError(err, "ReplicaStatus") return } case "DeleteMarker": z.DeleteMarker, err = dc.ReadBool() if err != nil { err = msgp.WrapError(err, "DeleteMarker") return } case "ReplicationTimeStamp": z.ReplicationTimeStamp, err = dc.ReadTime() if err != nil { err = msgp.WrapError(err, "ReplicationTimeStamp") return } case "ReplicationStatusInternal": z.ReplicationStatusInternal, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "ReplicationStatusInternal") return } case "VersionPurgeStatusInternal": z.VersionPurgeStatusInternal, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "VersionPurgeStatusInternal") return } case "ReplicateDecisionStr": z.ReplicateDecisionStr, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "ReplicateDecisionStr") return } case "Targets": var zb0002 uint32 zb0002, err = dc.ReadMapHeader() if err != nil { err = msgp.WrapError(err, "Targets") return } if z.Targets == nil { z.Targets = make(map[string]replication.StatusType, zb0002) } else if len(z.Targets) > 0 { for key := range z.Targets { delete(z.Targets, key) } } for zb0002 > 0 { zb0002-- var za0001 string var za0002 replication.StatusType za0001, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "Targets") return } err = za0002.DecodeMsg(dc) if err != nil { err = msgp.WrapError(err, "Targets", za0001) return } z.Targets[za0001] = za0002 } case "PurgeTargets": var zb0003 uint32 zb0003, err = dc.ReadMapHeader() if err != nil { err = msgp.WrapError(err, "PurgeTargets") return } if z.PurgeTargets == nil { z.PurgeTargets = make(map[string]VersionPurgeStatusType, zb0003) } else if len(z.PurgeTargets) > 0 { for key := range z.PurgeTargets { delete(z.PurgeTargets, key) } } for zb0003 > 0 { zb0003-- var za0003 string var za0004 VersionPurgeStatusType za0003, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "PurgeTargets") return } { var zb0004 string zb0004, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "PurgeTargets", za0003) return } za0004 = VersionPurgeStatusType(zb0004) } z.PurgeTargets[za0003] = za0004 } case "ResetStatusesMap": var zb0005 uint32 zb0005, err = dc.ReadMapHeader() if err != nil { err = msgp.WrapError(err, "ResetStatusesMap") return } if z.ResetStatusesMap == nil { z.ResetStatusesMap = make(map[string]string, zb0005) } else if len(z.ResetStatusesMap) > 0 { for key := range z.ResetStatusesMap { delete(z.ResetStatusesMap, key) } } for zb0005 > 0 { zb0005-- var za0005 string var za0006 string za0005, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "ResetStatusesMap") return } za0006, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "ResetStatusesMap", za0005) return } z.ResetStatusesMap[za0005] = za0006 } default: err = dc.Skip() if err != nil { err = msgp.WrapError(err) return } } } return } // EncodeMsg implements msgp.Encodable func (z *ReplicationState) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 10 // write "ReplicaTimeStamp" err = en.Append(0x8a, 0xb0, 0x52, 0x65, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x54, 0x69, 0x6d, 0x65, 0x53, 0x74, 0x61, 0x6d, 0x70) if err != nil { return } err = en.WriteTime(z.ReplicaTimeStamp) if err != nil { err = msgp.WrapError(err, "ReplicaTimeStamp") return } // write "ReplicaStatus" err = en.Append(0xad, 0x52, 0x65, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73) if err != nil { return } err = z.ReplicaStatus.EncodeMsg(en) if err != nil { err = msgp.WrapError(err, "ReplicaStatus") return } // write "DeleteMarker" err = en.Append(0xac, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x4d, 0x61, 0x72, 0x6b, 0x65, 0x72) if err != nil { return } err = en.WriteBool(z.DeleteMarker) if err != nil { err = msgp.WrapError(err, "DeleteMarker") return } // write "ReplicationTimeStamp" err = en.Append(0xb4, 0x52, 0x65, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x54, 0x69, 0x6d, 0x65, 0x53, 0x74, 0x61, 0x6d, 0x70) if err != nil { return } err = en.WriteTime(z.ReplicationTimeStamp) if err != nil { err = msgp.WrapError(err, "ReplicationTimeStamp") return } // write "ReplicationStatusInternal" err = en.Append(0xb9, 0x52, 0x65, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c) if err != nil { return } err = en.WriteString(z.ReplicationStatusInternal) if err != nil { err = msgp.WrapError(err, "ReplicationStatusInternal") return } // write "VersionPurgeStatusInternal" err = en.Append(0xba, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x50, 0x75, 0x72, 0x67, 0x65, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c) if err != nil { return } err = en.WriteString(z.VersionPurgeStatusInternal) if err != nil { err = msgp.WrapError(err, "VersionPurgeStatusInternal") return } // write "ReplicateDecisionStr" err = en.Append(0xb4, 0x52, 0x65, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x65, 0x44, 0x65, 0x63, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x53, 0x74, 0x72) if err != nil { return } err = en.WriteString(z.ReplicateDecisionStr) if err != nil { err = msgp.WrapError(err, "ReplicateDecisionStr") return } // write "Targets" err = en.Append(0xa7, 0x54, 0x61, 0x72, 0x67, 0x65, 0x74, 0x73) if err != nil { return } err = en.WriteMapHeader(uint32(len(z.Targets))) if err != nil { err = msgp.WrapError(err, "Targets") return } for za0001, za0002 := range z.Targets { err = en.WriteString(za0001) if err != nil { err = msgp.WrapError(err, "Targets") return } err = za0002.EncodeMsg(en) if err != nil { err = msgp.WrapError(err, "Targets", za0001) return } } // write "PurgeTargets" err = en.Append(0xac, 0x50, 0x75, 0x72, 0x67, 0x65, 0x54, 0x61, 0x72, 0x67, 0x65, 0x74, 0x73) if err != nil { return } err = en.WriteMapHeader(uint32(len(z.PurgeTargets))) if err != nil { err = msgp.WrapError(err, "PurgeTargets") return } for za0003, za0004 := range z.PurgeTargets { err = en.WriteString(za0003) if err != nil { err = msgp.WrapError(err, "PurgeTargets") return } err = en.WriteString(string(za0004)) if err != nil { err = msgp.WrapError(err, "PurgeTargets", za0003) return } } // write "ResetStatusesMap" err = en.Append(0xb0, 0x52, 0x65, 0x73, 0x65, 0x74, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x65, 0x73, 0x4d, 0x61, 0x70) if err != nil { return } err = en.WriteMapHeader(uint32(len(z.ResetStatusesMap))) if err != nil { err = msgp.WrapError(err, "ResetStatusesMap") return } for za0005, za0006 := range z.ResetStatusesMap { err = en.WriteString(za0005) if err != nil { err = msgp.WrapError(err, "ResetStatusesMap") return } err = en.WriteString(za0006) if err != nil { err = msgp.WrapError(err, "ResetStatusesMap", za0005) return } } return } // MarshalMsg implements msgp.Marshaler func (z *ReplicationState) MarshalMsg(b []byte) (o []byte, err error) { o = msgp.Require(b, z.Msgsize()) // map header, size 10 // string "ReplicaTimeStamp" o = append(o, 0x8a, 0xb0, 0x52, 0x65, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x54, 0x69, 0x6d, 0x65, 0x53, 0x74, 0x61, 0x6d, 0x70) o = msgp.AppendTime(o, z.ReplicaTimeStamp) // string "ReplicaStatus" o = append(o, 0xad, 0x52, 0x65, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73) o, err = z.ReplicaStatus.MarshalMsg(o) if err != nil { err = msgp.WrapError(err, "ReplicaStatus") return } // string "DeleteMarker" o = append(o, 0xac, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x4d, 0x61, 0x72, 0x6b, 0x65, 0x72) o = msgp.AppendBool(o, z.DeleteMarker) // string "ReplicationTimeStamp" o = append(o, 0xb4, 0x52, 0x65, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x54, 0x69, 0x6d, 0x65, 0x53, 0x74, 0x61, 0x6d, 0x70) o = msgp.AppendTime(o, z.ReplicationTimeStamp) // string "ReplicationStatusInternal" o = append(o, 0xb9, 0x52, 0x65, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c) o = msgp.AppendString(o, z.ReplicationStatusInternal) // string "VersionPurgeStatusInternal" o = append(o, 0xba, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x50, 0x75, 0x72, 0x67, 0x65, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c) o = msgp.AppendString(o, z.VersionPurgeStatusInternal) // string "ReplicateDecisionStr" o = append(o, 0xb4, 0x52, 0x65, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x65, 0x44, 0x65, 0x63, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x53, 0x74, 0x72) o = msgp.AppendString(o, z.ReplicateDecisionStr) // string "Targets" o = append(o, 0xa7, 0x54, 0x61, 0x72, 0x67, 0x65, 0x74, 0x73) o = msgp.AppendMapHeader(o, uint32(len(z.Targets))) for za0001, za0002 := range z.Targets { o = msgp.AppendString(o, za0001) o, err = za0002.MarshalMsg(o) if err != nil { err = msgp.WrapError(err, "Targets", za0001) return } } // string "PurgeTargets" o = append(o, 0xac, 0x50, 0x75, 0x72, 0x67, 0x65, 0x54, 0x61, 0x72, 0x67, 0x65, 0x74, 0x73) o = msgp.AppendMapHeader(o, uint32(len(z.PurgeTargets))) for za0003, za0004 := range z.PurgeTargets { o = msgp.AppendString(o, za0003) o = msgp.AppendString(o, string(za0004)) } // string "ResetStatusesMap" o = append(o, 0xb0, 0x52, 0x65, 0x73, 0x65, 0x74, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x65, 0x73, 0x4d, 0x61, 0x70) o = msgp.AppendMapHeader(o, uint32(len(z.ResetStatusesMap))) for za0005, za0006 := range z.ResetStatusesMap { o = msgp.AppendString(o, za0005) o = msgp.AppendString(o, za0006) } return } // UnmarshalMsg implements msgp.Unmarshaler func (z *ReplicationState) UnmarshalMsg(bts []byte) (o []byte, err error) { var field []byte _ = field var zb0001 uint32 zb0001, bts, err = msgp.ReadMapHeaderBytes(bts) if err != nil { err = msgp.WrapError(err) return } for zb0001 > 0 { zb0001-- field, bts, err = msgp.ReadMapKeyZC(bts) if err != nil { err = msgp.WrapError(err) return } switch msgp.UnsafeString(field) { case "ReplicaTimeStamp": z.ReplicaTimeStamp, bts, err = msgp.ReadTimeBytes(bts) if err != nil { err = msgp.WrapError(err, "ReplicaTimeStamp") return } case "ReplicaStatus": bts, err = z.ReplicaStatus.UnmarshalMsg(bts) if err != nil { err = msgp.WrapError(err, "ReplicaStatus") return } case "DeleteMarker": z.DeleteMarker, bts, err = msgp.ReadBoolBytes(bts) if err != nil { err = msgp.WrapError(err, "DeleteMarker") return } case "ReplicationTimeStamp": z.ReplicationTimeStamp, bts, err = msgp.ReadTimeBytes(bts) if err != nil { err = msgp.WrapError(err, "ReplicationTimeStamp") return } case "ReplicationStatusInternal": z.ReplicationStatusInternal, bts, err = msgp.ReadStringBytes(bts) if err != nil { err = msgp.WrapError(err, "ReplicationStatusInternal") return } case "VersionPurgeStatusInternal": z.VersionPurgeStatusInternal, bts, err = msgp.ReadStringBytes(bts) if err != nil { err = msgp.WrapError(err, "VersionPurgeStatusInternal") return } case "ReplicateDecisionStr": z.ReplicateDecisionStr, bts, err = msgp.ReadStringBytes(bts) if err != nil { err = msgp.WrapError(err, "ReplicateDecisionStr") return } case "Targets": var zb0002 uint32 zb0002, bts, err = msgp.ReadMapHeaderBytes(bts) if err != nil { err = msgp.WrapError(err, "Targets") return } if z.Targets == nil { z.Targets = make(map[string]replication.StatusType, zb0002) } else if len(z.Targets) > 0 { for key := range z.Targets { delete(z.Targets, key) } } for zb0002 > 0 { var za0001 string var za0002 replication.StatusType zb0002-- za0001, bts, err = msgp.ReadStringBytes(bts) if err != nil { err = msgp.WrapError(err, "Targets") return } bts, err = za0002.UnmarshalMsg(bts) if err != nil { err = msgp.WrapError(err, "Targets", za0001) return } z.Targets[za0001] = za0002 } case "PurgeTargets": var zb0003 uint32 zb0003, bts, err = msgp.ReadMapHeaderBytes(bts) if err != nil { err = msgp.WrapError(err, "PurgeTargets") return } if z.PurgeTargets == nil { z.PurgeTargets = make(map[string]VersionPurgeStatusType, zb0003) } else if len(z.PurgeTargets) > 0 { for key := range z.PurgeTargets { delete(z.PurgeTargets, key) } } for zb0003 > 0 { var za0003 string var za0004 VersionPurgeStatusType zb0003-- za0003, bts, err = msgp.ReadStringBytes(bts) if err != nil { err = msgp.WrapError(err, "PurgeTargets") return } { var zb0004 string zb0004, bts, err = msgp.ReadStringBytes(bts) if err != nil { err = msgp.WrapError(err, "PurgeTargets", za0003) return } za0004 = VersionPurgeStatusType(zb0004) } z.PurgeTargets[za0003] = za0004 } case "ResetStatusesMap": var zb0005 uint32 zb0005, bts, err = msgp.ReadMapHeaderBytes(bts) if err != nil { err = msgp.WrapError(err, "ResetStatusesMap") return } if z.ResetStatusesMap == nil { z.ResetStatusesMap = make(map[string]string, zb0005) } else if len(z.ResetStatusesMap) > 0 { for key := range z.ResetStatusesMap { delete(z.ResetStatusesMap, key) } } for zb0005 > 0 { var za0005 string var za0006 string zb0005-- za0005, bts, err = msgp.ReadStringBytes(bts) if err != nil { err = msgp.WrapError(err, "ResetStatusesMap") return } za0006, bts, err = msgp.ReadStringBytes(bts) if err != nil { err = msgp.WrapError(err, "ResetStatusesMap", za0005) return } z.ResetStatusesMap[za0005] = za0006 } default: bts, err = msgp.Skip(bts) if err != nil { err = msgp.WrapError(err) return } } } o = bts return } // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message func (z *ReplicationState) Msgsize() (s int) { s = 1 + 17 + msgp.TimeSize + 14 + z.ReplicaStatus.Msgsize() + 13 + msgp.BoolSize + 21 + msgp.TimeSize + 26 + msgp.StringPrefixSize + len(z.ReplicationStatusInternal) + 27 + msgp.StringPrefixSize + len(z.VersionPurgeStatusInternal) + 21 + msgp.StringPrefixSize + len(z.ReplicateDecisionStr) + 8 + msgp.MapHeaderSize if z.Targets != nil { for za0001, za0002 := range z.Targets { _ = za0002 s += msgp.StringPrefixSize + len(za0001) + za0002.Msgsize() } } s += 13 + msgp.MapHeaderSize if z.PurgeTargets != nil { for za0003, za0004 := range z.PurgeTargets { _ = za0004 s += msgp.StringPrefixSize + len(za0003) + msgp.StringPrefixSize + len(string(za0004)) } } s += 17 + msgp.MapHeaderSize if z.ResetStatusesMap != nil { for za0005, za0006 := range z.ResetStatusesMap { _ = za0006 s += msgp.StringPrefixSize + len(za0005) + msgp.StringPrefixSize + len(za0006) } } return } // DecodeMsg implements msgp.Decodable func (z *ResyncDecision) DecodeMsg(dc *msgp.Reader) (err error) { var field []byte _ = field var zb0001 uint32 zb0001, err = dc.ReadMapHeader() if err != nil { err = msgp.WrapError(err) return } for zb0001 > 0 { zb0001-- field, err = dc.ReadMapKeyPtr() if err != nil { err = msgp.WrapError(err) return } switch msgp.UnsafeString(field) { default: err = dc.Skip() if err != nil { err = msgp.WrapError(err) return } } } return } // EncodeMsg implements msgp.Encodable func (z ResyncDecision) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 0 err = en.Append(0x80) if err != nil { return } return } // MarshalMsg implements msgp.Marshaler func (z ResyncDecision) MarshalMsg(b []byte) (o []byte, err error) { o = msgp.Require(b, z.Msgsize()) // map header, size 0 o = append(o, 0x80) return } // UnmarshalMsg implements msgp.Unmarshaler func (z *ResyncDecision) UnmarshalMsg(bts []byte) (o []byte, err error) { var field []byte _ = field var zb0001 uint32 zb0001, bts, err = msgp.ReadMapHeaderBytes(bts) if err != nil { err = msgp.WrapError(err) return } for zb0001 > 0 { zb0001-- field, bts, err = msgp.ReadMapKeyZC(bts) if err != nil { err = msgp.WrapError(err) return } switch msgp.UnsafeString(field) { default: bts, err = msgp.Skip(bts) if err != nil { err = msgp.WrapError(err) return } } } o = bts return } // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message func (z ResyncDecision) Msgsize() (s int) { s = 1 return } // DecodeMsg implements msgp.Decodable func (z *ResyncTarget) DecodeMsg(dc *msgp.Reader) (err error) { var field []byte _ = field var zb0001 uint32 zb0001, err = dc.ReadMapHeader() if err != nil { err = msgp.WrapError(err) return } for zb0001 > 0 { zb0001-- field, err = dc.ReadMapKeyPtr() if err != nil { err = msgp.WrapError(err) return } switch msgp.UnsafeString(field) { case "Arn": z.Arn, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "Arn") return } case "ResetID": z.ResetID, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "ResetID") return } default: err = dc.Skip() if err != nil { err = msgp.WrapError(err) return } } } return } // EncodeMsg implements msgp.Encodable func (z ResyncTarget) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 2 // write "Arn" err = en.Append(0x82, 0xa3, 0x41, 0x72, 0x6e) if err != nil { return } err = en.WriteString(z.Arn) if err != nil { err = msgp.WrapError(err, "Arn") return } // write "ResetID" err = en.Append(0xa7, 0x52, 0x65, 0x73, 0x65, 0x74, 0x49, 0x44) if err != nil { return } err = en.WriteString(z.ResetID) if err != nil { err = msgp.WrapError(err, "ResetID") return } return } // MarshalMsg implements msgp.Marshaler func (z ResyncTarget) MarshalMsg(b []byte) (o []byte, err error) { o = msgp.Require(b, z.Msgsize()) // map header, size 2 // string "Arn" o = append(o, 0x82, 0xa3, 0x41, 0x72, 0x6e) o = msgp.AppendString(o, z.Arn) // string "ResetID" o = append(o, 0xa7, 0x52, 0x65, 0x73, 0x65, 0x74, 0x49, 0x44) o = msgp.AppendString(o, z.ResetID) return } // UnmarshalMsg implements msgp.Unmarshaler func (z *ResyncTarget) UnmarshalMsg(bts []byte) (o []byte, err error) { var field []byte _ = field var zb0001 uint32 zb0001, bts, err = msgp.ReadMapHeaderBytes(bts) if err != nil { err = msgp.WrapError(err) return } for zb0001 > 0 { zb0001-- field, bts, err = msgp.ReadMapKeyZC(bts) if err != nil { err = msgp.WrapError(err) return } switch msgp.UnsafeString(field) { case "Arn": z.Arn, bts, err = msgp.ReadStringBytes(bts) if err != nil { err = msgp.WrapError(err, "Arn") return } case "ResetID": z.ResetID, bts, err = msgp.ReadStringBytes(bts) if err != nil { err = msgp.WrapError(err, "ResetID") return } default: bts, err = msgp.Skip(bts) if err != nil { err = msgp.WrapError(err) return } } } o = bts return } // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message func (z ResyncTarget) Msgsize() (s int) { s = 1 + 4 + msgp.StringPrefixSize + len(z.Arn) + 8 + msgp.StringPrefixSize + len(z.ResetID) return } // DecodeMsg implements msgp.Decodable func (z *ResyncTargetDecision) DecodeMsg(dc *msgp.Reader) (err error) { var field []byte _ = field var zb0001 uint32 zb0001, err = dc.ReadMapHeader() if err != nil { err = msgp.WrapError(err) return } for zb0001 > 0 { zb0001-- field, err = dc.ReadMapKeyPtr() if err != nil { err = msgp.WrapError(err) return } switch msgp.UnsafeString(field) { case "Replicate": z.Replicate, err = dc.ReadBool() if err != nil { err = msgp.WrapError(err, "Replicate") return } case "ResetID": z.ResetID, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "ResetID") return } case "ResetBeforeDate": z.ResetBeforeDate, err = dc.ReadTime() if err != nil { err = msgp.WrapError(err, "ResetBeforeDate") return } default: err = dc.Skip() if err != nil { err = msgp.WrapError(err) return } } } return } // EncodeMsg implements msgp.Encodable func (z ResyncTargetDecision) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 3 // write "Replicate" err = en.Append(0x83, 0xa9, 0x52, 0x65, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x65) if err != nil { return } err = en.WriteBool(z.Replicate) if err != nil { err = msgp.WrapError(err, "Replicate") return } // write "ResetID" err = en.Append(0xa7, 0x52, 0x65, 0x73, 0x65, 0x74, 0x49, 0x44) if err != nil { return } err = en.WriteString(z.ResetID) if err != nil { err = msgp.WrapError(err, "ResetID") return } // write "ResetBeforeDate" err = en.Append(0xaf, 0x52, 0x65, 0x73, 0x65, 0x74, 0x42, 0x65, 0x66, 0x6f, 0x72, 0x65, 0x44, 0x61, 0x74, 0x65) if err != nil { return } err = en.WriteTime(z.ResetBeforeDate) if err != nil { err = msgp.WrapError(err, "ResetBeforeDate") return } return } // MarshalMsg implements msgp.Marshaler func (z ResyncTargetDecision) MarshalMsg(b []byte) (o []byte, err error) { o = msgp.Require(b, z.Msgsize()) // map header, size 3 // string "Replicate" o = append(o, 0x83, 0xa9, 0x52, 0x65, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x65) o = msgp.AppendBool(o, z.Replicate) // string "ResetID" o = append(o, 0xa7, 0x52, 0x65, 0x73, 0x65, 0x74, 0x49, 0x44) o = msgp.AppendString(o, z.ResetID) // string "ResetBeforeDate" o = append(o, 0xaf, 0x52, 0x65, 0x73, 0x65, 0x74, 0x42, 0x65, 0x66, 0x6f, 0x72, 0x65, 0x44, 0x61, 0x74, 0x65) o = msgp.AppendTime(o, z.ResetBeforeDate) return } // UnmarshalMsg implements msgp.Unmarshaler func (z *ResyncTargetDecision) UnmarshalMsg(bts []byte) (o []byte, err error) { var field []byte _ = field var zb0001 uint32 zb0001, bts, err = msgp.ReadMapHeaderBytes(bts) if err != nil { err = msgp.WrapError(err) return } for zb0001 > 0 { zb0001-- field, bts, err = msgp.ReadMapKeyZC(bts) if err != nil { err = msgp.WrapError(err) return } switch msgp.UnsafeString(field) { case "Replicate": z.Replicate, bts, err = msgp.ReadBoolBytes(bts) if err != nil { err = msgp.WrapError(err, "Replicate") return } case "ResetID": z.ResetID, bts, err = msgp.ReadStringBytes(bts) if err != nil { err = msgp.WrapError(err, "ResetID") return } case "ResetBeforeDate": z.ResetBeforeDate, bts, err = msgp.ReadTimeBytes(bts) if err != nil { err = msgp.WrapError(err, "ResetBeforeDate") return } default: bts, err = msgp.Skip(bts) if err != nil { err = msgp.WrapError(err) return } } } o = bts return } // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message func (z ResyncTargetDecision) Msgsize() (s int) { s = 1 + 10 + msgp.BoolSize + 8 + msgp.StringPrefixSize + len(z.ResetID) + 16 + msgp.TimeSize return } // DecodeMsg implements msgp.Decodable func (z *ResyncTargetsInfo) DecodeMsg(dc *msgp.Reader) (err error) { var field []byte _ = field var zb0001 uint32 zb0001, err = dc.ReadMapHeader() if err != nil { err = msgp.WrapError(err) return } for zb0001 > 0 { zb0001-- field, err = dc.ReadMapKeyPtr() if err != nil { err = msgp.WrapError(err) return } switch msgp.UnsafeString(field) { case "Targets": var zb0002 uint32 zb0002, err = dc.ReadArrayHeader() if err != nil { err = msgp.WrapError(err, "Targets") return } if cap(z.Targets) >= int(zb0002) { z.Targets = (z.Targets)[:zb0002] } else { z.Targets = make([]ResyncTarget, zb0002) } for za0001 := range z.Targets { var zb0003 uint32 zb0003, err = dc.ReadMapHeader() if err != nil { err = msgp.WrapError(err, "Targets", za0001) return } for zb0003 > 0 { zb0003-- field, err = dc.ReadMapKeyPtr() if err != nil { err = msgp.WrapError(err, "Targets", za0001) return } switch msgp.UnsafeString(field) { case "Arn": z.Targets[za0001].Arn, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "Targets", za0001, "Arn") return } case "ResetID": z.Targets[za0001].ResetID, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "Targets", za0001, "ResetID") return } default: err = dc.Skip() if err != nil { err = msgp.WrapError(err, "Targets", za0001) return } } } } default: err = dc.Skip() if err != nil { err = msgp.WrapError(err) return } } } return } // EncodeMsg implements msgp.Encodable func (z *ResyncTargetsInfo) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 1 // write "Targets" err = en.Append(0x81, 0xa7, 0x54, 0x61, 0x72, 0x67, 0x65, 0x74, 0x73) if err != nil { return } err = en.WriteArrayHeader(uint32(len(z.Targets))) if err != nil { err = msgp.WrapError(err, "Targets") return } for za0001 := range z.Targets { // map header, size 2 // write "Arn" err = en.Append(0x82, 0xa3, 0x41, 0x72, 0x6e) if err != nil { return } err = en.WriteString(z.Targets[za0001].Arn) if err != nil { err = msgp.WrapError(err, "Targets", za0001, "Arn") return } // write "ResetID" err = en.Append(0xa7, 0x52, 0x65, 0x73, 0x65, 0x74, 0x49, 0x44) if err != nil { return } err = en.WriteString(z.Targets[za0001].ResetID) if err != nil { err = msgp.WrapError(err, "Targets", za0001, "ResetID") return } } return } // MarshalMsg implements msgp.Marshaler func (z *ResyncTargetsInfo) MarshalMsg(b []byte) (o []byte, err error) { o = msgp.Require(b, z.Msgsize()) // map header, size 1 // string "Targets" o = append(o, 0x81, 0xa7, 0x54, 0x61, 0x72, 0x67, 0x65, 0x74, 0x73) o = msgp.AppendArrayHeader(o, uint32(len(z.Targets))) for za0001 := range z.Targets { // map header, size 2 // string "Arn" o = append(o, 0x82, 0xa3, 0x41, 0x72, 0x6e) o = msgp.AppendString(o, z.Targets[za0001].Arn) // string "ResetID" o = append(o, 0xa7, 0x52, 0x65, 0x73, 0x65, 0x74, 0x49, 0x44) o = msgp.AppendString(o, z.Targets[za0001].ResetID) } return } // UnmarshalMsg implements msgp.Unmarshaler func (z *ResyncTargetsInfo) UnmarshalMsg(bts []byte) (o []byte, err error) { var field []byte _ = field var zb0001 uint32 zb0001, bts, err = msgp.ReadMapHeaderBytes(bts) if err != nil { err = msgp.WrapError(err) return } for zb0001 > 0 { zb0001-- field, bts, err = msgp.ReadMapKeyZC(bts) if err != nil { err = msgp.WrapError(err) return } switch msgp.UnsafeString(field) { case "Targets": var zb0002 uint32 zb0002, bts, err = msgp.ReadArrayHeaderBytes(bts) if err != nil { err = msgp.WrapError(err, "Targets") return } if cap(z.Targets) >= int(zb0002) { z.Targets = (z.Targets)[:zb0002] } else { z.Targets = make([]ResyncTarget, zb0002) } for za0001 := range z.Targets { var zb0003 uint32 zb0003, bts, err = msgp.ReadMapHeaderBytes(bts) if err != nil { err = msgp.WrapError(err, "Targets", za0001) return } for zb0003 > 0 { zb0003-- field, bts, err = msgp.ReadMapKeyZC(bts) if err != nil { err = msgp.WrapError(err, "Targets", za0001) return } switch msgp.UnsafeString(field) { case "Arn": z.Targets[za0001].Arn, bts, err = msgp.ReadStringBytes(bts) if err != nil { err = msgp.WrapError(err, "Targets", za0001, "Arn") return } case "ResetID": z.Targets[za0001].ResetID, bts, err = msgp.ReadStringBytes(bts) if err != nil { err = msgp.WrapError(err, "Targets", za0001, "ResetID") return } default: bts, err = msgp.Skip(bts) if err != nil { err = msgp.WrapError(err, "Targets", za0001) return } } } } default: bts, err = msgp.Skip(bts) if err != nil { err = msgp.WrapError(err) return } } } o = bts return } // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message func (z *ResyncTargetsInfo) Msgsize() (s int) { s = 1 + 8 + msgp.ArrayHeaderSize for za0001 := range z.Targets { s += 1 + 4 + msgp.StringPrefixSize + len(z.Targets[za0001].Arn) + 8 + msgp.StringPrefixSize + len(z.Targets[za0001].ResetID) } return } // DecodeMsg implements msgp.Decodable func (z *VersionPurgeStatusType) DecodeMsg(dc *msgp.Reader) (err error) { { var zb0001 string zb0001, err = dc.ReadString() if err != nil { err = msgp.WrapError(err) return } (*z) = VersionPurgeStatusType(zb0001) } return } // EncodeMsg implements msgp.Encodable func (z VersionPurgeStatusType) EncodeMsg(en *msgp.Writer) (err error) { err = en.WriteString(string(z)) if err != nil { err = msgp.WrapError(err) return } return } // MarshalMsg implements msgp.Marshaler func (z VersionPurgeStatusType) MarshalMsg(b []byte) (o []byte, err error) { o = msgp.Require(b, z.Msgsize()) o = msgp.AppendString(o, string(z)) return } // UnmarshalMsg implements msgp.Unmarshaler func (z *VersionPurgeStatusType) UnmarshalMsg(bts []byte) (o []byte, err error) { { var zb0001 string zb0001, bts, err = msgp.ReadStringBytes(bts) if err != nil { err = msgp.WrapError(err) return } (*z) = VersionPurgeStatusType(zb0001) } o = bts return } // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message func (z VersionPurgeStatusType) Msgsize() (s int) { s = msgp.StringPrefixSize + len(string(z)) return }