Method GetTokensWithContext

tars/protocol/res/authf/Auth.tars.go:179–260

GetTokensWithContext is the proxy function for the method defined in the tars file, with the context

(tarsCtx context.Context, request *TokenRequest, opts ...map[string]string)

// GetTokensWithContext is the proxy function for the method defined in the tars file, with the context
func (obj *Auth) GetTokensWithContext(tarsCtx context.Context, request *TokenRequest, opts ...map[string]string) (ret []TokenResponse, err error) {
	var (
		length int32
		have   bool
		ty     byte
	)
	buf := codec.NewBuffer()
	err = request.WriteBlock(buf, 1)
	if err != nil {
		return ret, err
	}

	var statusMap map[string]string
	var contextMap map[string]string
	if len(opts) == 1 {
		contextMap = opts[0]
	} else if len(opts) == 2 {
		contextMap = opts[0]
		statusMap = opts[1]
	}

	tarsResp := new(requestf.ResponsePacket)
	err = obj.servant.TarsInvoke(tarsCtx, 0, "getTokens", buf.ToBytes(), statusMap, contextMap, tarsResp)
	if err != nil {
		return ret, err
	}
	readBuf := codec.NewReader(tools.Int8ToByte(tarsResp.SBuffer))
	_, ty, err = readBuf.SkipToNoCheck(0, true)
	if err != nil {
		return ret, err
	}
	if ty == codec.LIST {
		err = readBuf.ReadInt32(&length, 0, true)
		if err != nil {
			return ret, err
		}
		ret = make([]TokenResponse, length)
		for i0, e0 := int32(0), length; i0 < e0; i0++ {
			err = ret[i0].ReadBlock(readBuf, 0, true)
			if err != nil {
				return ret, err
			}
		}
	} else if ty == codec.SimpleList {
		err = fmt.Errorf("not support SimpleList type")
		if err != nil {
			return ret, err
		}
	} else {
		err = fmt.Errorf("require vector, but not")
		if err != nil {
			return ret, err
		}
	}

	if len(opts) == 1 {
		for k := range contextMap {
			delete(contextMap, k)