Method LRem

engine/grpc/client/list.go:283–318

(key string, count int32, value interface{})

}

func (c *Client) LRem(key string, count int32, value interface{}) error {
	client, err := newListGrpcClient(c.Addr)
	if err != nil {
		return errors.New("new grpc client error: " + err.Error())
	}

	req := &glist.GListLRemRequest{
		Key:   key,
		Count: count,
	}

	switch v := value.(type) {
	case string:
		req.Value = &glist.GListLRemRequest_StringValue{StringValue: v}
	case int32:
		req.Value = &glist.GListLRemRequest_Int32Value{Int32Value: v}
	case int64:
		req.Value = &glist.GListLRemRequest_Int64Value{Int64Value: v}
	case float32:
		req.Value = &glist.GListLRemRequest_Float32Value{Float32Value: v}
	case float64:
		req.Value = &glist.GListLRemRequest_Float64Value{Float64Value: v}
	case bool:
		req.Value = &glist.GListLRemRequest_BoolValue{BoolValue: v}
	case []byte:
		req.Value = &glist.GListLRemRequest_BytesValue{BytesValue: v}
	default:
		return errors.New("unknown value type")
	}

	_, err = client.LRem(context.Background(), req)
	if err != nil {
		return errors.New("client LRem failed: " + err.Error())
	}
	return nil
}

func (c *Client) LIndex(key string, index int) (interface{}, error) {
	client, err := newListGrpcClient(c.Addr)