func()

in scheduler/api/thrift/gen-go/scoot/cloudscoot.go [1087:1137]

• 51 lines of code
• 13 McCabe index (conditional complexity)

func (p *CloudScootClient) recvSetRebalanceMinimumDuration() (err error) {
	iprot := p.InputProtocol
	if iprot == nil {
		iprot = p.ProtocolFactory.GetProtocol(p.Transport)
		p.InputProtocol = iprot
	}
	method, mTypeId, seqId, err := iprot.ReadMessageBegin()
	if err != nil {
		return
	}
	if method != "SetRebalanceMinimumDuration" {
		err = thrift.NewTApplicationException(thrift.WRONG_METHOD_NAME, "SetRebalanceMinimumDuration failed: wrong method name")
		return
	}
	if p.SeqId != seqId {
		err = thrift.NewTApplicationException(thrift.BAD_SEQUENCE_ID, "SetRebalanceMinimumDuration failed: out of sequence response")
		return
	}
	if mTypeId == thrift.EXCEPTION {
		error32 := thrift.NewTApplicationException(thrift.UNKNOWN_APPLICATION_EXCEPTION, "Unknown Exception")
		var error33 error
		error33, err = error32.Read(iprot)
		if err != nil {
			return
		}
		if err = iprot.ReadMessageEnd(); err != nil {
			return
		}
		err = error33
		return
	}
	if mTypeId != thrift.REPLY {
		err = thrift.NewTApplicationException(thrift.INVALID_MESSAGE_TYPE_EXCEPTION, "SetRebalanceMinimumDuration failed: invalid message type")
		return
	}
	result := CloudScootSetRebalanceMinimumDurationResult{}
	if err = result.Read(iprot); err != nil {
		return
	}
	if err = iprot.ReadMessageEnd(); err != nil {
		return
	}
	if result.Ir != nil {
		err = result.Ir
		return
	} else if result.Err != nil {
		err = result.Err
		return
	}
	return
}